pub fn build_export_dataflow<A: Allocate>(
timely_worker: &mut Worker<A>,
storage_state: &mut StorageState,
id: GlobalId,
description: StorageSinkDesc<CollectionMetadata, Timestamp>,
)
Expand description
do the export dataflow thing
pub fn build_export_dataflow<A: Allocate>(
timely_worker: &mut Worker<A>,
storage_state: &mut StorageState,
id: GlobalId,
description: StorageSinkDesc<CollectionMetadata, Timestamp>,
)
do the export dataflow thing