Skip to main content

sink_output_column_count

Function sink_output_column_count 

Source
pub(crate) fn sink_output_column_count(
    sink_schema: &[ColumnSchema],
) -> Result<usize, Error>
Expand description

Legacy helper for callers that only have a sink schema. New stateless flows resolve the suffix against both schemas and store it in StatelessFlow.