(&mut self, task: &ExecutionTask, op: &ColumnarOp)
| 11 | |
| 12 | impl CoreLoop { |
| 13 | pub(super) fn dispatch_columnar(&mut self, task: &ExecutionTask, op: &ColumnarOp) -> Response { |
| 14 | match op { |
| 15 | ColumnarOp::Scan { |
| 16 | collection, |
| 17 | projection, |
| 18 | limit, |
| 19 | filters, |
| 20 | rls_filters, |
| 21 | sort_keys, |
| 22 | system_as_of_ms, |
| 23 | valid_at_ms, |
| 24 | prefilter, |
| 25 | computed_columns, |
| 26 | } => self.execute_columnar_scan( |
| 27 | task, |
| 28 | ColumnarScanParams { |
| 29 | collection, |
| 30 | projection, |
| 31 | limit: *limit, |
| 32 | filters, |
| 33 | rls_filters, |
| 34 | sort_keys, |
| 35 | system_as_of_ms: *system_as_of_ms, |
| 36 | valid_at_ms: *valid_at_ms, |
| 37 | prefilter: prefilter.as_ref(), |
| 38 | computed_columns, |
| 39 | }, |
| 40 | ), |
| 41 | |
| 42 | ColumnarOp::Insert { |
| 43 | collection, |
| 44 | payload, |
| 45 | format, |
| 46 | intent, |
| 47 | on_conflict_updates, |
| 48 | surrogates, |
| 49 | schema_bytes, |
| 50 | } => { |
| 51 | if let Some(r) = self.check_engine_pressure(task, nodedb_mem::EngineId::Columnar) { |
| 52 | return r; |
| 53 | } |
| 54 | self.execute_columnar_insert( |
| 55 | task, |
| 56 | collection, |
| 57 | payload, |
| 58 | format, |
| 59 | *intent, |
| 60 | on_conflict_updates, |
| 61 | surrogates, |
| 62 | schema_bytes, |
| 63 | ) |
| 64 | } |
| 65 | |
| 66 | ColumnarOp::Update { |
| 67 | collection, |
| 68 | filters, |
| 69 | updates, |
| 70 | } => { |
no test coverage detected