mz_compute::logging::compute

Type Alias PusherColumnar

Source
type PusherColumnar<D> = Counter<Timestamp, Column<(D, Timestamp, Diff)>, Tee<Timestamp, Column<(D, Timestamp, Diff)>>>;
Expand description

A pusher for updates of value D for columnar containers.

Aliased Type§

struct PusherColumnar<D> { /* private fields */ }

Implementations

Source§

impl<T, C, P> Counter<T, C, P>
where P: Push<Message<T, C>>, T: Ord + Clone + 'static,

Source

pub fn new(pushee: P) -> Counter<T, C, P>

Allocates a new Counter from a pushee and shared counts.

Source

pub fn produced(&self) -> &Rc<RefCell<ChangeBatch<T>>>

A references to shared changes in counts, for cloning or draining.

Trait Implementations

Source§

impl<T, C, P> Debug for Counter<T, C, P>
where T: Debug, C: Debug, P: Debug + Push<Message<T, C>>,

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter. Read more
Source§

impl<T, C, P> Push<Message<T, C>> for Counter<T, C, P>
where T: Timestamp, C: Container, P: Push<Message<T, C>>,

Source§

fn push(&mut self, message: &mut Option<Message<T, C>>)

Pushes element with the opportunity to take ownership.
Source§

fn send(&mut self, element: T)

Pushes element and drops any resulting resources.
Source§

fn done(&mut self)

Pushes None, conventionally signalling a flush.