Function dataflow::render::sources::import_table [−][src]
pub(crate) fn import_table<G>(
as_of_frontier: &Antichain<Timestamp>,
storage_state: &mut StorageState,
scope: &mut G,
persisted_name: Option<String>
) -> (LocalInput, (Collection<G, Row>, Collection<G, DataflowError>)) where
G: Scope<Timestamp = Timestamp>,
Expand description
Imports a table (non-durable, local source of input).