----------------------------------------------------------- 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