Module arrow Copy item path Source pub use super::arrow_deltalake::arrow_array as arrow_array_deltalake;pub use super::arrow_deltalake::arrow_buffer as arrow_buffer_deltalake;pub use super::arrow_deltalake::arrow_cast as arrow_cast_deltalake;pub use super::arrow_deltalake::arrow_schema as arrow_schema_deltalake;pub use super::arrow_iceberg::arrow_array as arrow_array_iceberg;pub use super::arrow_iceberg::arrow_buffer as arrow_buffer_iceberg;pub use super::arrow_iceberg::arrow_cast as arrow_cast_iceberg;pub use super::arrow_iceberg::arrow_schema as arrow_schema_iceberg;pub use super::arrow_udf::arrow_array as arrow_array_udf;pub use super::arrow_udf::arrow_buffer as arrow_buffer_udf;pub use super::arrow_udf::arrow_cast as arrow_cast_udf;pub use super::arrow_udf::arrow_schema as arrow_schema_udf;arrow_52 🔒 arrow_54 🔒 arrow_deltalake 🔒 This is for arrow dependency named arrow-xxx-deltalake such as arrow-array-deltalake
in the cargo workspace. arrow_iceberg 🔒 arrow_udf 🔒 This is for arrow dependency named arrow-xxx such as arrow-array in the cargo workspace. reexport 🔒 For other RisingWave crates, they can directly use arrow re-exported here, without adding
arrow dependencies in their Cargo.toml. And they don’t need to care about the version. DeltaLakeConvert IcebergArrowConvert IcebergCreateTableArrowConvert Iceberg sink with create_table_if_not_exists option will use this struct to convert the
iceberg data type to arrow data type. UdfArrowConvert Arrow conversion for UDF. ArrowIntervalTypeTrait 🔒 Arrow 52 changed the interval type from i128 to arrow_buffer::IntervalMonthDayNano, so
we introduced this trait to customize the conversion in arrow_impl.rs.
We may delete this after all arrow versions are upgraded. DeltaLakeFromArrow Defines how to convert Arrow arrays to RisingWave arrays. DeltaLakeToArrow Defines how to convert RisingWave arrays to Arrow arrays. IcebergFromArrow Defines how to convert Arrow arrays to RisingWave arrays. IcebergToArrow Defines how to convert RisingWave arrays to Arrow arrays. UdfFromArrow Defines how to convert Arrow arrays to RisingWave arrays. UdfToArrow Defines how to convert RisingWave arrays to Arrow arrays. is_parquet_schema_match_source_schema This function checks whether the schema of a Parquet file matches the user defined schema.
It handles the following special cases: