pub struct FactorizedExpandChain { /* private fields */ }Expand description
Builder for chaining multiple factorized expansions.
This is useful for multi-hop queries where you want to keep data factorized across multiple expansion steps.
Implementations§
Source§impl FactorizedExpandChain
impl FactorizedExpandChain
Sourcepub fn new(store: Arc<LpgStore>, source: Box<dyn Operator>) -> Self
pub fn new(store: Arc<LpgStore>, source: Box<dyn Operator>) -> Self
Creates a new chain starting from a source operator.
Sourcepub fn with_tx_context(self, epoch: EpochId, tx_id: Option<TxId>) -> Self
pub fn with_tx_context(self, epoch: EpochId, tx_id: Option<TxId>) -> Self
Sets the transaction context.
Sourcepub fn expand(
self,
source_column: usize,
direction: Direction,
edge_type: Option<String>,
) -> Result<Self, OperatorError>
pub fn expand( self, source_column: usize, direction: Direction, edge_type: Option<String>, ) -> Result<Self, OperatorError>
Adds an expansion step to the chain.
Returns self for chaining.
Sourcepub fn finish(self) -> Option<FactorizedChunk>
pub fn finish(self) -> Option<FactorizedChunk>
Finishes the chain and returns the factorized result.
Sourcepub fn finish_flat(self) -> Option<DataChunk>
pub fn finish_flat(self) -> Option<DataChunk>
Finishes the chain and returns a flattened DataChunk.
Auto Trait Implementations§
impl Freeze for FactorizedExpandChain
impl !RefUnwindSafe for FactorizedExpandChain
impl Send for FactorizedExpandChain
impl Sync for FactorizedExpandChain
impl Unpin for FactorizedExpandChain
impl !UnwindSafe for FactorizedExpandChain
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more