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	Description
KafkaScanSpec	KafkaGroupScan.getKafkaScanSpec()

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

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