Module datafusion::physical_plan::test

Utilities for testing datafusion-physical-plan

Modules

• exec
  Simple iterator over batches for use in testing

Structs

• TestPartitionStream

Functions

• aggr_test_schema
  Get the schema for the aggregate_test_* csv files
• assert_is_pending
  Asserts that given future is pending.
• build_table_i32
  returns record batch with 3 columns of i32 in memory
• build_table_scan_i32
  returns memory table scan wrapped around record batch with 3 columns of i32
• make_partition
  Return a RecordBatch with a single Int32 array with values (0..sz) in a field named “i”
• mem_exec
  Returns a MemoryExec that scans partitions of 100 batches each
• scan_partitioned
  Returns a MemoryExec that scans partitions of 100 batches each