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

Packages that use KafkaSubScan

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

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

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

Modifier and Type	Method	Description
KafkaSubScan	KafkaGroupScan.getSpecificScan(int minorFragmentId)

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

Modifier and Type	Method	Description
CloseableRecordBatch	KafkaScanBatchCreator.getBatch(ExecutorFragmentContext context, KafkaSubScan subScan, List<RecordBatch> children)