risingwave_common/array/arrow/
mod.rs

1// Copyright 2023 RisingWave Labs
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7//     http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15// These mods imports arrow_impl.rs to provide FromArrow, ToArrow traits for corresponding arrow versions,
16// and the default From/To implementations.
17
18mod arrow_58;
19// These mods import mods above and may override some methods.
20mod arrow_deltalake;
21mod arrow_iceberg;
22mod arrow_lancedb;
23mod arrow_udf;
24
25pub use arrow_deltalake::DeltaLakeConvert;
26pub use arrow_iceberg::{
27    ICEBERG_DECIMAL_PRECISION, ICEBERG_DECIMAL_SCALE, IcebergArrowConvert,
28    IcebergCreateTableArrowConvert,
29};
30pub use arrow_lancedb::LanceDbConvert;
31pub use arrow_udf::UdfArrowConvert;
32pub use reexport::*;
33/// For other RisingWave crates, they can directly use arrow re-exported here, without adding
34/// `arrow` dependencies in their `Cargo.toml`. And they don't need to care about the version.
35mod reexport {
36    pub use super::arrow_58::{
37        FromArrow as Arrow58FromArrow, ToArrow as Arrow58ToArrow, arrow_array as arrow_array_58,
38        arrow_buffer as arrow_buffer_58, arrow_cast as arrow_cast_58,
39        arrow_schema as arrow_schema_58,
40    };
41    pub use super::arrow_deltalake::{
42        FromArrow as DeltaLakeFromArrow, ToArrow as DeltaLakeToArrow,
43        arrow_array as arrow_array_deltalake, arrow_buffer as arrow_buffer_deltalake,
44        arrow_cast as arrow_cast_deltalake, arrow_schema as arrow_schema_deltalake,
45    };
46    pub use super::arrow_iceberg::{
47        FromArrow as IcebergFromArrow, ToArrow as IcebergToArrow,
48        arrow_array as arrow_array_iceberg, arrow_buffer as arrow_buffer_iceberg,
49        arrow_cast as arrow_cast_iceberg, arrow_schema as arrow_schema_iceberg,
50        is_parquet_field_match_source_schema, is_parquet_schema_match_source_schema,
51    };
52    pub use super::arrow_lancedb::{
53        FromArrow as LanceDbFromArrow, ToArrow as LanceDbToArrow,
54        arrow_array as arrow_array_lancedb, arrow_buffer as arrow_buffer_lancedb,
55        arrow_cast as arrow_cast_lancedb, arrow_schema as arrow_schema_lancedb,
56    };
57    pub use super::arrow_udf::{
58        FromArrow as UdfFromArrow, ToArrow as UdfToArrow, arrow_array as arrow_array_udf,
59        arrow_buffer as arrow_buffer_udf, arrow_cast as arrow_cast_udf,
60        arrow_schema as arrow_schema_udf,
61    };
62}
risingwave_common/array/arrow/mod.rs

risingwave_common/array/arrow/
mod.rs
