diff options
author | 2017-09-13 14:33:37 -0400 | |
---|---|---|
committer | 2017-09-13 14:34:08 -0400 | |
commit | da309841ad25ab47537a6d2de00cd98bd113392c (patch) | |
tree | 2c9760180ebe02511a7ad132ff7f2f1a55c44ed8 /src/main/java/org/openecomp/datarouter/entity/AggregationEntity.java | |
parent | 553712cafeb9b68f0dfab1262a3f4a9230e3404d (diff) |
Renaming openecomp to onap
Issue-ID: AAI-208
Change-Id: Ib940bd2c32ad8eece6053a759cec294126c797ab
Signed-off-by: Arul.Nambi <arul.nambi@amdocs.com>
Diffstat (limited to 'src/main/java/org/openecomp/datarouter/entity/AggregationEntity.java')
-rw-r--r-- | src/main/java/org/openecomp/datarouter/entity/AggregationEntity.java | 122 |
1 files changed, 0 insertions, 122 deletions
diff --git a/src/main/java/org/openecomp/datarouter/entity/AggregationEntity.java b/src/main/java/org/openecomp/datarouter/entity/AggregationEntity.java deleted file mode 100644 index 57a5f5c..0000000 --- a/src/main/java/org/openecomp/datarouter/entity/AggregationEntity.java +++ /dev/null @@ -1,122 +0,0 @@ -/** - * ============LICENSE_START======================================================= - * org.onap.aai - * ================================================================================ - * Copyright © 2017 AT&T Intellectual Property. All rights reserved. - * Copyright © 2017 Amdocs - * ================================================================================ - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * ============LICENSE_END========================================================= - * - * ECOMP is a trademark and service mark of AT&T Intellectual Property. - */ -package org.openecomp.datarouter.entity; - -import java.io.Serializable; -import java.util.Arrays; -import java.util.HashMap; -import java.util.Iterator; -import java.util.Map; -import java.util.Map.Entry; - -import org.openecomp.datarouter.util.NodeUtils; - -import com.fasterxml.jackson.databind.JsonNode; -import com.fasterxml.jackson.databind.ObjectMapper; -import com.fasterxml.jackson.databind.node.ObjectNode; - -/** - * The Class AggregationEntity. Mimics functionality of AAIUI's AggregationEntity - */ -public class AggregationEntity implements DocumentStoreDataEntity, Serializable { - private String id; - private String link; - private String lastmodTimestamp; - - public String getLink() { - return link; - } - public void setLink(String link) { - this.link = link; - } - public String getId() { - // make sure that deliveFields() is called before getting the id - return id; - } - public void setId(String id) { - this.id = id; - } - - - public String getLastmodTimestamp() { - return lastmodTimestamp; - } - public void setLastmodTimestamp(String lastmodTimestamp) { - this.lastmodTimestamp = lastmodTimestamp; - } - - - Map<String, String> attributes = new HashMap<String, String>(); - ObjectMapper mapper = new ObjectMapper(); - - /** - * Instantiates a new aggregation entity. - */ - public AggregationEntity() { } - - public void deriveFields(JsonNode uebPayload) { - - this.setId(NodeUtils.generateUniqueShaDigest(link)); - - this.setLastmodTimestamp(Long.toString(System.currentTimeMillis())); - - JsonNode entityNode = uebPayload.get("entity"); - - Iterator<Entry<String, JsonNode>> nodes = entityNode.fields(); - - while (nodes.hasNext()) { - Map.Entry<String, JsonNode> entry = (Map.Entry<String, JsonNode>) nodes.next(); - if (!entry.getKey().equalsIgnoreCase("relationship-list")){ - attributes.put(entry.getKey(), entry.getValue().asText()); - } - } - } - - public void copyAttributeKeyValuePair(Map<String, Object> map){ - for(String key: map.keySet()){ - if (!key.equalsIgnoreCase("relationship-list")){ // ignore relationship data which is not required in aggregation - this.attributes.put(key, map.get(key).toString()); // not sure if entity attribute can contain an object as value - } - } - } - - public void addAttributeKeyValuePair(String key, String value){ - this.attributes.put(key, value); - } - - public String getAsJson() { - ObjectNode rootNode = mapper.createObjectNode(); - rootNode.put("link", this.getLink()); - rootNode.put("lastmodTimestamp", lastmodTimestamp); - for (String key: this.attributes.keySet()){ - rootNode.put(key, this.attributes.get(key)); - } - return rootNode.toString(); - } - - @Override - public String toString() { - return "AggregationEntity [id=" + id + ", link=" + link + ", attributes=" + attributes - + ", mapper=" + mapper + "]"; - } -} |