pub struct StateFile {
pub name: String,
pub path: PathBuf,
pub min_time: i64,
pub max_time: i64,
}Expand description
An immutable local state file an operator produced at a barrier: content-stable, so a backend
that stores files (the object store) uploads it once and later epochs that still reference it
re-upload nothing. min_time/max_time are its event-time range, for the manifest and rescale.
Fields§
§name: String§path: PathBuf§min_time: i64§max_time: i64Trait Implementations§
impl Eq for StateFile
impl StructuralPartialEq for StateFile
Auto Trait Implementations§
impl Freeze for StateFile
impl RefUnwindSafe for StateFile
impl Send for StateFile
impl Sync for StateFile
impl Unpin for StateFile
impl UnsafeUnpin for StateFile
impl UnwindSafe for StateFile
Blanket Implementations§
impl<T> Allocation for T
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<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.