Mike Percy has submitted this change and it was merged. Change subject: KUDU-1416 Upsert support for Flume sink ......................................................................
KUDU-1416 Upsert support for Flume sink This patch adds a new SimpleKeyedKuduEventProducer class that can upsert. The original KuduEventProducer class, SimpleKuduEventProducer, assumed it was inserting a binary payload to a key column, and thus was not compatible with upserts. SimpleKeyedKuduEventProducer supports inserting or upserting a binary payload with string key column. Change-Id: Ibe5b5df70687103ed6916d58148336882aa66d85 Reviewed-on: http://gerrit.cloudera.org:8080/3157 Tested-by: Kudu Jenkins Reviewed-by: Mike Percy <[email protected]> --- M java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/KuduSink.java A java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/SimpleKeyedKuduEventProducer.java M java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/SimpleKuduEventProducer.java A java/kudu-flume-sink/src/test/java/org/apache/kudu/flume/sink/KeyedKuduEventProducerTest.java 4 files changed, 315 insertions(+), 3 deletions(-) Approvals: Mike Percy: Looks good to me, approved Kudu Jenkins: Verified -- To view, visit http://gerrit.cloudera.org:8080/3157 To unsubscribe, visit http://gerrit.cloudera.org:8080/settings Gerrit-MessageType: merged Gerrit-Change-Id: Ibe5b5df70687103ed6916d58148336882aa66d85 Gerrit-PatchSet: 4 Gerrit-Project: kudu Gerrit-Branch: master Gerrit-Owner: Will Berkeley <[email protected]> Gerrit-Reviewer: Ara Ebrahimi <[email protected]> Gerrit-Reviewer: Kudu Jenkins Gerrit-Reviewer: Mike Percy <[email protected]> Gerrit-Reviewer: Todd Lipcon <[email protected]> Gerrit-Reviewer: Will Berkeley <[email protected]>
