Batch¶

Batch is an abstraction of data source scans for batch queries.

Contract¶

Creating PartitionReaderFactory¶

PartitionReaderFactory createReaderFactory()

PartitionReaderFactory to create a PartitionReader to read records from the input partitions

See:

• ParquetScan

Used when:

• BatchScanExec is requested for a PartitionReaderFactory

Planning Input Partitions¶

InputPartition[] planInputPartitions()

InputPartitions to scan this data source with

See:

• FileScan

Used when:

• BatchScanExec is requested for the input partitions and filtered input partitions

Implementations¶

• FileScan
• KafkaBatch