pub struct EventTimeExtractor { /* private fields */ }Expand description
Extracts event timestamps from Arrow RecordBatch columns.
Implementations§
Source§impl EventTimeExtractor
impl EventTimeExtractor
Sourcepub fn from_column(name: &str) -> Self
pub fn from_column(name: &str) -> Self
Creates an extractor that looks up a column by name. The column index is cached after the first extraction.
Sourcepub fn from_index(index: usize) -> Self
pub fn from_index(index: usize) -> Self
Creates an extractor that uses a column by index. Skips the name lookup entirely.
Sourcepub fn with_mode(self, mode: ExtractionMode) -> Self
pub fn with_mode(self, mode: ExtractionMode) -> Self
Sets the extraction mode for multi-row batches.
Sourcepub fn mode(&self) -> ExtractionMode
pub fn mode(&self) -> ExtractionMode
Gets the configured extraction mode.
Sourcepub fn validate_schema(&self, schema: &Schema) -> Result<(), EventTimeError>
pub fn validate_schema(&self, schema: &Schema) -> Result<(), EventTimeError>
Validates that the schema contains a Timestamp(_) column at the
configured position.
§Errors
Returns an error if the column is missing or not a Timestamp(_).
Sourcepub fn extract(&mut self, batch: &RecordBatch) -> Result<i64, EventTimeError>
pub fn extract(&mut self, batch: &RecordBatch) -> Result<i64, EventTimeError>
Extracts the event timestamp from a batch, in epoch milliseconds.
§Errors
Returns an error if the batch is empty, the column is missing,
the column is not a Timestamp(_), the value at the selected row
is null, or Arrow’s cast kernel fails.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for EventTimeExtractor
impl RefUnwindSafe for EventTimeExtractor
impl Send for EventTimeExtractor
impl Sync for EventTimeExtractor
impl Unpin for EventTimeExtractor
impl UnsafeUnpin for EventTimeExtractor
impl UnwindSafe for EventTimeExtractor
Blanket Implementations§
§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
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
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§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 more§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Returns the layout of the type.