| 263 | } |
| 264 | |
| 265 | pub fn timeseries_scan(collection: &str) -> PhysicalPlan { |
| 266 | PhysicalPlan::Timeseries(TimeseriesOp::Scan { |
| 267 | collection: collection.into(), |
| 268 | time_range: (0, i64::MAX), |
| 269 | projection: Vec::new(), |
| 270 | limit: 100, |
| 271 | filters: Vec::new(), |
| 272 | bucket_interval_ms: 0, |
| 273 | group_by: Vec::new(), |
| 274 | aggregates: Vec::new(), |
| 275 | gap_fill: String::new(), |
| 276 | rls_filters: Vec::new(), |
| 277 | system_as_of_ms: None, |
| 278 | valid_at_ms: None, |
| 279 | computed_columns: Vec::new(), |
| 280 | }) |
| 281 | } |
| 282 | |
| 283 | pub fn crdt_apply(collection: &str, doc_id: &str) -> PhysicalPlan { |
| 284 | PhysicalPlan::Crdt(CrdtOp::Apply { |