[kudu-CR] KUDU-1416 Upsert support for Flume sink

["Will Berkeley (Code Review)" <ge...@cloudera.org>]

Will Berkeley has uploaded a new change for review.

  http://gerrit.cloudera.org:8080/3157

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.

There's a lot more functionality- supporting > 1 key columns, supporting more
types than binary payload and string key- that could be added later or as
enhancements to this patch. I'm just looking for initial feedback.

Change-Id: Ibe5b5df70687103ed6916d58148336882aa66d85
---
M java/kudu-flume-sink/src/main/java/org/kududb/flume/sink/KuduSink.java
A java/kudu-flume-sink/src/main/java/org/kududb/flume/sink/SimpleKeyedKuduEventProducer.java
M java/kudu-flume-sink/src/main/java/org/kududb/flume/sink/SimpleKuduEventProducer.java
A java/kudu-flume-sink/src/test/java/org/kududb/flume/sink/KeyedKuduEventProducerTest.java
4 files changed, 313 insertions(+), 3 deletions(-)


  git pull ssh://gerrit.cloudera.org:29418/kudu refs/changes/57/3157/1
-- 
To view, visit http://gerrit.cloudera.org:8080/3157
To unsubscribe, visit http://gerrit.cloudera.org:8080/settings

Gerrit-MessageType: newchange
Gerrit-Change-Id: Ibe5b5df70687103ed6916d58148336882aa66d85
Gerrit-PatchSet: 1
Gerrit-Project: kudu
Gerrit-Branch: master
Gerrit-Owner: Will Berkeley <wd...@gmail.com>