pub struct ArrowArrayAccessor { /* private fields */ }Expand description
Partner type representing accessing and walking arrow arrays alongside iceberg schema
Implementations§
Source§impl ArrowArrayAccessor
impl ArrowArrayAccessor
Sourcepub fn new() -> Self
pub fn new() -> Self
Creates a new instance of ArrowArrayAccessor with the default ID matching mode
Sourcepub fn new_with_match_mode(match_mode: FieldMatchMode) -> Self
pub fn new_with_match_mode(match_mode: FieldMatchMode) -> Self
Creates a new instance of ArrowArrayAccessor with the specified matching mode
Trait Implementations§
Source§impl Default for ArrowArrayAccessor
impl Default for ArrowArrayAccessor
Source§impl PartnerAccessor<Arc<dyn Array>> for ArrowArrayAccessor
impl PartnerAccessor<Arc<dyn Array>> for ArrowArrayAccessor
Source§fn struct_partner<'a>(
&self,
schema_partner: &'a ArrayRef,
) -> Result<&'a ArrayRef>
fn struct_partner<'a>( &self, schema_partner: &'a ArrayRef, ) -> Result<&'a ArrayRef>
Get the struct partner from schema partner.
Source§fn field_partner<'a>(
&self,
struct_partner: &'a ArrayRef,
field: &NestedField,
) -> Result<&'a ArrayRef>
fn field_partner<'a>( &self, struct_partner: &'a ArrayRef, field: &NestedField, ) -> Result<&'a ArrayRef>
Get the field partner from struct partner.
Source§fn list_element_partner<'a>(
&self,
list_partner: &'a ArrayRef,
) -> Result<&'a ArrayRef>
fn list_element_partner<'a>( &self, list_partner: &'a ArrayRef, ) -> Result<&'a ArrayRef>
Get the list element partner from list partner.
Auto Trait Implementations§
impl Freeze for ArrowArrayAccessor
impl RefUnwindSafe for ArrowArrayAccessor
impl Send for ArrowArrayAccessor
impl Sync for ArrowArrayAccessor
impl Unpin for ArrowArrayAccessor
impl UnwindSafe for ArrowArrayAccessor
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Downcast for T
impl<T> Downcast for T
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<T> ServiceExt for T
impl<T> ServiceExt for T
Source§fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>where
Self: Sized,
fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>where
Self: Sized,
Apply a transformation to the response body. Read more
Source§fn decompression(self) -> Decompression<Self>where
Self: Sized,
fn decompression(self) -> Decompression<Self>where
Self: Sized,
Decompress response bodies. Read more
Source§fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
High level tracing that classifies responses using HTTP status codes. Read more
Source§fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
High level tracing that classifies responses using gRPC headers. Read more