Will Berkeley has uploaded a new change for review. http://gerrit.cloudera.org:8080/3883
Change subject: Add RegexpKuduEventProducer class ...................................................................... Add RegexpKuduEventProducer class This patch adds the RegexpKuduEventProducer class. This class serializes Event objects to Kudu inserts or upserts by decoding the body into a string, parsing the string using a regular expression, and finally mapping match groups to columns by matching the name of the match group to the name of the column. Parsed values are naively coerced to the proper type-- this could be improved in the future. This provides an easy-to-use but flexible way to ingest data with varying schemas into Kudu from Flume. Change-Id: Ibd64542095f0064a21635ec76c46d6a1be98b7ea --- A java/kudu-flume-sink/src/main/java/org/apache/kudu/flume/sink/RegexpKuduEventProducer.java A java/kudu-flume-sink/src/test/java/org/apache/kudu/flume/sink/RegExpKuduEventProducerTest.java 2 files changed, 416 insertions(+), 0 deletions(-) git pull ssh://gerrit.cloudera.org:29418/kudu refs/changes/83/3883/1 -- To view, visit http://gerrit.cloudera.org:8080/3883 To unsubscribe, visit http://gerrit.cloudera.org:8080/settings Gerrit-MessageType: newchange Gerrit-Change-Id: Ibd64542095f0064a21635ec76c46d6a1be98b7ea Gerrit-PatchSet: 1 Gerrit-Project: kudu Gerrit-Branch: master Gerrit-Owner: Will Berkeley <wdberke...@gmail.com>
