Skip to content

Commit 8423533

Browse files
committed
arrow dtype extension conversion
Signed-off-by: Baris Palaska <barispalaska@gmail.com>
1 parent 452a4a3 commit 8423533

10 files changed

Lines changed: 609 additions & 70 deletions

File tree

Cargo.lock

Lines changed: 2 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Cargo.toml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -106,6 +106,7 @@ async-lock = "3.4"
106106
async-stream = "0.3.6"
107107
async-trait = "0.1.89"
108108
base16ct = "1.0.0"
109+
base64 = "0.22"
109110
bigdecimal = "0.4.8"
110111
bindgen = "0.72.0"
111112
bit-vec = "0.9.0"

vortex-array/Cargo.toml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@ arrow-schema = { workspace = true }
3232
arrow-select = { workspace = true }
3333
arrow-string = { workspace = true }
3434
async-lock = { workspace = true }
35+
base64 = { workspace = true }
3536
bytes = { workspace = true }
3637
cfg-if = { workspace = true }
3738
cudarc = { workspace = true, optional = true }

vortex-array/public-api.lock

Lines changed: 36 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8492,6 +8492,26 @@ impl vortex_array::dtype::arrow::FromArrowType<alloc::sync::Arc<arrow_schema::sc
84928492

84938493
pub fn vortex_array::dtype::DType::from_arrow(value: arrow_schema::schema::SchemaRef) -> Self
84948494

8495+
pub trait vortex_array::dtype::arrow::FromArrowWithSession<T>: core::marker::Sized
8496+
8497+
pub fn vortex_array::dtype::arrow::FromArrowWithSession::from_arrow_with_session(value: T, session: &vortex_session::VortexSession) -> Self
8498+
8499+
impl vortex_array::dtype::arrow::FromArrowWithSession<&alloc::sync::Arc<arrow_schema::schema::Schema>> for vortex_array::dtype::DType
8500+
8501+
pub fn vortex_array::dtype::DType::from_arrow_with_session(value: &arrow_schema::schema::SchemaRef, session: &vortex_session::VortexSession) -> Self
8502+
8503+
impl vortex_array::dtype::arrow::FromArrowWithSession<&arrow_schema::field::Field> for vortex_array::dtype::DType
8504+
8505+
pub fn vortex_array::dtype::DType::from_arrow_with_session(field: &arrow_schema::field::Field, session: &vortex_session::VortexSession) -> Self
8506+
8507+
impl vortex_array::dtype::arrow::FromArrowWithSession<&arrow_schema::fields::Fields> for vortex_array::dtype::StructFields
8508+
8509+
pub fn vortex_array::dtype::StructFields::from_arrow_with_session(value: &arrow_schema::fields::Fields, session: &vortex_session::VortexSession) -> Self
8510+
8511+
impl vortex_array::dtype::arrow::FromArrowWithSession<&arrow_schema::schema::Schema> for vortex_array::dtype::DType
8512+
8513+
pub fn vortex_array::dtype::DType::from_arrow_with_session(value: &arrow_schema::schema::Schema, session: &vortex_session::VortexSession) -> Self
8514+
84958515
pub trait vortex_array::dtype::arrow::TryFromArrowType<T>: core::marker::Sized
84968516

84978517
pub fn vortex_array::dtype::arrow::TryFromArrowType::try_from_arrow(value: T) -> vortex_error::VortexResult<Self>
@@ -9038,6 +9058,18 @@ impl vortex_array::dtype::arrow::FromArrowType<alloc::sync::Arc<arrow_schema::sc
90389058

90399059
pub fn vortex_array::dtype::DType::from_arrow(value: arrow_schema::schema::SchemaRef) -> Self
90409060

9061+
impl vortex_array::dtype::arrow::FromArrowWithSession<&alloc::sync::Arc<arrow_schema::schema::Schema>> for vortex_array::dtype::DType
9062+
9063+
pub fn vortex_array::dtype::DType::from_arrow_with_session(value: &arrow_schema::schema::SchemaRef, session: &vortex_session::VortexSession) -> Self
9064+
9065+
impl vortex_array::dtype::arrow::FromArrowWithSession<&arrow_schema::field::Field> for vortex_array::dtype::DType
9066+
9067+
pub fn vortex_array::dtype::DType::from_arrow_with_session(field: &arrow_schema::field::Field, session: &vortex_session::VortexSession) -> Self
9068+
9069+
impl vortex_array::dtype::arrow::FromArrowWithSession<&arrow_schema::schema::Schema> for vortex_array::dtype::DType
9070+
9071+
pub fn vortex_array::dtype::DType::from_arrow_with_session(value: &arrow_schema::schema::Schema, session: &vortex_session::VortexSession) -> Self
9072+
90419073
impl vortex_flatbuffers::FlatBufferRoot for vortex_array::dtype::DType
90429074

90439075
impl vortex_flatbuffers::WriteFlatBuffer for vortex_array::dtype::DType
@@ -9992,6 +10024,10 @@ impl vortex_array::dtype::arrow::FromArrowType<&arrow_schema::fields::Fields> fo
999210024

999310025
pub fn vortex_array::dtype::StructFields::from_arrow(value: &arrow_schema::fields::Fields) -> Self
999410026

10027+
impl vortex_array::dtype::arrow::FromArrowWithSession<&arrow_schema::fields::Fields> for vortex_array::dtype::StructFields
10028+
10029+
pub fn vortex_array::dtype::StructFields::from_arrow_with_session(value: &arrow_schema::fields::Fields, session: &vortex_session::VortexSession) -> Self
10030+
999510031
impl<T, V> core::iter::traits::collect::FromIterator<(T, V)> for vortex_array::dtype::StructFields where T: core::convert::Into<vortex_array::dtype::FieldName>, V: core::convert::Into<vortex_array::dtype::FieldDType>
999610032

999710033
pub fn vortex_array::dtype::StructFields::from_iter<I: core::iter::traits::collect::IntoIterator<Item = (T, V)>>(iter: I) -> Self

0 commit comments

Comments
 (0)