diff options
Diffstat (limited to 'dcae-analytics-cdap-common/src/main/java/org/openecomp/dcae/apod/analytics/cdap/common/persistance/tca/TCAMessageStatusEntity.java')
-rw-r--r-- | dcae-analytics-cdap-common/src/main/java/org/openecomp/dcae/apod/analytics/cdap/common/persistance/tca/TCAMessageStatusEntity.java | 91 |
1 files changed, 43 insertions, 48 deletions
diff --git a/dcae-analytics-cdap-common/src/main/java/org/openecomp/dcae/apod/analytics/cdap/common/persistance/tca/TCAMessageStatusEntity.java b/dcae-analytics-cdap-common/src/main/java/org/openecomp/dcae/apod/analytics/cdap/common/persistance/tca/TCAMessageStatusEntity.java index c529e55..d6b3099 100644 --- a/dcae-analytics-cdap-common/src/main/java/org/openecomp/dcae/apod/analytics/cdap/common/persistance/tca/TCAMessageStatusEntity.java +++ b/dcae-analytics-cdap-common/src/main/java/org/openecomp/dcae/apod/analytics/cdap/common/persistance/tca/TCAMessageStatusEntity.java @@ -22,12 +22,11 @@ package org.openecomp.dcae.apod.analytics.cdap.common.persistance.tca; import org.apache.hadoop.io.Writable; import org.apache.hadoop.io.WritableUtils; -import org.openecomp.dcae.apod.analytics.model.domain.cef.EventSeverity; import org.openecomp.dcae.apod.analytics.model.domain.policy.tca.Direction; import org.openecomp.dcae.apod.analytics.model.domain.policy.tca.TCAPolicy; import org.openecomp.dcae.apod.analytics.tca.processor.TCACEFJsonProcessor; import org.openecomp.dcae.apod.analytics.tca.processor.TCACEFPolicyDomainFilter; -import org.openecomp.dcae.apod.analytics.tca.processor.TCACEFPolicyFunctionalRoleFilter; +import org.openecomp.dcae.apod.analytics.tca.processor.TCACEFPolicyEventNameFilter; import org.openecomp.dcae.apod.analytics.tca.processor.TCACEFPolicyThresholdsProcessor; import java.io.DataInput; @@ -49,7 +48,7 @@ public class TCAMessageStatusEntity implements Writable, Serializable { private String messageType; private String vesMessage; private String domain; - private String functionalRole; + private String eventName; private String thresholdPath; private String thresholdSeverity; private String thresholdDirection; @@ -58,8 +57,8 @@ public class TCAMessageStatusEntity implements Writable, Serializable { private String jsonProcessorMessage; private String domainFilterStatus; private String domainFilterMessage; - private String functionalRoleFilterStatus; - private String functionalRoleFilterMessage; + private String eventNameFilterStatus; + private String eventNameFilterMessage; private String thresholdCalculatorStatus; private String thresholdCalculatorMessage; private String alertMessage; @@ -79,11 +78,11 @@ public class TCAMessageStatusEntity implements Writable, Serializable { * @param messageType {@link TCACalculatorMessageType} * @param vesMessage incoming VES message from collector * @param domain VES message domain if present - * @param functionalRole VES message functional role if present + * @param eventName VES message functional role if present */ public TCAMessageStatusEntity(final long creationTS, final int instanceId, final String messageType, - final String vesMessage, final String domain, final String functionalRole) { - this(creationTS, instanceId, messageType, vesMessage, domain, functionalRole, null, null, null, null, + final String vesMessage, final String domain, final String eventName) { + this(creationTS, instanceId, messageType, vesMessage, domain, eventName, null, null, null, null, null, null, null, null, null, null, null, null, null); } @@ -96,7 +95,7 @@ public class TCAMessageStatusEntity implements Writable, Serializable { * @param messageType {@link TCACalculatorMessageType} * @param vesMessage incoming VES message from collector * @param domain VES message domain if present - * @param functionalRole VES message functional role if present + * @param eventName VES message event name if present * @param thresholdPath Violated threshold path * @param thresholdSeverity Violated threshold Severity if any * @param thresholdDirection Violated threshold Direction if any @@ -105,23 +104,19 @@ public class TCAMessageStatusEntity implements Writable, Serializable { * @param jsonProcessorMessage {@link TCACEFJsonProcessor} message * @param domainFilterStatus {@link TCACEFPolicyDomainFilter} status * @param domainFilterMessage {@link TCACEFPolicyDomainFilter} message - * @param functionalRoleFilterStatus - * {@link TCACEFPolicyFunctionalRoleFilter} status - * @param functionalRoleFilterMessage - * {@link TCACEFPolicyFunctionalRoleFilter} message - * @param thresholdCalculatorStatus - * {@link TCACEFPolicyThresholdsProcessor} status - * @param thresholdCalculatorMessage - * {@link TCACEFPolicyThresholdsProcessor} message + * @param eventNameFilterStatus {@link TCACEFPolicyEventNameFilter} status + * @param eventNameFilterMessage {@link TCACEFPolicyEventNameFilter} message + * @param thresholdCalculatorStatus {@link TCACEFPolicyThresholdsProcessor} status + * @param thresholdCalculatorMessage {@link TCACEFPolicyThresholdsProcessor} message * @param alertMessage alert message that will be sent out in case of threshold violation */ public TCAMessageStatusEntity(long creationTS, int instanceId, String messageType, String vesMessage, - String domain, String functionalRole, + String domain, String eventName, String thresholdPath, String thresholdSeverity, String thresholdDirection, Long thresholdValue, String jsonProcessorStatus, String jsonProcessorMessage, String domainFilterStatus, String domainFilterMessage, - String functionalRoleFilterStatus, String functionalRoleFilterMessage, + String eventNameFilterStatus, String eventNameFilterMessage, String thresholdCalculatorStatus, String thresholdCalculatorMessage, String alertMessage) { this.creationTS = creationTS; @@ -129,7 +124,7 @@ public class TCAMessageStatusEntity implements Writable, Serializable { this.messageType = messageType; this.vesMessage = vesMessage; this.domain = domain; - this.functionalRole = functionalRole; + this.eventName = eventName; this.thresholdPath = thresholdPath; this.thresholdSeverity = thresholdSeverity; this.thresholdDirection = thresholdDirection; @@ -138,8 +133,8 @@ public class TCAMessageStatusEntity implements Writable, Serializable { this.jsonProcessorMessage = jsonProcessorMessage; this.domainFilterStatus = domainFilterStatus; this.domainFilterMessage = domainFilterMessage; - this.functionalRoleFilterStatus = functionalRoleFilterStatus; - this.functionalRoleFilterMessage = functionalRoleFilterMessage; + this.eventNameFilterStatus = eventNameFilterStatus; + this.eventNameFilterMessage = eventNameFilterMessage; this.thresholdCalculatorStatus = thresholdCalculatorStatus; this.thresholdCalculatorMessage = thresholdCalculatorMessage; this.alertMessage = alertMessage; @@ -237,21 +232,21 @@ public class TCAMessageStatusEntity implements Writable, Serializable { } /** - * Provides VES Message Functional Role + * Provides VES Message Event Name * - * @return ves message functional role + * @return ves message Event Name */ - public String getFunctionalRole() { - return functionalRole; + public String getEventName() { + return eventName; } /** * Sets VES Message Functional Role * - * @param functionalRole ves message Functional Role + * @param eventName ves message Functional Role */ - public void setFunctionalRole(String functionalRole) { - this.functionalRole = functionalRole; + public void setEventName(String eventName) { + this.eventName = eventName; } /** @@ -273,7 +268,7 @@ public class TCAMessageStatusEntity implements Writable, Serializable { } /** - * Violated threshold {@link EventSeverity} + * Violated threshold Event Severity * * @return event severity */ @@ -398,35 +393,35 @@ public class TCAMessageStatusEntity implements Writable, Serializable { this.domainFilterMessage = domainFilterMessage; } - public String getFunctionalRoleFilterStatus() { - return functionalRoleFilterStatus; + public String getEventNameFilterStatus() { + return eventNameFilterStatus; } /** - * Provides {@link TCACEFPolicyFunctionalRoleFilter} status + * Provides {@link TCACEFPolicyEventNameFilter} status * - * @param functionalRoleFilterStatus functional Role filter status + * @param eventNameFilterStatus functional Role filter status */ - public void setFunctionalRoleFilterStatus(String functionalRoleFilterStatus) { - this.functionalRoleFilterStatus = functionalRoleFilterStatus; + public void setEventNameFilterStatus(String eventNameFilterStatus) { + this.eventNameFilterStatus = eventNameFilterStatus; } /** - * Provides {@link TCACEFPolicyFunctionalRoleFilter} message + * Provides {@link TCACEFPolicyEventNameFilter} message * * @return functional role filter message */ - public String getFunctionalRoleFilterMessage() { - return functionalRoleFilterMessage; + public String getEventNameFilterMessage() { + return eventNameFilterMessage; } /** * Sets Functional Role filter message * - * @param functionalRoleFilterMessage functional role filter message + * @param eventNameFilterMessage functional role filter message */ - public void setFunctionalRoleFilterMessage(String functionalRoleFilterMessage) { - this.functionalRoleFilterMessage = functionalRoleFilterMessage; + public void setEventNameFilterMessage(String eventNameFilterMessage) { + this.eventNameFilterMessage = eventNameFilterMessage; } /** @@ -498,7 +493,7 @@ public class TCAMessageStatusEntity implements Writable, Serializable { WritableUtils.writeString(dataOutput, vesMessage); WritableUtils.writeString(dataOutput, domain); - WritableUtils.writeString(dataOutput, functionalRole); + WritableUtils.writeString(dataOutput, eventName); WritableUtils.writeString(dataOutput, thresholdPath); WritableUtils.writeString(dataOutput, thresholdSeverity); @@ -509,8 +504,8 @@ public class TCAMessageStatusEntity implements Writable, Serializable { WritableUtils.writeString(dataOutput, jsonProcessorMessage); WritableUtils.writeString(dataOutput, domainFilterStatus); WritableUtils.writeString(dataOutput, domainFilterMessage); - WritableUtils.writeString(dataOutput, functionalRoleFilterStatus); - WritableUtils.writeString(dataOutput, functionalRoleFilterMessage); + WritableUtils.writeString(dataOutput, eventNameFilterStatus); + WritableUtils.writeString(dataOutput, eventNameFilterMessage); WritableUtils.writeString(dataOutput, thresholdCalculatorStatus); WritableUtils.writeString(dataOutput, thresholdCalculatorMessage); @@ -532,7 +527,7 @@ public class TCAMessageStatusEntity implements Writable, Serializable { vesMessage = WritableUtils.readString(dataInput); domain = WritableUtils.readString(dataInput); - functionalRole = WritableUtils.readString(dataInput); + eventName = WritableUtils.readString(dataInput); thresholdPath = WritableUtils.readString(dataInput); thresholdSeverity = WritableUtils.readString(dataInput); @@ -543,8 +538,8 @@ public class TCAMessageStatusEntity implements Writable, Serializable { jsonProcessorMessage = WritableUtils.readString(dataInput); domainFilterStatus = WritableUtils.readString(dataInput); domainFilterMessage = WritableUtils.readString(dataInput); - functionalRoleFilterStatus = WritableUtils.readString(dataInput); - functionalRoleFilterMessage = WritableUtils.readString(dataInput); + eventNameFilterStatus = WritableUtils.readString(dataInput); + eventNameFilterMessage = WritableUtils.readString(dataInput); thresholdCalculatorStatus = WritableUtils.readString(dataInput); thresholdCalculatorMessage = WritableUtils.readString(dataInput); |