pub fn trace<T>(&self) -> Stream<Circuit<P>, T>
    where
        B: BatchReader<Time = ()>,
        B::Key: Clone,
        B::Val: Clone,
        T: NumEntries
            + DeepSizeOf
            + Trace<Key = B::Key, Val = B::Val, Time = NestedTimestamp32, R = B::R>
            + Clone
            + 'static,
    {
        self.circuit()
            .cache_get_or_insert_with(TraceId::new(self.local_node_id()), || {
                self.circuit().region("trace", || {
                    let (ExportStream { local, export }, z1feedback) =
                        self.circuit().add_feedback_with_export(Z1Trace::new(false));
                    let trace = self.circuit().add_binary_operator_with_preference(
                        <TraceAppend<T, B>>::new(),
                        &local,
                        self,
                        OwnershipPreference::STRONGLY_PREFER_OWNED,
                        OwnershipPreference::PREFER_OWNED,
                    );
                    z1feedback.connect_with_preference(
                        &trace,
                        OwnershipPreference::STRONGLY_PREFER_OWNED,
                    );
                    self.circuit()
                        .cache_insert(DelayedTraceId::new(trace.local_node_id()), local);
                    self.circuit()
                        .cache_insert(ExportId::new(trace.local_node_id()), export);
                    trace
                })
            })
            .clone()
    }
/// Record batches in `self` in a trace.
///
/// This operator labels each untimed batch in the stream with the current
/// timestamp and adds it to a trace.  
Record batches in `self` in a trace.
This operator labels each untimed batch in the stream with the current
timestamp and adds it to a trace.
Record batches in ` self ` in a trace . This operator labels each untimed batch in the stream with the current timestamp and adds it to a trace .
pub fn trace<T>(&self) -> Stream<Circuit<P>, T>
    where
        B: BatchReader<Time = ()>,
        B::Key: Clone,
        B::Val: Clone,
        T: NumEntries
            + DeepSizeOf
            + Trace<Key = B::Key, Val = B::Val, Time = NestedTimestamp32, R = B::R>
            + Clone
            + 'static,
    {
        self.circuit()
            .cache_get_or_insert_with(TraceId::new(self.local_node_id()), || {
                self.circuit().region("trace", || {
                    let (ExportStream { local, export }, z1feedback) =
                        self.circuit().add_feedback_with_export(Z1Trace::new(false));
                    let trace = self.circuit().add_binary_operator_with_preference(
                        <TraceAppend<T, B>>::new(),
                        &local,
                        self,
                        OwnershipPreference::STRONGLY_PREFER_OWNED,
                        OwnershipPreference::PREFER_OWNED,
                    );
                    z1feedback.connect_with_preference(
                        &trace,
                        OwnershipPreference::STRONGLY_PREFER_OWNED,
                    );
                    self.circuit()
                        .cache_insert(DelayedTraceId::new(trace.local_node_id()), local);
                    self.circuit()
                        .cache_insert(ExportId::new(trace.local_node_id()), export);
                    trace
                })
            })
            .clone()
    }
pub fn trace < T > ( & self ) -> Stream < Circuit < P > , T > where B : BatchReader < Time = ( ) > , B :: Key : Clone , B :: Val : Clone , T : NumEntries + DeepSizeOf + Trace < Key = B :: Key , Val = B :: Val , Time = NestedTimestamp32 , R = B :: R > + Clone + ' static , { self . circuit ( ) . cache_get_or_insert_with ( TraceId :: new ( self . local_node_id ( ) ) , | | { self . circuit ( ) . region ( " " , | | { let ( ExportStream { local , export } , z1feedback ) = self . circuit ( ) . add_feedback_with_export ( Z1Trace :: new ( false ) ) ; let trace = self . circuit ( ) . add_binary_operator_with_preference ( < TraceAppend < T , B > > :: new ( ) , & local , self , OwnershipPreference :: STRONGLY_PREFER_OWNED , OwnershipPreference :: PREFER_OWNED , ) ; z1feedback . connect_with_preference ( & trace , OwnershipPreference :: STRONGLY_PREFER_OWNED , ) ; self . circuit ( ) . cache_insert ( DelayedTraceId :: new ( trace . local_node_id ( ) ) , local ) ; self . circuit ( ) . cache_insert ( ExportId :: new ( trace . local_node_id ( ) ) , export ) ; trace } ) } ) . clone ( ) }
Record batches in `self` in a trace.
Record batches in ` self ` in a trace .
&self