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	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	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	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	Description
GroupScan	KafkaGroupScan.cloneWithNewSpec(List<KafkaPartitionScanSpec> partitionScanSpecList)

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

Modifier	Constructor	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

Modifier	Constructor	Description
	KafkaSubScan(StoragePluginRegistry registry, String userName, KafkaStoragePluginConfig kafkaStoragePluginConfig, List<SchemaPath> columns, int records, LinkedList<KafkaPartitionScanSpec> partitionSubScanSpecList)