Uses of Class
org.apache.drill.exec.store.kafka.KafkaScanSpec

Packages that use KafkaScanSpec

Package	Description
org.apache.drill.exec.store.kafka	Kafka storage plugin.

Uses of KafkaScanSpec in org.apache.drill.exec.store.kafka

Methods in org.apache.drill.exec.store.kafka that return KafkaScanSpec

Modifier and Type	Method and Description
KafkaScanSpec	KafkaGroupScan.getKafkaScanSpec()

Constructors in org.apache.drill.exec.store.kafka with parameters of type KafkaScanSpec

Constructor and Description
KafkaGroupScan(KafkaStoragePlugin kafkaStoragePlugin, KafkaScanSpec kafkaScanSpec, List<SchemaPath> columns)
KafkaGroupScan(String userName, KafkaStoragePluginConfig kafkaStoragePluginConfig, List<SchemaPath> columns, KafkaScanSpec scanSpec, StoragePluginRegistry pluginRegistry)
KafkaGroupScan(String userName, KafkaStoragePlugin kafkaStoragePlugin, List<SchemaPath> columns, KafkaScanSpec kafkaScanSpec)