diff options
author | an4828 <nekrassov@att.com> | 2017-09-15 15:28:53 -0400 |
---|---|---|
committer | an4828 <nekrassov@att.com> | 2017-09-18 09:24:04 -0400 |
commit | 4edf0fa48892bf38d0e3838d125e9bf2324b38e0 (patch) | |
tree | 7216dae042828ec2cf38cb9300af1a32a17b3b91 /dcae-analytics-cdap-tca/src/main/java/org/openecomp/dcae/apod/analytics/cdap/tca/flowlet/TCAVESMessageRouterFlowlet.java | |
parent | 82aaf956855507e5a72d5ef5b45e398430d04a7a (diff) |
Add support for ABATED alerts within CDAP TCA
Change-Id: Iae560a2d0a47b30b41cd31206dc481a08e4930f7
Signed-off-by: an4828 <nekrassov@att.com>
Issue-ID: DCAEGEN2-107
Signed-off-by: an4828 <nekrassov@att.com>
Diffstat (limited to 'dcae-analytics-cdap-tca/src/main/java/org/openecomp/dcae/apod/analytics/cdap/tca/flowlet/TCAVESMessageRouterFlowlet.java')
-rw-r--r-- | dcae-analytics-cdap-tca/src/main/java/org/openecomp/dcae/apod/analytics/cdap/tca/flowlet/TCAVESMessageRouterFlowlet.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/dcae-analytics-cdap-tca/src/main/java/org/openecomp/dcae/apod/analytics/cdap/tca/flowlet/TCAVESMessageRouterFlowlet.java b/dcae-analytics-cdap-tca/src/main/java/org/openecomp/dcae/apod/analytics/cdap/tca/flowlet/TCAVESMessageRouterFlowlet.java index 3023c90..b32173b 100644 --- a/dcae-analytics-cdap-tca/src/main/java/org/openecomp/dcae/apod/analytics/cdap/tca/flowlet/TCAVESMessageRouterFlowlet.java +++ b/dcae-analytics-cdap-tca/src/main/java/org/openecomp/dcae/apod/analytics/cdap/tca/flowlet/TCAVESMessageRouterFlowlet.java @@ -27,8 +27,7 @@ import co.cask.cdap.api.flow.flowlet.OutputEmitter; import co.cask.cdap.api.flow.flowlet.StreamEvent; import com.google.common.base.Charsets; import org.openecomp.dcae.apod.analytics.cdap.common.CDAPComponentsConstants; - -import static org.openecomp.dcae.apod.analytics.common.AnalyticsConstants.TCA_VES_MESSAGE_ROUTER_PARTITION_KEY; +import org.openecomp.dcae.apod.analytics.common.AnalyticsConstants; /** @@ -54,6 +53,7 @@ public class TCAVESMessageRouterFlowlet extends AbstractFlowlet { @ProcessInput public void routeVESMessage(StreamEvent vesMessageStreamEvent) { final String vesMessage = Charsets.UTF_8.decode(vesMessageStreamEvent.getBody()).toString(); - vesMessageEmitter.emit(vesMessage, TCA_VES_MESSAGE_ROUTER_PARTITION_KEY, vesMessage.hashCode()); + vesMessageEmitter.emit( + vesMessage, AnalyticsConstants.TCA_VES_MESSAGE_ROUTER_PARTITION_KEY, vesMessage.hashCode()); } } |