-/*
- * ===============================LICENSE_START======================================
- * dcae-analytics
- * ================================================================================
- * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * 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===========================================
- */
-
-package org.openecomp.dcae.apod.analytics.cdap.common;
-
-/**
- * Contains static constant variable names and values of all DCAE CDAP Components for
- * e.g. app names, app descriptions, streams, datasets, flows, flowlets, workers, outputs etc.
- *
- * <p>
- * A strict naming convention must be followed for variable names for CDAP Components names for proper
- * identification of CDAP Component variable purpose and function. A custom configuration settings can be
- * generated for app
- * deployment purposes based on variable naming conventions.
- *
- * The variable names should have 4 parts separated by an underscore:
- * <ul>
- * <li>Name of the DCAE sub module (e.g. TCA) to which variable is applicable</li>
- * <li>Information about variable name:
- * <ul>
- * <li>FIXED - if variable value is fixed and cannot be changed</li>
- * <li>DEFAULT - if variable name is default name and can be changed by cdap settings file
- * when application is created</li>
- * </ul>
- * </li>
- * <li>Actual Descriptive name about the CDAP component (may contain underscrores) </li>
- * <li>CDAP component type e.g STREAM, DATASET, APP, FLOW, FLOWLET, OUTPUT</li>
- * </ul>
- *
- * <p>e.g TCA_DEFAULT_DMAAP_INPUT_STREAM</p>
- *
- * <p><strong>RegEx Format (DCAE MODULE NAME)_(FIXED|DEFAULT)_(VARIABLE NAME)_(CDAP COMPONENT TYPE)</strong></p>
- *
- * @author Rajiv Singla . Creation Date: 10/24/2016.
- */
-public abstract class CDAPComponentsConstants {
-
- // =============== Common Module Constants ==================== //
-
- /**
- * Default DCAE App Name. It should be overriden by sub modules
- */
- public static final String COMMON_DEFAULT_DCAE_CDAP_NAME_APP = "DCAE_ANALYTICS_GENERIC_APP";
-
- /**
- * Default DCAE App Description. It should be overriden by sub modules
- */
- public static final String COMMON_DEFAULT_DCAE_CDAP_DESCRIPTION_APP = "DCAE ANALYTICS GENERIC APP DESCRIPTION";
-
- // =============== TCA Module Constants ==================== //
-
- /**
- * Default TCA application name if application name is not provided from startup configuration
- */
- public static final String TCA_DEFAULT_NAME_APP = "dcae-tca";
-
- /**
- * Default TCA application description if not provided from startup configuration
- */
- public static final String TCA_DEFAULT_DESCRIPTION_APP = "DCAE Analytics Threshold Crossing Alert Application";
-
- /**
- * Default TCA DMaaP Subscriber output stream name if not provided from startup configuration
- */
- public static final String TCA_DEFAULT_SUBSCRIBER_OUTPUT_NAME_STREAM = "TCASubscriberOutputStream";
-
-
- /**
- * Fixed TCA DMaaP Subscriber output stream description
- */
- public static final String TCA_FIXED_SUBSCRIBER_OUTPUT_DESCRIPTION_STREAM =
- "Stream which contains all message from VES Collector DMaaP MR topic";
-
-
- /**
- * Fixed Name of TCA DMaaP Subscriber Worker - which will be fetching DMaaP Messages posting them to CDAP stream
- */
- public static final String TCA_FIXED_DMAAP_SUBSCRIBER_WORKER = "TCADMaaPMRSubscriberWorker";
-
- /**
- * Fixed Description of TCA DMaaP Subscriber Worker
- */
- public static final String TCA_FIXED_DMAAP_SUBSCRIBER_DESCRIPTION_WORKER =
- "Fetches messages from DMaaP MR Topic at frequent intervals and writes them to a CDAP stream";
-
- /**
- * Fixed Name of TCA DMaaP Publisher Worker - which will be publishing messages to DMaaP MR
- */
- public static final String TCA_FIXED_DMAAP_PUBLISHER_WORKER = "TCADMaaPMRPublisherWorker";
-
- /**
- * Fixed Description of TCA DMaaP Publisher Worker
- */
- public static final String TCA_FIXED_DMAAP_PUBLISHER_DESCRIPTION_WORKER =
- "Polls TCA Alerts Table at frequent intervals for new alerts and publishes them to DMaaP MR Topic";
-
- /**
- * Fixed name for TCA VES Collector Messages Processing Flow
- */
- public static final String TCA_FIXED_VES_COLLECTOR_NAME_FLOW = "TCAVESCollectorFlow";
-
-
- /**
- * Fixed description for TCA VES Collector Messages Processing Flow
- */
- public static final String TCA_FIXED_VES_COLLECTOR_DESCRIPTION_FLOW = "Flow performs TCA on VES Collector Messages";
-
-
- /**
- * Fixed Name for TCA VES Message Router Flowlet
- */
- public static final String TCA_FIXED_VES_MESSAGE_ROUTER_NAME_FLOWLET = "TCAVESMessageRouterFlowlet";
-
- /**
- * Fixed Description for TCA VES Message Router Flowlet
- */
- public static final String TCA_FIXED_VES_MESSAGE_ROUTER_DESCRIPTION_FLOWLET =
- "Routes message received from TCA VES Collector to TCA Threshold Calculator Flowlet instances";
-
- /**
- * Fixed TCA VES Message Router Flowlet Output
- */
- public static final String TCA_FIXED_VES_MESSAGE_ROUTER_OUTPUT = "TCAVESMessageRouterFlowlet";
-
- /**
- * Fixed Name for TCA VES Message Policy Violated Threshold Calculator Flowlet
- */
- public static final String TCA_FIXED_VES_THRESHOLD_VIOLATION_CALCULATOR_NAME_FLOWLET =
- "TCAVESThresholdViolationCalculatorFlowlet";
-
- /**
- * Fixed Description for TCA VES Message Policy Violated Threshold Calculator Flowlet
- */
- public static final String TCA_FIXED_VES_THRESHOLD_VIOLATION_CALCULATOR_DESCRIPTION_FLOWLET =
- "Applies TCA Policy Thresholds to VES Message and determined if any message violated TCA Policy thresholds";
-
- /**
- * Fixed Name for TCA VES Message Policy Violated Threshold Calculator Output
- */
- public static final String TCA_FIXED_VES_TCA_CALCULATOR_NAME_OUTPUT = "TCAThresholdViolationCalculatorOutput";
-
-
- /**
- * Fixed Name for TCA VES Alerts Abatement Flowlet
- */
- public static final String TCA_FIXED_VES_ALERTS_ABATEMENT_NAME_FLOWLET = "TCAVESAlertsAbatementFlowlet";
-
- /**
- * Fixed Description for TCA VES Alerts Abatement Flowlet
- */
- public static final String TCA_FIXED_VES_ALERTS_ABATEMENT_DESCRIPTION_FLOWLET =
- "Determines if abatement event needs to be posted to downstream systems";
-
- /**
- * Fixed Name for TCA VES Alerts Abatement Flowlet output
- */
- public static final String TCA_FIXED_VES_ALERTS_ABATEMENT_NAME_OUTPUT = "TCAVESAlertsAbatementFlowletOutput";
-
- /**
- * Fixed Name for TCA VES Alerts Sink Flowlet
- */
- public static final String TCA_FIXED_VES_ALERTS_SINK_NAME_FLOWLET = "TCAVESAlertsSinkFlowlet";
-
- /**
- * Fixed Description for TCA VES Alerts Sink Flowlet
- */
- public static final String TCA_FIXED_VES_ALERTS_SINK_DESCRIPTION_FLOWLET =
- "Saves messages which violated TCA Policy in a data set";
-
-
- /**
- * Default Name for TCA VES Message status table which contain status of all messages processed by TCA
- */
- public static final String TCA_DEFAULT_VES_MESSAGE_STATUS_NAME_TABLE = "TCAVESMessageStatusTable";
-
-
- /**
- * Fixed Description for TCA VES Message status table which contain status of all messages processed by TCA
- */
- public static final String TCA_FIXED_VES_MESSAGE_STATUS_DESCRIPTION_TABLE =
- "Store processing information about all incoming TCA VES Messages";
-
- /**
- * Default Name for TCA VES Alerts table which contains alerts that can be send to downstream systems
- */
- public static final String TCA_DEFAULT_VES_ALERTS_NAME_TABLE = "TCAVESAlertsTable";
-
- /**
- * Fixed Description for TCA VES Alerts table which contains alerts that can be send to downstream systems
- */
- public static final String TCA_FIXED_VES_ALERTS_DESCRIPTION_TABLE =
- "Stores alert messages that need to be DMaaP";
-
- /**
- * Default Name for TCA Alerts abatement table which contains information to send out abated alerts
- */
- public static final String TCA_DEFAULT_ALERTS_ABATEMENT_NAME_TABLE = "TCAAlertsAbatementTable";
-
- /**
- * Fixed Description for TCA Alerts abatement table which contains information to determine abatement alerts
- */
- public static final String TCA_FIXED_ALERTS_ABATEMENT_DESCRIPTION_TABLE =
- "Stores information to determine creation of abatement alerts";
-
-
- private CDAPComponentsConstants() {
-
- }
-
-}
+/*\r
+ * ===============================LICENSE_START======================================\r
+ * dcae-analytics\r
+ * ================================================================================\r
+ * Copyright © 2017 AT&T Intellectual Property. All rights reserved.\r
+ * ================================================================================\r
+ * Licensed under the Apache License, Version 2.0 (the "License");\r
+ * you may not use this file except in compliance with the License.\r
+ * You may obtain a copy of the License at\r
+ *\r
+ * http://www.apache.org/licenses/LICENSE-2.0\r
+ *\r
+ * Unless required by applicable law or agreed to in writing, software\r
+ * distributed under the License is distributed on an "AS IS" BASIS,\r
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+ * See the License for the specific language governing permissions and\r
+ * limitations under the License.\r
+ * ============================LICENSE_END===========================================\r
+ */\r
+\r
+package org.openecomp.dcae.apod.analytics.cdap.common;\r
+\r
+/**\r
+ * Contains static constant variable names and values of all DCAE CDAP Components for\r
+ * e.g. app names, app descriptions, streams, datasets, flows, flowlets, workers, outputs etc.\r
+ *\r
+ * <p>\r
+ * A strict naming convention must be followed for variable names for CDAP Components names for proper\r
+ * identification of CDAP Component variable purpose and function. A custom configuration settings can be\r
+ * generated for app\r
+ * deployment purposes based on variable naming conventions.\r
+ *\r
+ * The variable names should have 4 parts separated by an underscore:\r
+ * <ul>\r
+ * <li>Name of the DCAE sub module (e.g. TCA) to which variable is applicable</li>\r
+ * <li>Information about variable name:\r
+ * <ul>\r
+ * <li>FIXED - if variable value is fixed and cannot be changed</li>\r
+ * <li>DEFAULT - if variable name is default name and can be changed by cdap settings file\r
+ * when application is created</li>\r
+ * </ul>\r
+ * </li>\r
+ * <li>Actual Descriptive name about the CDAP component (may contain underscrores) </li>\r
+ * <li>CDAP component type e.g STREAM, DATASET, APP, FLOW, FLOWLET, OUTPUT</li>\r
+ * </ul>\r
+ *\r
+ * <p>e.g TCA_DEFAULT_DMAAP_INPUT_STREAM</p>\r
+ *\r
+ * <p><strong>RegEx Format (DCAE MODULE NAME)_(FIXED|DEFAULT)_(VARIABLE NAME)_(CDAP COMPONENT TYPE)</strong></p>\r
+ *\r
+ * @author Rajiv Singla . Creation Date: 10/24/2016.\r
+ */\r
+public abstract class CDAPComponentsConstants {\r
+\r
+ // =============== Common Module Constants ==================== //\r
+\r
+ /**\r
+ * Default DCAE App Name. It should be overriden by sub modules\r
+ */\r
+ public static final String COMMON_DEFAULT_DCAE_CDAP_NAME_APP = "DCAE_ANALYTICS_GENERIC_APP";\r
+\r
+ /**\r
+ * Default DCAE App Description. It should be overriden by sub modules\r
+ */\r
+ public static final String COMMON_DEFAULT_DCAE_CDAP_DESCRIPTION_APP = "DCAE ANALYTICS GENERIC APP DESCRIPTION";\r
+\r
+ // =============== TCA Module Constants ==================== //\r
+\r
+ /**\r
+ * Default TCA application name if application name is not provided from startup configuration\r
+ */\r
+ public static final String TCA_DEFAULT_NAME_APP = "dcae-tca";\r
+\r
+ /**\r
+ * Default TCA application description if not provided from startup configuration\r
+ */\r
+ public static final String TCA_DEFAULT_DESCRIPTION_APP = "DCAE Analytics Threshold Crossing Alert Application";\r
+\r
+ /**\r
+ * Default TCA DMaaP Subscriber output stream name if not provided from startup configuration\r
+ */\r
+ public static final String TCA_DEFAULT_SUBSCRIBER_OUTPUT_NAME_STREAM = "TCASubscriberOutputStream";\r
+\r
+\r
+ /**\r
+ * Fixed TCA DMaaP Subscriber output stream description\r
+ */\r
+ public static final String TCA_FIXED_SUBSCRIBER_OUTPUT_DESCRIPTION_STREAM =\r
+ "Stream which contains all message from VES Collector DMaaP MR topic";\r
+\r
+\r
+ /**\r
+ * Fixed Name of TCA DMaaP Subscriber Worker - which will be fetching DMaaP Messages posting them to CDAP stream\r
+ */\r
+ public static final String TCA_FIXED_DMAAP_SUBSCRIBER_WORKER = "TCADMaaPMRSubscriberWorker";\r
+\r
+ /**\r
+ * Fixed Description of TCA DMaaP Subscriber Worker\r
+ */\r
+ public static final String TCA_FIXED_DMAAP_SUBSCRIBER_DESCRIPTION_WORKER =\r
+ "Fetches messages from DMaaP MR Topic at frequent intervals and writes them to a CDAP stream";\r
+\r
+ /**\r
+ * Fixed Name of TCA DMaaP Publisher Worker - which will be publishing messages to DMaaP MR\r
+ */\r
+ public static final String TCA_FIXED_DMAAP_PUBLISHER_WORKER = "TCADMaaPMRPublisherWorker";\r
+\r
+ /**\r
+ * Fixed Description of TCA DMaaP Publisher Worker\r
+ */\r
+ public static final String TCA_FIXED_DMAAP_PUBLISHER_DESCRIPTION_WORKER =\r
+ "Polls TCA Alerts Table at frequent intervals for new alerts and publishes them to DMaaP MR Topic";\r
+\r
+ /**\r
+ * Fixed name for TCA VES Collector Messages Processing Flow\r
+ */\r
+ public static final String TCA_FIXED_VES_COLLECTOR_NAME_FLOW = "TCAVESCollectorFlow";\r
+\r
+\r
+ /**\r
+ * Fixed description for TCA VES Collector Messages Processing Flow\r
+ */\r
+ public static final String TCA_FIXED_VES_COLLECTOR_DESCRIPTION_FLOW = "Flow performs TCA on VES Collector Messages";\r
+\r
+\r
+ /**\r
+ * Fixed Name for TCA VES Message Router Flowlet\r
+ */\r
+ public static final String TCA_FIXED_VES_MESSAGE_ROUTER_NAME_FLOWLET = "TCAVESMessageRouterFlowlet";\r
+\r
+ /**\r
+ * Fixed Description for TCA VES Message Router Flowlet\r
+ */\r
+ public static final String TCA_FIXED_VES_MESSAGE_ROUTER_DESCRIPTION_FLOWLET =\r
+ "Routes message received from TCA VES Collector to TCA Threshold Calculator Flowlet instances";\r
+\r
+ /**\r
+ * Fixed TCA VES Message Router Flowlet Output\r
+ */\r
+ public static final String TCA_FIXED_VES_MESSAGE_ROUTER_OUTPUT = "TCAVESMessageRouterFlowlet";\r
+\r
+ /**\r
+ * Fixed Name for TCA VES Message Policy Violated Threshold Calculator Flowlet\r
+ */\r
+ public static final String TCA_FIXED_VES_THRESHOLD_VIOLATION_CALCULATOR_NAME_FLOWLET =\r
+ "TCAVESThresholdViolationCalculatorFlowlet";\r
+\r
+ /**\r
+ * Fixed Description for TCA VES Message Policy Violated Threshold Calculator Flowlet\r
+ */\r
+ public static final String TCA_FIXED_VES_THRESHOLD_VIOLATION_CALCULATOR_DESCRIPTION_FLOWLET =\r
+ "Applies TCA Policy Thresholds to VES Message and determined if any message violated TCA Policy thresholds";\r
+\r
+ /**\r
+ * Fixed Name for TCA VES Message Policy Violated Threshold Calculator Output\r
+ */\r
+ public static final String TCA_FIXED_VES_TCA_CALCULATOR_NAME_OUTPUT = "TCAThresholdViolationCalculatorOutput";\r
+\r
+\r
+ /**\r
+ * Fixed Name for TCA VES Alerts Abatement Flowlet\r
+ */\r
+ public static final String TCA_FIXED_VES_ALERTS_ABATEMENT_NAME_FLOWLET = "TCAVESAlertsAbatementFlowlet";\r
+\r
+ /**\r
+ * Fixed Description for TCA VES Alerts Abatement Flowlet\r
+ */\r
+ public static final String TCA_FIXED_VES_ALERTS_ABATEMENT_DESCRIPTION_FLOWLET =\r
+ "Determines if abatement event needs to be posted to downstream systems";\r
+\r
+ /**\r
+ * Fixed Name for TCA VES Alerts Abatement Flowlet output\r
+ */\r
+ public static final String TCA_FIXED_VES_ALERTS_ABATEMENT_NAME_OUTPUT = "TCAVESAlertsAbatementFlowletOutput";\r
+\r
+\r
+ /**\r
+ * Fixed Name for TCA VES A&AI Enrichment Flowlet\r
+ */\r
+ public static final String TCA_FIXED_VES_AAI_ENRICHMENT_NAME_FLOWLET = "TCAVESAAIEnrichmentFlowlet";\r
+\r
+ /**\r
+ * Fixed Description for TCA VES A&AI Enrichment Flowlet\r
+ */\r
+ public static final String TCA_FIXED_VES_AAI_ENRICHMENT_DESCRIPTION_FLOWLET =\r
+ "Performs A&AI Enrichment of non abated alerts";\r
+\r
+ /**\r
+ * Fixed Name for TCA VES A&AI Enrichment Flowlet output\r
+ */\r
+ public static final String TCA_FIXED_VES_AAI_ENRICHMENT_NAME_OUTPUT = "TCAVESAAIEnrichmentFlowletOutput";\r
+\r
+ /**\r
+ * Fixed Name for TCA VES Alerts Sink Flowlet\r
+ */\r
+ public static final String TCA_FIXED_VES_ALERTS_SINK_NAME_FLOWLET = "TCAVESAlertsSinkFlowlet";\r
+\r
+ /**\r
+ * Fixed Description for TCA VES Alerts Sink Flowlet\r
+ */\r
+ public static final String TCA_FIXED_VES_ALERTS_SINK_DESCRIPTION_FLOWLET =\r
+ "Saves messages which violated TCA Policy in a data set";\r
+\r
+\r
+ /**\r
+ * Default Name for TCA VES Message status table which contain status of all messages processed by TCA\r
+ */\r
+ public static final String TCA_DEFAULT_VES_MESSAGE_STATUS_NAME_TABLE = "TCAVESMessageStatusTable";\r
+\r
+\r
+ /**\r
+ * Fixed Description for TCA VES Message status table which contain status of all messages processed by TCA\r
+ */\r
+ public static final String TCA_FIXED_VES_MESSAGE_STATUS_DESCRIPTION_TABLE =\r
+ "Store processing information about all incoming TCA VES Messages";\r
+\r
+ /**\r
+ * Default Name for TCA VES Alerts table which contains alerts that can be send to downstream systems\r
+ */\r
+ public static final String TCA_DEFAULT_VES_ALERTS_NAME_TABLE = "TCAVESAlertsTable";\r
+\r
+ /**\r
+ * Fixed Description for TCA VES Alerts table which contains alerts that can be send to downstream systems\r
+ */\r
+ public static final String TCA_FIXED_VES_ALERTS_DESCRIPTION_TABLE =\r
+ "Stores alert messages that need to be DMaaP";\r
+\r
+ /**\r
+ * Default Name for TCA Alerts abatement table which contains information to send out abated alerts\r
+ */\r
+ public static final String TCA_DEFAULT_ALERTS_ABATEMENT_NAME_TABLE = "TCAAlertsAbatementTable";\r
+\r
+ /**\r
+ * Fixed Description for TCA Alerts abatement table which contains information to determine abatement alerts\r
+ */\r
+ public static final String TCA_FIXED_ALERTS_ABATEMENT_DESCRIPTION_TABLE =\r
+ "Stores information to determine creation of abatement alerts";\r
+\r
+\r
+ private CDAPComponentsConstants() {\r
+\r
+ }\r
+\r
+}\r
Code Review / dcaegen2 / analytics / tca.git / blobdiff