Package | Description |
---|---|
org.apache.drill.exec.store.kafka |
Kafka storage plugin.
|
org.apache.drill.exec.store.kafka.decoders | |
org.apache.drill.exec.store.kafka.schema |
Class and Description |
---|
KafkaGroupScan |
KafkaPartitionScanSpec |
KafkaScanSpec |
KafkaStoragePlugin |
KafkaStoragePluginConfig |
KafkaSubScan |
MetaDataField
MetaData fields provide additional information about each message.
|
Class and Description |
---|
KafkaStoragePlugin |
ReadOptions
Holds all system / session options that are used during data read from Kafka.
|
Class and Description |
---|
KafkaStoragePlugin |
Copyright © 1970 The Apache Software Foundation. All rights reserved.