-/*\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.plugins.domain.config.dmaap;\r
-\r
-import co.cask.cdap.api.annotation.Description;\r
-import co.cask.cdap.api.annotation.Macro;\r
-import com.google.common.base.Objects;\r
-\r
-import javax.annotation.Nullable;\r
-\r
-/**\r
- * DMaaP MR Publisher Config\r
- * <p>\r
- * @author Rajiv Singla . Creation Date: 1/17/2017.\r
- */\r
-public class DMaaPMRSinkPluginConfig extends BaseDMaaPMRPluginConfig {\r
-\r
- private static final long serialVersionUID = 1L;\r
-\r
- @Description("Column name of input schema which contains the message that needs to be written to DMaaP MR Topic")\r
- @Macro\r
- protected String messageColumnName;\r
-\r
- @Description("DMaaP MR Publisher Max Batch Size. Defaults to no Batch")\r
- @Nullable\r
- @Macro\r
- protected Integer maxBatchSize;\r
-\r
- @Description("DMaaP MR Publisher Recovery Queue Size. Default to 1000K messages which can be buffered in memory " +\r
- "in case DMaaP MR Publisher is temporarily unavailable")\r
- @Nullable\r
- @Macro\r
- protected Integer maxRecoveryQueueSize;\r
-\r
- // Required No Arg constructor\r
- public DMaaPMRSinkPluginConfig() {\r
- this(null, null, null, null);\r
- }\r
-\r
- public DMaaPMRSinkPluginConfig(String referenceName, String hostName, String topicName, String messageColumnName) {\r
- super(referenceName, hostName, topicName);\r
- this.messageColumnName = messageColumnName;\r
- }\r
-\r
- /**\r
- * Column name of incoming Schema field that contains the message that needs to published to DMaaP MR Topic\r
- *\r
- * @return Column name of incoming schema which contains message that needs to published to DMaaP MR Topic\r
- */\r
- public String getMessageColumnName() {\r
- return messageColumnName;\r
- }\r
-\r
- /**\r
- * DMaaP MR Publisher Max Batch Size.\r
- *\r
- * @return DMaaP MR Publisher Max Batch Size\r
- */\r
- @Nullable\r
- public Integer getMaxBatchSize() {\r
- return maxBatchSize;\r
- }\r
-\r
- /**\r
- * DMaaP MR Publisher Max Recovery Queue Size\r
- *\r
- * @return DMaaP MR Publisher Max Recovery Queue Size\r
- */\r
- @Nullable\r
- public Integer getMaxRecoveryQueueSize() {\r
- return maxRecoveryQueueSize;\r
- }\r
-\r
- @Override\r
- public String toString() {\r
- return Objects.toStringHelper(this)\r
- .add("super", super.toString())\r
- .add("messageColumnName", messageColumnName)\r
- .add("maxBatchSize", maxBatchSize)\r
- .add("maxRecoveryQueueSize", maxRecoveryQueueSize)\r
- .toString();\r
- }\r
-}\r
+/*
+ * ===============================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.onap.dcae.apod.analytics.cdap.plugins.domain.config.dmaap;
+
+import co.cask.cdap.api.annotation.Description;
+import co.cask.cdap.api.annotation.Macro;
+import com.google.common.base.Objects;
+
+import javax.annotation.Nullable;
+
+/**
+ * DMaaP MR Publisher Config
+ * <p>
+ * @author Rajiv Singla . Creation Date: 1/17/2017.
+ */
+public class DMaaPMRSinkPluginConfig extends BaseDMaaPMRPluginConfig {
+
+ private static final long serialVersionUID = 1L;
+
+ @Description("Column name of input schema which contains the message that needs to be written to DMaaP MR Topic")
+ @Macro
+ protected String messageColumnName;
+
+ @Description("DMaaP MR Publisher Max Batch Size. Defaults to no Batch")
+ @Nullable
+ @Macro
+ protected Integer maxBatchSize;
+
+ @Description("DMaaP MR Publisher Recovery Queue Size. Default to 1000K messages which can be buffered in memory " +
+ "in case DMaaP MR Publisher is temporarily unavailable")
+ @Nullable
+ @Macro
+ protected Integer maxRecoveryQueueSize;
+
+ // Required No Arg constructor
+ public DMaaPMRSinkPluginConfig() {
+ this(null, null, null, null);
+ }
+
+ public DMaaPMRSinkPluginConfig(String referenceName, String hostName, String topicName, String messageColumnName) {
+ super(referenceName, hostName, topicName);
+ this.messageColumnName = messageColumnName;
+ }
+
+ /**
+ * Column name of incoming Schema field that contains the message that needs to published to DMaaP MR Topic
+ *
+ * @return Column name of incoming schema which contains message that needs to published to DMaaP MR Topic
+ */
+ public String getMessageColumnName() {
+ return messageColumnName;
+ }
+
+ /**
+ * DMaaP MR Publisher Max Batch Size.
+ *
+ * @return DMaaP MR Publisher Max Batch Size
+ */
+ @Nullable
+ public Integer getMaxBatchSize() {
+ return maxBatchSize;
+ }
+
+ /**
+ * DMaaP MR Publisher Max Recovery Queue Size
+ *
+ * @return DMaaP MR Publisher Max Recovery Queue Size
+ */
+ @Nullable
+ public Integer getMaxRecoveryQueueSize() {
+ return maxRecoveryQueueSize;
+ }
+
+ @Override
+ public String toString() {
+ return Objects.toStringHelper(this)
+ .add("super", super.toString())
+ .add("messageColumnName", messageColumnName)
+ .add("maxBatchSize", maxBatchSize)
+ .add("maxRecoveryQueueSize", maxRecoveryQueueSize)
+ .toString();
+ }
+}
Code Review / dcaegen2 / analytics / tca.git / blobdiff