flow::batching_mode::task

Function create_table_with_expr

Source
fn create_table_with_expr(
    plan: &LogicalPlan,
    sink_table_name: &[String; 3],
) -> Result<CreateTableExpr, Error>