Module datafusion::physical_plan::common

Defines common code used in execution plans

Structs

AbortOnDropMany

Helper that aborts the given join handles on drop.

AbortOnDropSingle

Helper that aborts the given join handle on drop.

SizedRecordBatchStream

Stream of record batches

Functions

build_checked_file_list

Recursively builds a list of files in a directory with a given extension

build_file_list

Recursively builds a list of files in a directory with a given extension

collect

Create a vector of record batches from a stream

compute_record_batch_statistics

Computes the statistics for an in-memory RecordBatch