fn assert_catalog_parquet_files(
        state: &TestCatalogState,
        expected: &[(String, IoxParquetMetaData)],
    ) {
        let actual = get_catalog_parquet_files(state);
        for ((actual_path, actual_md), (expected_path, expected_md)) in
            actual.iter().zip(expected.iter())
        {
            assert_eq!(actual_path, expected_path);

            let actual_schema = actual_md.read_schema().unwrap();
            let expected_schema = expected_md.read_schema().unwrap();
            assert_eq!(actual_schema, expected_schema);

            // NOTE: the actual table name is not important here as long as it is the same for both calls, since it is
            // only used to generate out statistics struct (not to read / dispatch anything).
            let actual_stats = actual_md.read_statistics(&actual_schema).unwrap();
            let expected_stats = expected_md.read_statistics(&expected_schema).unwrap();
            assert_eq!(actual_stats, expected_stats);
        }
    }
/// Assert that set of parquet files tracked by a catalog are identical to the given sorted list.
Assert that set of parquet files tracked by a catalog are identical to the given sorted list.
Assert that set of parquet files tracked by a catalog are identical to the given sorted list .
fn assert_catalog_parquet_files(
        state: &TestCatalogState,
        expected: &[(String, IoxParquetMetaData)],
    ) {
        let actual = get_catalog_parquet_files(state);
        for ((actual_path, actual_md), (expected_path, expected_md)) in
            actual.iter().zip(expected.iter())
        {
            assert_eq!(actual_path, expected_path);
            let actual_schema = actual_md.read_schema().unwrap();
            let expected_schema = expected_md.read_schema().unwrap();
            assert_eq!(actual_schema, expected_schema);
            // NOTE: the actual table name is not important here as long as it is the same for both calls, since it is
            // only used to generate out statistics struct (not to read / dispatch anything).
            let actual_stats = actual_md.read_statistics(&actual_schema).unwrap();
            let expected_stats = expected_md.read_statistics(&expected_schema).unwrap();
            assert_eq!(actual_stats, expected_stats);
        }
    }
fn assert_catalog_parquet_files ( state : & TestCatalogState , expected : & [ ( String , IoxParquetMetaData ) ] , ) { let actual = get_catalog_parquet_files ( state ) ; for ( ( actual_path , actual_md ) , ( expected_path , expected_md ) ) in actual . iter ( ) . zip ( expected . iter ( ) ) { assert_eq ! ( actual_path expected_path ) ; let actual_schema = actual_md . read_schema ( ) . unwrap ( ) ; let expected_schema = expected_md . read_schema ( ) . unwrap ( ) ; assert_eq ! ( actual_schema expected_schema ) ; // NOTE: the actual table name is not important here as long as it is the same for both calls, since it is // only used to generate out statistics struct (not to read / dispatch anything). let actual_stats = actual_md . read_statistics ( & actual_schema ) . unwrap ( ) ; let expected_stats = expected_md . read_statistics ( & expected_schema ) . unwrap ( ) ; assert_eq ! ( actual_stats expected_stats ) ; } }
Assert that set of parquet files tracked by a catalog are identical to the given sorted list.
Assert that set of parquet files tracked by a catalog are identical to the given sorted list .
state
&TestCatalogState
expected
&[(String, IoxParquetMetaData)]
state
&TestCatalogState
expected
&[(String, IoxParquetMetaData)]