Type Alias DataOutput 

type DataOutput = AsyncOutputHandle<KafkaTimestamp, FueledBuilder<CapacityContainerBuilder<Vec<((usize, Result<SourceMessage, DataflowError>), KafkaTimestamp, Diff)>>>>;

Aliased Type

struct DataOutput { /* private fields */ }