Will Berkeley has uploaded a new change for review. http://gerrit.cloudera.org:8080/4034
Change subject: Add AvroKuduEventProducer to Kudu-Flume integration ...................................................................... Add AvroKuduEventProducer to Kudu-Flume integration This adds a KuduEventProducer that accepts events with Avro-encoded bodies and allows the KuduSink to push them to Kudu. It only accepts schemas of Record type that hold values of types compatible with Kudu's types. The schema is provided to the EventProducer ahead of time, as a file. Hopefully, with the regex EventProducer, this will provide users with a basic capability to stream into Kudu using Flume via configuration, no coding. Change-Id: I6715df72e447e72f4801a2e026f6840d09b401e1 --- M java/kudu-flume-sink/pom.xml A java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/AvroKuduEventProducer.java A java/kudu-flume-sink/src/test/java/org/apache/kudu/flume/sink/AvroKuduEventProducerTest.java A java/kudu-flume-sink/src/test/resources/testAvroEventProducer.avsc 4 files changed, 383 insertions(+), 0 deletions(-) git pull ssh://gerrit.cloudera.org:29418/kudu refs/changes/34/4034/1 -- To view, visit http://gerrit.cloudera.org:8080/4034 To unsubscribe, visit http://gerrit.cloudera.org:8080/settings Gerrit-MessageType: newchange Gerrit-Change-Id: I6715df72e447e72f4801a2e026f6840d09b401e1 Gerrit-PatchSet: 1 Gerrit-Project: kudu Gerrit-Branch: master Gerrit-Owner: Will Berkeley <wdberke...@gmail.com>
