Enum dataflow::SequencedCommand[][src]

pub enum SequencedCommand {
    CreateDataflows(Vec<DataflowDesc>),
    DropSources(Vec<GlobalId>),
    DropSinks(Vec<GlobalId>),
    DropIndexes(Vec<GlobalId>),
    Peek {
        id: GlobalId,
        key: Option<Row>,
        conn_id: u32,
        tx: UnboundedSender<PeekResponse>,
        timestamp: Timestamp,
        finishing: RowSetFinishing,
        map_filter_project: MapFilterProject,
    },
    CancelPeek {
        conn_id: u32,
    },
    Insert {
        id: GlobalId,
        updates: Vec<Update>,
    },
    AllowCompaction(Vec<(GlobalId, Antichain<Timestamp>)>),
    AddSourceTimestamping {
        id: GlobalId,
        connector: SourceConnector,
    },
    AdvanceSourceTimestamp {
        id: GlobalId,
        update: TimestampSourceUpdate,
    },
    DropSourceTimestamping {
        id: GlobalId,
    },
    AdvanceAllLocalInputs {
        advance_to: Timestamp,
    },
    EnableFeedback(UnboundedSender<WorkerFeedbackWithMeta>),
    EnableCaching(UnboundedSender<CacheMessage>),
    EnableLogging(LoggingConfig),
    Shutdown,
}

Explicit instructions for timely dataflow workers.

Variants

CreateDataflows(Vec<DataflowDesc>)

Create a sequence of dataflows.

DropSources(Vec<GlobalId>)

Drop the sources bound to these names.

DropSinks(Vec<GlobalId>)

Drop the sinks bound to these names.

DropIndexes(Vec<GlobalId>)

Drop the indexes bound to these namees.

Peek

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.

Fields of Peek

id: GlobalId

The identifier of the arrangement.

key: Option<Row>

An optional key that should be used for the arrangement.

conn_id: u32

The identifier of this peek request.

Used in responses and cancelation requests.

tx: UnboundedSender<PeekResponse>

A communication link for sending a response.

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: MapFilterProject

Linear operation to apply in-line on each result.

CancelPeek

Cancel the peek associated with the given conn_id.

Fields of CancelPeek

conn_id: u32

The identifier of the peek request to cancel.

Insert

Insert updates into the local input named id.

Fields of Insert

id: GlobalId

Identifier of the local input.

updates: Vec<Update>

A list of updates to be introduced to the input.

AllowCompaction(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.

AddSourceTimestamping

Add a new source to be aware of for timestamping.

Fields of AddSourceTimestamping

id: GlobalId

The ID of the timestamped source

connector: SourceConnector

The connector for the timestamped source.

AdvanceSourceTimestamp

Advance worker timestamp

Fields of AdvanceSourceTimestamp

id: GlobalId

The ID of the timestamped source

update: TimestampSourceUpdate

The associated update (RT or BYO)

DropSourceTimestamping

Drop all timestamping info for a source

Fields of DropSourceTimestamping

id: GlobalId

The ID id of the formerly timestamped source.

AdvanceAllLocalInputs

Advance all local inputs to the given timestamp.

Fields of AdvanceAllLocalInputs

advance_to: Timestamp

The timestamp to advance to.

EnableFeedback(UnboundedSender<WorkerFeedbackWithMeta>)

Request that feedback is streamed to the provided channel.

EnableCaching(UnboundedSender<CacheMessage>)

Request that cache data is streamed to the provided channel.

EnableLogging(LoggingConfig)

Request that the logging sources in the contained configuration are installed.

Shutdown

Disconnect inputs, drain dataflows, and shut down timely workers.

Trait Implementations

impl Clone for SequencedCommand[src]

impl Debug for SequencedCommand[src]

Auto Trait Implementations

impl !RefUnwindSafe for SequencedCommand[src]

impl Send for SequencedCommand[src]

impl Sync for SequencedCommand[src]

impl Unpin for SequencedCommand[src]

impl !UnwindSafe for SequencedCommand[src]

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> Data for T where
    T: 'static + Clone
[src]

impl<T> From<T> for T[src]

impl<T> Instrument for T[src]

impl<T> Instrument for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T> ProgressEventTimestamp for T where
    T: Data + Any + Debug
[src]

impl<T> Same<T> for T[src]

type Output = T

Should always be Self

impl<T> ToOwned for T where
    T: Clone
[src]

type Owned = T

The resulting type after obtaining ownership.

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>, 
[src]