Module common 

Defines common code used in execution plans

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

build_file_list_recurse 🔒

Recursively build a list of files in a directory with a given extension with an accumulator list

can_project

Checks if the given projection is valid for the given schema.

collect

Create a vector of record batches from a stream

compute_record_batch_statistics

Computes the statistics for an in-memory RecordBatch

spawn_buffered

If running in a tokio context spawns the execution of stream to a separate task allowing it to execute in parallel with an intermediate buffer of size buffer

Type Aliases

SharedMemoryReservation 🔒

[MemoryReservation] used across query execution streams