Expand description
Utility functions to make testing DataFusion based crates easier
Modules§
- csv
- Helpers for writing csv files and reading them back
- parquet
parquet - Helpers for writing parquet files and reading them back
Structs§
- Test
Table Factory - TableFactory for tests
- Test
Table Provider - TableProvider for testing purposes
Functions§
- aggr_
test_ schema - Get the schema for the aggregate_test_* csv files
- arrow_
test_ data - Returns the arrow test data directory, which is by default stored
in a git submodule rooted at
testing/data. - bounded_
stream - Creates an bounded stream for testing purposes.
- get_
data_ dir - Returns a directory path for finding test data.
- parquet_
test_ data parquet - Returns the parquet test data directory, which is by default
stored in a git submodule rooted at
parquet-testing/data. - plan_
and_ collect - Execute SQL and return results
- populate_
csv_ partitions - Generate CSV partitions within the supplied directory
- register_
aggregate_ csv - Register session context for the aggregate_test_100.csv file
- register_
unbounded_ file_ with_ ordering - This function creates an unbounded sorted file for testing purposes.
- scan_
empty - Scan an empty data source, mainly used in tests
- scan_
empty_ with_ partitions - Scan an empty data source with configured partition, mainly used in tests.
- test_
table - Create a table from the aggregate_test_100.csv file with the name “aggregate_test_100”
- test_
table_ with_ name - Create a table from the aggregate_test_100.csv file with the specified name