AvroFileFormat — FileFormat For Avro-Encoded Files
AvroFileFormat — FileFormat For Avro-Encoded Files
AvroFileFormat — FileFormat For Avro-Encoded Files
Avro Data Source Spark SQL supports structured queries over Avro files as well as in columns (in a DataFrame). ...
JsonUtils Helper Object JsonUtils is a Scala object with methods for serializing and deserializing Kafka TopicPart ...
KafkaWriteTask KafkaWriteTask is used to write rows (from a structured query) to Apache Kafka. KafkaWriteTask is ...
KafkaWriter Helper Object — Writing Structured Queries to Kafka
InternalKafkaConsumer InternalKafkaConsumer is…FIXME Getting Single Kafka ConsumerRecord ...
KafkaDataConsumer Contract KafkaDataConsumer is the contract for KafkaDataConsumers that use an InternalKafkaConsu ...
KafkaOffsetRangeLimit KafkaOffsetRangeLimit is the desired offset range limits for starting, ending, and specific ...
KafkaOffsetReader KafkaOffsetReader is used to query a Kafka cluster for partition offsets. KafkaOffsetReader is ...
ConsumerStrategy Contract — Kafka Consumer Providers