----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/68633/#review208459 -----------------------------------------------------------
Ship it! Ship It! - Vineet Garg On Sept. 5, 2018, 9:15 p.m., Slim Bouguerra wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/68633/ > ----------------------------------------------------------- > > (Updated Sept. 5, 2018, 9:15 p.m.) > > > Review request for hive, Gopal V and Vineet Garg. > > > Bugs: [HIVE-20481] > https://issues.apache.org/jira/browse/[HIVE-20481] > > > Repository: hive-git > > > Description > ------- > > This Patch adds the kafka record key as an extra metadata column. > > > Diffs > ----- > > > itests/qtest-druid/src/main/java/org/apache/hive/kafka/SingleNodeKafkaCluster.java > c9339b565e > kafka-handler/src/java/org/apache/hadoop/hive/kafka/GenericKafkaSerDe.java > e7ea53f4bc > kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaJsonSerDe.java > f383190083 > > kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaPullerRecordReader.java > 908ee5e29f > > kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaRecordWritable.java > c6924ea480 > kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaScanTrimmer.java > 76415151ec > > kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaStorageHandler.java > 5847df5e7e > > kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaStorageHandlerInfo.java > PRE-CREATION > > kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaStreamingUtils.java > d2d0ebc192 > > kafka-handler/src/test/org/apache/hadoop/hive/kafka/KafkaPullerInputSplitTest.java > be26986818 > > kafka-handler/src/test/org/apache/hadoop/hive/kafka/KafkaRecordIteratorTest.java > 5de51cd00a > > kafka-handler/src/test/org/apache/hadoop/hive/kafka/KafkaRecordWritableTest.java > 8f9df548f7 > > kafka-handler/src/test/org/apache/hadoop/hive/kafka/KafkaScanTrimmerTest.java > 289dafde36 > > kafka-handler/src/test/org/apache/hadoop/hive/kafka/KafkaStreamingUtilsTest.java > 8d68ec27c8 > ql/src/java/org/apache/hadoop/hive/ql/metadata/StorageHandlerInfo.java > dbc44a6621 > ql/src/test/queries/clientpositive/kafka_storage_handler.q 8daa3e3bc0 > ql/src/test/results/clientpositive/druid/kafka_storage_handler.q.out > 3dec33d790 > testutils/ptest2/conf/deployed/master-mr2.properties 90a654cf8a > > > Diff: https://reviews.apache.org/r/68633/diff/1/ > > > Testing > ------- > > Via Qfiles > > > Thanks, > > Slim Bouguerra > >
