Path	Lines of Code
kafka-handler/src/java/org/apache/hadoop/hive/kafka/HiveKafkaProducer.java	185
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaDagCredentialSupplier.java	102
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaInputFormat.java	155
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaInputSplit.java	148
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaJsonSerDe.java	184
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaOutputFormat.java	69
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaRecordIterator.java	137
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaRecordReader.java	123
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaScanTrimmer.java	346
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaSerDe.java	301
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaStorageHandler.java	334
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaStorageHandlerInfo.java	42
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaTableProperties.java	35
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaUtils.java	312
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaWritable.java	133
kafka-handler/src/java/org/apache/hadoop/hive/kafka/MetadataColumn.java	47
kafka-handler/src/java/org/apache/hadoop/hive/kafka/RetryUtils.java	87
kafka-handler/src/java/org/apache/hadoop/hive/kafka/SimpleKafkaWriter.java	124
kafka-handler/src/java/org/apache/hadoop/hive/kafka/TransactionalKafkaWriter.java	259
kafka-handler/src/java/org/apache/hadoop/hive/kafka/VectorizedKafkaRecordReader.java	143
kafka-handler/src/java/org/apache/hadoop/hive/kafka/package-info.java	1