(&self, p: ScanParams)
| 33 | } |
| 34 | |
| 35 | fn plan_scan(&self, p: ScanParams) -> Result<SqlPlan> { |
| 36 | if p.temporal.is_temporal() { |
| 37 | return Err(SqlError::Unsupported { |
| 38 | detail: format!( |
| 39 | "FOR SYSTEM_TIME / FOR VALID_TIME is not supported on KV collection '{}'", |
| 40 | p.collection |
| 41 | ), |
| 42 | }); |
| 43 | } |
| 44 | Ok(SqlPlan::Scan { |
| 45 | collection: p.collection, |
| 46 | alias: p.alias, |
| 47 | engine: EngineType::KeyValue, |
| 48 | filters: p.filters, |
| 49 | projection: p.projection, |
| 50 | sort_keys: p.sort_keys, |
| 51 | limit: p.limit, |
| 52 | offset: p.offset, |
| 53 | distinct: p.distinct, |
| 54 | window_functions: p.window_functions, |
| 55 | temporal: p.temporal, |
| 56 | }) |
| 57 | } |
| 58 | |
| 59 | fn plan_point_get(&self, p: PointGetParams) -> Result<SqlPlan> { |
| 60 | Ok(SqlPlan::PointGet { |
no test coverage detected