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

Fields in org.apache.drill.exec.store.kafka declared as KafkaStoragePluginConfig

Modifier and Type	Field and Description
protected static KafkaStoragePluginConfig	KafkaTestBase.storagePluginConfig

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

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

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

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