Trait dataflow::render::sinks::SinkRender [−][src]
pub trait SinkRender<G> where
G: Scope<Timestamp = Timestamp>, {
fn uses_keys(&self) -> bool;
fn get_key_indices(&self) -> Option<&[usize]>;
fn get_relation_key_indices(&self) -> Option<&[usize]>;
fn render_continuous_sink(
&self,
compute_state: &mut ComputeState,
sink: &SinkDesc,
sink_id: GlobalId,
sinked_collection: Collection<G, (Option<Row>, Option<Row>), Diff>,
metrics: &SinkBaseMetrics
) -> Option<Rc<dyn Any>>
where
G: Scope<Timestamp = Timestamp>;
}