Struct rlink::functions::schema_base::timestamp_assigner::SchemaBaseTimestampAssigner [−][src]
pub struct SchemaBaseTimestampAssigner { /* fields omitted */ }
Implementations
Trait Implementations
impl CheckpointFunction for SchemaBaseTimestampAssigner
[src]
impl CheckpointFunction for SchemaBaseTimestampAssigner
[src]fn consult_version(
&mut self,
context: &FunctionSnapshotContext,
_handle: &Option<CheckpointHandle>
) -> CheckpointId
[src]
&mut self,
context: &FunctionSnapshotContext,
_handle: &Option<CheckpointHandle>
) -> CheckpointId
fn initialize_state(
&mut self,
_context: &FunctionSnapshotContext,
_handle: &Option<CheckpointHandle>
)
[src]
&mut self,
_context: &FunctionSnapshotContext,
_handle: &Option<CheckpointHandle>
)
fn snapshot_state(
&mut self,
_context: &FunctionSnapshotContext
) -> Option<CheckpointHandle>
[src]
&mut self,
_context: &FunctionSnapshotContext
) -> Option<CheckpointHandle>
impl TimestampAssigner for SchemaBaseTimestampAssigner
[src]
impl TimestampAssigner for SchemaBaseTimestampAssigner
[src]fn extract_timestamp(
&mut self,
row: &mut Record,
_previous_element_timestamp: u64
) -> u64
[src]
&mut self,
row: &mut Record,
_previous_element_timestamp: u64
) -> u64
Auto Trait Implementations
impl RefUnwindSafe for SchemaBaseTimestampAssigner
impl RefUnwindSafe for SchemaBaseTimestampAssigner
impl Send for SchemaBaseTimestampAssigner
impl Send for SchemaBaseTimestampAssigner
impl Sync for SchemaBaseTimestampAssigner
impl Sync for SchemaBaseTimestampAssigner
impl Unpin for SchemaBaseTimestampAssigner
impl Unpin for SchemaBaseTimestampAssigner
impl UnwindSafe for SchemaBaseTimestampAssigner
impl UnwindSafe for SchemaBaseTimestampAssigner
Blanket Implementations
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T> Same<T> for T
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<T> UnsafeAny for T where
T: Any,
impl<T> UnsafeAny for T where
T: Any,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,