Skip to main content

DataOutputs

mz_storage::source::mysql

Type Alias DataOutputs 

Source 
type DataOutputs = SharedFuel<GtidPartition, CapacityContainerBuilder<Vec<(Result<SourceMessage, DataflowError>, GtidPartition, Diff)>>>;
Expand description

The data output ports of an operator, one per source export in output index order.

Aliased Type§

struct DataOutputs {
    handles: Vec<AsyncOutputHandle<Partitioned<Uuid, GtidState>, CapacityContainerBuilder<Vec<(Result<SourceMessage, DataflowError>, Partitioned<Uuid, GtidState>, Overflowing<i64>)>>>>,
    outstanding_bytes: usize,
    yielded: bool,
}

Fields§

§handles: Vec<AsyncOutputHandle<Partitioned<Uuid, GtidState>, CapacityContainerBuilder<Vec<(Result<SourceMessage, DataflowError>, Partitioned<Uuid, GtidState>, Overflowing<i64>)>>>>§outstanding_bytes: usize§yielded: bool