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.

IPCWriter

Write in Arrow IPC format.

SizedRecordBatchStream

Stream of record batches

Functions

batch_byte_size

Returns the total number of bytes of memory occupied physically by this batch.

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

get_meet_of_orderings

Calculates the “meet” of given orderings. The meet is the finest ordering that satisfied by all the given orderings, see https://en.wikipedia.org/wiki/Join_and_meet.

merge_batches

Merge two record batch references into a single record batch. All the record batches inside the slice must have the same schema.

merge_multiple_batches

Merge a slice of record batch references into a single record batch, or return None if the slice itself is empty. All the record batches inside the slice must have the same schema.

transpose

Transposes the given vector of vectors.