Enum dataflow_types::client::ComputeCommand [−][src]
pub enum ComputeCommand {
CreateInstance,
DropInstance,
CreateDataflows(Vec<DataflowDescription<Plan>>),
DropSinks(Vec<GlobalId>),
DropIndexes(Vec<GlobalId>),
Peek {
id: GlobalId,
key: Option<Row>,
conn_id: u32,
timestamp: Timestamp,
finishing: RowSetFinishing,
map_filter_project: SafeMfpPlan,
},
CancelPeek {
conn_id: u32,
},
AllowIndexCompaction(Vec<(GlobalId, Antichain<Timestamp>)>),
EnableLogging(LoggingConfig),
}
Expand description
Commands related to the computation and maintenance of views.
Variants
CreateInstance
Indicates the creation of an instance, and is the first command for its compute instance.
DropInstance
Indicates the termination of an instance, and is the last command for its compute instance.
CreateDataflows(Vec<DataflowDescription<Plan>>)
Tuple Fields
0: Vec<DataflowDescription<Plan>>
Create a sequence of dataflows.
Each of the dataflows must contain as_of
members that are valid
for each of the referenced arrangements, meaning AllowCompaction
should be held back to those values until the command.
Subsequent commands may arbitrarily compact the arrangements;
the dataflow runners are responsible for ensuring that they can
correctly maintain the dataflows.
DropSinks(Vec<GlobalId>)
Drop the sinks bound to these names.
DropIndexes(Vec<GlobalId>)
Drop the indexes bound to these namees.
Peek
Fields
id: GlobalId
The identifier of the arrangement.
conn_id: u32
The identifier of this peek request.
Used in responses and cancelation requests.
timestamp: Timestamp
The logical timestamp at which the arrangement is queried.
finishing: RowSetFinishing
Actions to apply to the result set before returning them.
map_filter_project: SafeMfpPlan
Linear operation to apply in-line on each result.
Peek at an arrangement.
This request elicits data from the worker, by naming an arrangement and some actions to apply to the results before returning them.
The timestamp
member must be valid for the arrangement that
is referenced by id
. This means that AllowCompaction
for
this arrangement should not pass timestamp
before this command.
Subsequent commands may arbitrarily compact the arrangements;
the dataflow runners are responsible for ensuring that they can
correctly answer the Peek
.
CancelPeek
Fields
conn_id: u32
The identifier of the peek request to cancel.
Cancel the peek associated with the given conn_id
.
AllowIndexCompaction(Vec<(GlobalId, Antichain<Timestamp>)>)
Enable compaction in views.
Each entry in the vector names a view and provides a frontier after which accumulations must be correct. The workers gain the liberty of compacting the corresponding maintained traces up through that frontier.
EnableLogging(LoggingConfig)
Tuple Fields
Request that the logging sources in the contained configuration are installed.
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
Performs the conversion.
Performs the conversion.
Auto Trait Implementations
impl RefUnwindSafe for ComputeCommand
impl Send for ComputeCommand
impl Sync for ComputeCommand
impl Unpin for ComputeCommand
impl UnwindSafe for ComputeCommand
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