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