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

Packages that use KafkaStoragePluginConfig

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

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

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

Modifier and Type	Method	Description
KafkaStoragePluginConfig	KafkaStoragePlugin.getConfig()
KafkaStoragePluginConfig	KafkaGroupScan.getKafkaStoragePluginConfig()
KafkaStoragePluginConfig	KafkaSubScan.getKafkaStoragePluginConfig()

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

Modifier	Constructor	Description
	KafkaGroupScan(String userName, KafkaStoragePluginConfig kafkaStoragePluginConfig, List<SchemaPath> columns, int records, KafkaScanSpec scanSpec, StoragePluginRegistry pluginRegistry)
	KafkaStoragePlugin(KafkaStoragePluginConfig config, DrillbitContext context, String name)
	KafkaSubScan(StoragePluginRegistry registry, String userName, KafkaStoragePluginConfig kafkaStoragePluginConfig, List<SchemaPath> columns, int records, LinkedList<KafkaPartitionScanSpec> partitionSubScanSpecList)