| Interface | Description |
|---|---|
| RetryUtils.CleanupAfterFailure |
Cleanup procedure after each failed attempt.
|
| RetryUtils.Task<T> |
Task to be performed.
|
| Class | Description |
|---|---|
| KafkaInputFormat |
Kafka puller input format to read records from a Kafka Queue.
|
| KafkaInputSplit |
Kafka Hadoop Input Split Class.
|
| KafkaOutputFormat |
Kafka Hive Output Format class used to write Hive Rows to a Kafka Queue.
|
| KafkaRecordReader |
Kafka Records Reader implementation.
|
| KafkaSerDe |
Generic Kafka Serde that allow user to delegate Serde to other class like Avro,
Json or any class that supports
BytesWritable. |
| KafkaStorageHandler |
Hive Kafka storage handler to allow user to read and write from/to Kafka message bus.
|
| KafkaWritable |
Writable implementation of Kafka ConsumerRecord.
|
| RetryUtils |
Retry utils class mostly taken from Apache Druid Project org.apache.druid.java.util.common.RetryUtils.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.