You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kudu.apache.org by mp...@apache.org on 2016/12/01 15:51:32 UTC
kudu git commit: [flume] Add interface annotations to
KuduOperationsProducers
Repository: kudu
Updated Branches:
refs/heads/master 8ffc6d184 -> 016ae9c23
[flume] Add interface annotations to KuduOperationsProducers
This ensures their javadocs get generated.
Change-Id: I2612dd7448e83545b361735cf897fa7cdabfcb84
Reviewed-on: http://gerrit.cloudera.org:8080/5279
Tested-by: Kudu Jenkins
Reviewed-by: Mike Percy <mp...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/kudu/repo
Commit: http://git-wip-us.apache.org/repos/asf/kudu/commit/016ae9c2
Tree: http://git-wip-us.apache.org/repos/asf/kudu/tree/016ae9c2
Diff: http://git-wip-us.apache.org/repos/asf/kudu/diff/016ae9c2
Branch: refs/heads/master
Commit: 016ae9c23c28ea5a690247c85d1f680d87a1b8c9
Parents: 8ffc6d1
Author: Will Berkeley <wd...@gmail.com>
Authored: Wed Nov 30 14:53:01 2016 -0500
Committer: Mike Percy <mp...@apache.org>
Committed: Thu Dec 1 14:12:58 2016 +0000
----------------------------------------------------------------------
.../org/apache/kudu/flume/sink/AvroKuduOperationsProducer.java | 4 ++++
.../org/apache/kudu/flume/sink/RegexpKuduOperationsProducer.java | 4 ++++
.../kudu/flume/sink/SimpleKeyedKuduOperationsProducer.java | 4 ++++
.../org/apache/kudu/flume/sink/SimpleKuduOperationsProducer.java | 4 ++++
4 files changed, 16 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kudu/blob/016ae9c2/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/AvroKuduOperationsProducer.java
----------------------------------------------------------------------
diff --git a/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/AvroKuduOperationsProducer.java b/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/AvroKuduOperationsProducer.java
index a139eb1..f02beef 100644
--- a/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/AvroKuduOperationsProducer.java
+++ b/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/AvroKuduOperationsProducer.java
@@ -48,6 +48,8 @@ import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.kudu.ColumnSchema;
+import org.apache.kudu.annotations.InterfaceAudience;
+import org.apache.kudu.annotations.InterfaceStability;
import org.apache.kudu.client.KuduTable;
import org.apache.kudu.client.Operation;
import org.apache.kudu.client.PartialRow;
@@ -80,6 +82,8 @@ import org.apache.kudu.client.PartialRow;
* </tr>
* </table>
*/
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
public class AvroKuduOperationsProducer implements KuduOperationsProducer {
public static final String OPERATION_PROP = "operation";
public static final String SCHEMA_PROP = "schemaPath";
http://git-wip-us.apache.org/repos/asf/kudu/blob/016ae9c2/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/RegexpKuduOperationsProducer.java
----------------------------------------------------------------------
diff --git a/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/RegexpKuduOperationsProducer.java b/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/RegexpKuduOperationsProducer.java
index 3ed147c..4e261ff 100644
--- a/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/RegexpKuduOperationsProducer.java
+++ b/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/RegexpKuduOperationsProducer.java
@@ -36,6 +36,8 @@ import org.slf4j.LoggerFactory;
import org.apache.kudu.ColumnSchema;
import org.apache.kudu.Schema;
import org.apache.kudu.Type;
+import org.apache.kudu.annotations.InterfaceAudience;
+import org.apache.kudu.annotations.InterfaceStability;
import org.apache.kudu.client.Insert;
import org.apache.kudu.client.KuduTable;
import org.apache.kudu.client.Operation;
@@ -113,6 +115,8 @@ import org.apache.kudu.client.Upsert;
*
* @see Pattern
*/
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
public class RegexpKuduOperationsProducer implements KuduOperationsProducer {
private static final Logger logger = LoggerFactory.getLogger(RegexpKuduOperationsProducer.class);
http://git-wip-us.apache.org/repos/asf/kudu/blob/016ae9c2/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/SimpleKeyedKuduOperationsProducer.java
----------------------------------------------------------------------
diff --git a/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/SimpleKeyedKuduOperationsProducer.java b/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/SimpleKeyedKuduOperationsProducer.java
index 897738a..7cff7bb 100644
--- a/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/SimpleKeyedKuduOperationsProducer.java
+++ b/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/SimpleKeyedKuduOperationsProducer.java
@@ -26,6 +26,8 @@ import org.apache.flume.Context;
import org.apache.flume.Event;
import org.apache.flume.FlumeException;
+import org.apache.kudu.annotations.InterfaceAudience;
+import org.apache.kudu.annotations.InterfaceStability;
import org.apache.kudu.client.Insert;
import org.apache.kudu.client.KuduTable;
import org.apache.kudu.client.Operation;
@@ -69,6 +71,8 @@ import org.apache.kudu.client.Upsert;
* </tr>
* </table>
*/
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
public class SimpleKeyedKuduOperationsProducer implements KuduOperationsProducer {
public static final String PAYLOAD_COLUMN_PROP = "payloadColumn";
public static final String PAYLOAD_COLUMN_DEFAULT = "payload";
http://git-wip-us.apache.org/repos/asf/kudu/blob/016ae9c2/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/SimpleKuduOperationsProducer.java
----------------------------------------------------------------------
diff --git a/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/SimpleKuduOperationsProducer.java b/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/SimpleKuduOperationsProducer.java
index e2f4452..f0f8569 100644
--- a/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/SimpleKuduOperationsProducer.java
+++ b/java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/SimpleKuduOperationsProducer.java
@@ -26,6 +26,8 @@ import org.apache.flume.Context;
import org.apache.flume.Event;
import org.apache.flume.FlumeException;
+import org.apache.kudu.annotations.InterfaceAudience;
+import org.apache.kudu.annotations.InterfaceStability;
import org.apache.kudu.client.Insert;
import org.apache.kudu.client.KuduTable;
import org.apache.kudu.client.Operation;
@@ -52,6 +54,8 @@ import org.apache.kudu.client.PartialRow;
* </tr>
* </table>
*/
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
public class SimpleKuduOperationsProducer implements KuduOperationsProducer {
public static final String PAYLOAD_COLUMN_PROP = "payloadColumn";
public static final String PAYLOAD_COLUMN_DEFAULT = "payload";