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

Packages that use KafkaStoragePlugin

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

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

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

Modifier and Type	Method	Description
KafkaStoragePlugin	KafkaSubScan.getKafkaStoragePlugin()
KafkaStoragePlugin	KafkaGroupScan.getStoragePlugin()

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

Modifier	Constructor	Description
	KafkaGroupScan(String userName, KafkaStoragePlugin kafkaStoragePlugin, List<SchemaPath> columns, int records, KafkaScanSpec kafkaScanSpec)
	KafkaGroupScan(KafkaStoragePlugin kafkaStoragePlugin, KafkaScanSpec kafkaScanSpec, List<SchemaPath> columns, int records)
	KafkaRecordReader(KafkaPartitionScanSpec subScanSpec, OptionManager options, KafkaStoragePlugin plugin, int maxRecords)
	KafkaSubScan(String userName, KafkaStoragePlugin kafkaStoragePlugin, List<SchemaPath> columns, int records, List<KafkaPartitionScanSpec> partitionSubScanSpecList)

Uses of KafkaStoragePlugin in org.apache.drill.exec.store.kafka.decoders

Methods in org.apache.drill.exec.store.kafka.decoders with parameters of type KafkaStoragePlugin

Modifier and Type	Method	Description
org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]>	AvroMessageReader.getConsumer(KafkaStoragePlugin plugin)
org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]>	JsonMessageReader.getConsumer(KafkaStoragePlugin plugin)
org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]>	MessageReader.getConsumer(KafkaStoragePlugin plugin)
void	AvroMessageReader.init(SchemaNegotiator negotiator, ReadOptions readOptions, KafkaStoragePlugin plugin)
void	JsonMessageReader.init(SchemaNegotiator negotiator, ReadOptions readOptions, KafkaStoragePlugin plugin)
void	MessageReader.init(SchemaNegotiator negotiator, ReadOptions readOptions, KafkaStoragePlugin plugin)

Uses of KafkaStoragePlugin in org.apache.drill.exec.store.kafka.schema

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

Modifier	Constructor	Description
	KafkaMessageSchema(KafkaStoragePlugin plugin, String name)
	KafkaSchemaFactory(KafkaStoragePlugin plugin, String schemaName)