Enum strymon_job::operators::publish::Partition

pub enum Partition {
    PerWorker,
    Merge,
}

Marker to specify topic partitioning.

A single logical Timely Dataflow stream will have a partition on each worker. When publishing a logical stream, the publishing job can decide to either publish each stream partition indivdually, or have them be merged by a single worker, resulting in a single topic.

Variants

PerWorker

Publish one topic per worker.

The resulting topic name will have the local worker identifier as suffix, e.g. name.1 for the stream produced by worker 1.

Merge

Merge all streams and publish a single topic.

No worker identifier is appended to the name.

Trait Implementations

impl Debug for Partition

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Copy for Partition

impl Clone for Partition

fn clone(&self) -> Partition

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.