pub struct CheckpointVisitor { /* private fields */ }Available on crate feature
internal-api only.Expand description
Extracts the first checkpoint action found, leaving checkpoint as None if a batch has
none. The action is an array of single-key tagged objects, each one of the metadata actions
embedded in an adaptiveMetadata manifest commit.
Trait Implementations§
Source§impl Default for CheckpointVisitor
impl Default for CheckpointVisitor
Source§fn default() -> CheckpointVisitor
fn default() -> CheckpointVisitor
Returns the “default value” for a type. Read more
Source§impl RowVisitor for CheckpointVisitor
Available on crate feature adaptive-metadata-in-dev only.
impl RowVisitor for CheckpointVisitor
Available on crate feature
adaptive-metadata-in-dev only.Source§fn selected_column_names_and_types(
&self,
) -> (&'static [ColumnName], &'static [DataType])
fn selected_column_names_and_types( &self, ) -> (&'static [ColumnName], &'static [DataType])
The names and types of leaf fields this visitor accesses. The
EngineData being visited
validates these types when extracting column getters, and RowVisitor::visit will receive
one getter for each selected field, in the requested order. The column names are used by
RowVisitor::visit_rows_of to select fields from a “typical” EngineData; callers whose
engine data has different column names can manually invoke EngineData::visit_rows.Source§fn visit<'a>(
&mut self,
row_count: usize,
getters: &[&'a dyn GetData<'a>],
) -> DeltaResult<()>
fn visit<'a>( &mut self, row_count: usize, getters: &[&'a dyn GetData<'a>], ) -> DeltaResult<()>
Have the visitor visit the data. This will be called on a visitor passed to
EngineData::visit_rows. For each leaf in the schema that was passed to extract a
“getter” of type GetData will be present. This can be used to actually get at the data
for each row. You can use the TypedGetData trait if you want to have a way to extract
typed data that will fail if the “getter” is for an unexpected type. The data in getters
does not outlive the call to this function (i.e. it should be copied if needed).Source§fn visit_rows_of(&mut self, data: &dyn EngineData) -> DeltaResult<()>where
Self: Sized,
fn visit_rows_of(&mut self, data: &dyn EngineData) -> DeltaResult<()>where
Self: Sized,
Visit the rows of an
EngineData, selecting the leaf column names given by
RowVisitor::selected_column_names_and_types. This is a thin wrapper around
EngineData::visit_rows which in turn will eventually invoke RowVisitor::visit.Auto Trait Implementations§
impl Freeze for CheckpointVisitor
impl RefUnwindSafe for CheckpointVisitor
impl Send for CheckpointVisitor
impl Sync for CheckpointVisitor
impl Unpin for CheckpointVisitor
impl UnsafeUnpin for CheckpointVisitor
impl UnwindSafe for CheckpointVisitor
Blanket Implementations§
impl<T> Allocation for T
Source§impl<T> AsAny for T
impl<T> AsAny for T
Source§fn any_ref(&self) -> &(dyn Any + Send + Sync + 'static)
fn any_ref(&self) -> &(dyn Any + Send + Sync + 'static)
Obtains a
dyn Any reference to the object: Read moreSource§fn as_any(self: Arc<T>) -> Arc<dyn Any + Send + Sync> ⓘ
fn as_any(self: Arc<T>) -> Arc<dyn Any + Send + Sync> ⓘ
Obtains an
Arc<dyn Any> reference to the object: Read moreSource§fn into_any(self: Box<T>) -> Box<dyn Any + Send + Sync>
fn into_any(self: Box<T>) -> Box<dyn Any + Send + Sync>
Converts the object to
Box<dyn Any>: Read moreSource§fn type_name(&self) -> &'static str
fn type_name(&self) -> &'static str
Convenient wrapper for
std::any::type_name, since Any does not provide it and
Any::type_id is useless as a debugging aid (its Debug is just a mess of hex digits).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> FoldWithOption for T
impl<T> FoldWithOption 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> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<KernelType, ArrowType> TryIntoArrow<ArrowType> for KernelTypewhere
ArrowType: TryFromKernel<KernelType>,
impl<KernelType, ArrowType> TryIntoArrow<ArrowType> for KernelTypewhere
ArrowType: TryFromKernel<KernelType>,
Source§fn try_into_arrow(self) -> Result<ArrowType, ArrowError>
fn try_into_arrow(self) -> Result<ArrowType, ArrowError>
Available on crate feature
arrow-conversion and (crate features arrow-conversion or declarative-plans or default-engine-base) only.Source§impl<KernelType, ArrowType> TryIntoKernel<KernelType> for ArrowTypewhere
KernelType: TryFromArrow<ArrowType>,
impl<KernelType, ArrowType> TryIntoKernel<KernelType> for ArrowTypewhere
KernelType: TryFromArrow<ArrowType>,
Source§fn try_into_kernel(self) -> Result<KernelType, ArrowError>
fn try_into_kernel(self) -> Result<KernelType, ArrowError>
Available on crate feature
arrow-conversion and (crate features arrow-conversion or declarative-plans or default-engine-base) only.