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

Packages that use KafkaPartitionScanSpec

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

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

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

Modifier and Type	Method and Description
KafkaPartitionScanSpec	KafkaPartitionScanSpec.clone()
KafkaPartitionScanSpec	KafkaGroupScan.PartitionScanWork.getPartitionScanSpec()

Methods in org.apache.drill.exec.store.kafka that return types with arguments of type KafkaPartitionScanSpec

Modifier and Type	Method and Description
List<KafkaPartitionScanSpec>	KafkaGroupScan.getPartitionScanSpecList()
List<KafkaPartitionScanSpec>	KafkaSubScan.getPartitionSubScanSpecList()
List<KafkaPartitionScanSpec>	KafkaPartitionScanSpecBuilder.parseTree()
List<KafkaPartitionScanSpec>	KafkaPartitionScanSpecBuilder.visitBooleanOperator(BooleanOperator op, Void value)
List<KafkaPartitionScanSpec>	KafkaPartitionScanSpecBuilder.visitFunctionCall(FunctionCall call, Void value)
List<KafkaPartitionScanSpec>	KafkaPartitionScanSpecBuilder.visitUnknown(LogicalExpression e, Void value)

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

Modifier and Type	Method and Description
void	KafkaPartitionScanSpec.mergeScanSpec(String functionName, KafkaPartitionScanSpec scanSpec)

Method parameters in org.apache.drill.exec.store.kafka with type arguments of type KafkaPartitionScanSpec

Modifier and Type	Method and Description
GroupScan	KafkaGroupScan.cloneWithNewSpec(List<KafkaPartitionScanSpec> partitionScanSpecList)

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

Constructor and Description
KafkaRecordReader(KafkaPartitionScanSpec subScanSpec, OptionManager options, KafkaStoragePlugin plugin, int maxRecords)
MessageIterator(org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]> kafkaConsumer, KafkaPartitionScanSpec subScanSpec, long kafkaPollTimeOut)
PartitionScanWork(EndpointByteMap byteMap, KafkaPartitionScanSpec partitionScanSpec)

Constructor parameters in org.apache.drill.exec.store.kafka with type arguments of type KafkaPartitionScanSpec

Constructor and Description
KafkaSubScan(StoragePluginRegistry registry, String userName, KafkaStoragePluginConfig kafkaStoragePluginConfig, List<SchemaPath> columns, LinkedList<KafkaPartitionScanSpec> partitionSubScanSpecList)
KafkaSubScan(String userName, KafkaStoragePlugin kafkaStoragePlugin, List<SchemaPath> columns, List<KafkaPartitionScanSpec> partitionSubScanSpecList)