Enum dataflow_types::client::Command [−][src]
pub enum Command {
Compute(ComputeCommand, usize),
Storage(StorageCommand),
}
Expand description
Explicit instructions for timely dataflow workers.
Variants
Compute(ComputeCommand, usize)
A compute command.
Storage(StorageCommand)
Tuple Fields
A storage command.
Implementations
Partitions the command into parts
many disjoint pieces.
This is used to subdivide commands that can be sharded across workers,
for example the plan::Constant
stages of dataflow plans, and the
Command::Insert
commands that may contain multiple updates.
Indicates which global ids should start and cease frontier tracking.
Identifiers added to start
will install frontier tracking, and indentifiers
added to cease
will uninstall frontier tracking.
Returns the same of this kind of command.
Must remain unique over all variants of Command
.
Trait Implementations
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations
impl RefUnwindSafe for Command
impl UnwindSafe for Command
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