Struct mz_compute::TraceManager
source · pub struct TraceManager { /* private fields */ }
Expand description
A TraceManager
stores maps from global identifiers to the primary arranged
representation of that collection.
Implementations§
source§impl TraceManager
impl TraceManager
sourcepub fn new(metrics: TraceMetrics, worker_id: usize) -> Self
pub fn new(metrics: TraceMetrics, worker_id: usize) -> Self
TODO(undocumented)
sourcepub fn maintenance(&mut self)
pub fn maintenance(&mut self)
performs maintenance work on the managed traces.
In particular, this method enables the physical merging of batches, so that at most a logarithmic number of batches need to be maintained. Any new batches introduced after this method is called will not be physically merged until the method is called again. This is mostly due to limitations of differential dataflow, which requires users to perform this explicitly; if that changes we may be able to remove this code.
sourcepub fn allow_compaction(
&mut self,
id: GlobalId,
frontier: AntichainRef<'_, Timestamp>
)
pub fn allow_compaction( &mut self, id: GlobalId, frontier: AntichainRef<'_, Timestamp> )
Enables compaction of traces associated with the identifier.
Compaction may not occur immediately, but once this method is called the
associated traces may not accumulate to the correct quantities for times
not in advance of frontier
. Users should take care to only rely on
accumulations at times in advance of frontier
.
sourcepub fn get(&self, id: &GlobalId) -> Option<&TraceBundle>
pub fn get(&self, id: &GlobalId) -> Option<&TraceBundle>
Returns a reference to the trace for id
, should it exist.
sourcepub fn get_mut(&mut self, id: &GlobalId) -> Option<&mut TraceBundle>
pub fn get_mut(&mut self, id: &GlobalId) -> Option<&mut TraceBundle>
Returns a mutable reference to the trace for id
, should it
exist.
sourcepub fn del_all_traces(&mut self)
pub fn del_all_traces(&mut self)
Removes all managed traces.
Auto Trait Implementations§
impl !RefUnwindSafe for TraceManager
impl !Send for TraceManager
impl !Sync for TraceManager
impl Unpin for TraceManager
impl !UnwindSafe for TraceManager
Blanket Implementations§
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
source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
RustType::into_proto
.