Struct MutablePullExecutor 

pub struct MutablePullExecutor<'a, S: GraphStorageMut> { /* private fields */ }

Pull-based read-write executor. Wraps the existing MutableExecutor under the same row-cursor API. Mutations are applied during open_compiled; the returned cursor yields the resulting rows lazily.

Implementations

impl<'a, S: GraphStorageMut + GraphStorage> MutablePullExecutor<'a, S>

pub fn new(storage: &'a mut S, params: BTreeMap<String, LoraValue>) -> Self

pub fn open_compiled( self, compiled: &'a CompiledQuery, ) -> ExecResult<Box<dyn RowSource + 'a>>

where S: 'a,

Open a cursor for a compiled write query.

Fast path: when a branch root is one of Create / Set / Delete / Remove / Merge and its input subtree is fully streamable, returns a [StreamingWriteCursor] that pulls input row-by-row and applies the per-row write through MutableExecutor::apply_write_op. UNION ALL plans stream one branch at a time. Plain UNION drains branches first so rows can be deduplicated by name.

Fallback: a branch that is not streamable materializes through MutableExecutor::execute_rows and wraps the result in a BufferedRowSource.