summaryrefslogtreecommitdiffstats
path: root/src/main/java/org/openecomp/datarouter/entity/AggregationEntity.java
diff options
context:
space:
mode:
authorArul.Nambi <arul.nambi@amdocs.com>2017-09-13 14:33:37 -0400
committerArul.Nambi <arul.nambi@amdocs.com>2017-09-13 14:34:08 -0400
commitda309841ad25ab47537a6d2de00cd98bd113392c (patch)
tree2c9760180ebe02511a7ad132ff7f2f1a55c44ed8 /src/main/java/org/openecomp/datarouter/entity/AggregationEntity.java
parent553712cafeb9b68f0dfab1262a3f4a9230e3404d (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.java122
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 + "]";
- }
-}