Function dataflow::render::sources::get_persist_config [−][src]
fn get_persist_config(
source_id: &SourceInstanceId,
persist_desc: SourcePersistDesc,
persist_client: &mut RuntimeClient
) -> PersistentSourceConfig<Result<Row, DecodeError>, Result<Row, DecodeError>, SourceTimestamp, AssignedTimestamp>