Struct persist::operators::upsert::DifferentialStateIngester [−][src]
Expand description
Ingests differential updates, consolidates them, and emits a final HashMap
that contains the
consolidated upsert state.
Fields
differential_state: HashMap<(K, V), isize>
Implementations
Auto Trait Implementations
impl<K, V> RefUnwindSafe for DifferentialStateIngester<K, V> where
K: RefUnwindSafe,
V: RefUnwindSafe,
impl<K, V> Send for DifferentialStateIngester<K, V> where
K: Send,
V: Send,
impl<K, V> Sync for DifferentialStateIngester<K, V> where
K: Sync,
V: Sync,
impl<K, V> Unpin for DifferentialStateIngester<K, V> where
K: Unpin,
V: Unpin,
impl<K, V> UnwindSafe for DifferentialStateIngester<K, V> where
K: UnwindSafe,
V: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more