Expand description
Utilities for testing datafusion-physical-plan
Modules§
- exec
- Simple iterator over batches for use in testing
Structs§
- Test
Memory Exec TestMemoryExecis a mock equivalent toMemorySourceConfigwithExecutionPlanimplemented for testing. i.e. It has some but not all the functionality ofMemorySourceConfig. This implements an in-memory DataSource rather than explicitly implementing a trait. It is implemented in this manner to keep relevant unit tests in place while avoiding circular dependencies betweendatafusion-physical-plananddatafusion-datasource.- Test
Partition Stream
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_ i32_ two_ cols - Returns record batch with 2 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”
- make_
partition_ utf8 - mem_
exec - Returns a
DataSourceExecthat scanspartitionsof 100 batches each - mem_
exec_ utf8 - scan_
partitioned - Returns a
DataSourceExecthat scanspartitionsof 100 batches each - scan_
partitioned_ utf8