flow::batching_mode::task

Function build_primary_key_constraint

Source 
fn build_primary_key_constraint(
    plan: &LogicalPlan,
    schema: &Fields,
) -> Result<(Option<String>, Vec<String>), Error>
Expand description

Return first timestamp column which is in group by clause and other columns which are also in group by clause

ยงReturns

  • Option<String> - first timestamp column which is in group by clause
  • Vec<String> - other columns which are also in group by clause