Module arrow

Re-exports

• 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;

Modules

• arrow_52 🔒
• arrow_53 🔒
• 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.

Structs

• 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.

Traits

• 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.