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 and Description
KafkaStoragePlugin	KafkaSubScan.getKafkaStoragePlugin()
KafkaStoragePlugin	KafkaGroupScan.getStoragePlugin()

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

Constructor and Description
KafkaGroupScan(KafkaStoragePlugin kafkaStoragePlugin, KafkaScanSpec kafkaScanSpec, List<SchemaPath> columns)
KafkaGroupScan(String userName, KafkaStoragePlugin kafkaStoragePlugin, List<SchemaPath> columns, KafkaScanSpec kafkaScanSpec)
KafkaRecordReader(KafkaPartitionScanSpec subScanSpec, OptionManager options, KafkaStoragePlugin plugin, int maxRecords)
KafkaSubScan(String userName, KafkaStoragePlugin kafkaStoragePlugin, List<SchemaPath> columns, 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 and Description
org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]>	AvroMessageReader.getConsumer(KafkaStoragePlugin plugin)
org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]>	MessageReader.getConsumer(KafkaStoragePlugin plugin)
org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]>	JsonMessageReader.getConsumer(KafkaStoragePlugin plugin)
void	AvroMessageReader.init(SchemaNegotiator negotiator, ReadOptions readOptions, KafkaStoragePlugin plugin)
void	MessageReader.init(SchemaNegotiator negotiator, ReadOptions readOptions, KafkaStoragePlugin plugin)
void	JsonMessageReader.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

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