----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/69170/ -----------------------------------------------------------
Review request for hive, Gopal V and Teddy Choi. Bugs: HIVE-20486 https://issues.apache.org/jira/browse/HIVE-20486 Repository: hive-git Description ------- This PR adds a vectorized record reader to the Kafka Storage Handler. Minor documentation fixup Some small refactors to the Serde index managements. Diffs ----- itests/util/src/main/java/org/apache/hadoop/hive/ql/QTestUtil.java 5924d06371 kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaInputFormat.java c401df9850 kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaRecordIterator.java 2225f19a4d kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaRecordReader.java 7f8353c9f0 kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaSerDe.java 6b2ca1056e kafka-handler/src/java/org/apache/hadoop/hive/kafka/SimpleKafkaWriter.java 678e190b3f kafka-handler/src/java/org/apache/hadoop/hive/kafka/VectorizedKafkaRecordReader.java PRE-CREATION kafka-handler/src/test/org/apache/hadoop/hive/kafka/SimpleKafkaWriterTest.java 8a9bbc7f66 ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java e3e329f89b ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorizedSerde.java c97143c633 ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcSerde.java 7b788350b2 ql/src/java/org/apache/hadoop/hive/ql/io/orc/VectorizedOrcSerde.java f2295d6015 ql/src/test/queries/clientpositive/kafka_storage_handler.q e6cd276f95 ql/src/test/results/clientpositive/druid/kafka_storage_handler.q.out 8ea2aa9d3a Diff: https://reviews.apache.org/r/69170/diff/1/ Testing ------- Thanks, Slim Bouguerra