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