Function columnar_count

nodedb-test-support/src/tx_batch_helpers.rs:234–253

(collection: &str)

}

pub fn columnar_count(collection: &str) -> PhysicalPlan {
    PhysicalPlan::Query(QueryOp::Aggregate {
        collection: collection.into(),
        group_by: Vec::new(),
        aggregates: vec![AggregateSpec {
            function: "count".into(),
            alias: "count(*)".into(),
            user_alias: None,
            field: "*".into(),
            expr: None,
        }],
        filters: Vec::new(),
        having: Vec::new(),
        limit: 10,
        sub_group_by: Vec::new(),
        sub_aggregates: Vec::new(),
        grouping_sets: Vec::new(),
        sort_keys: Vec::new(),
    })
}

pub fn timeseries_ingest(collection: &str, ilp: &str) -> PhysicalPlan {
    PhysicalPlan::Timeseries(TimeseriesOp::Ingest {