Struct PhysicalExtend 

pub struct PhysicalExtend {
    pub rel_table_name: String,
    pub rel_table_id: u64,
    pub rel_var: String,
    pub bound_node_var: String,
    pub direction: EdgeDirection,
    pub dst_node_var: String,
    pub dst_table_name: String,
    pub dst_table_id: u64,
    pub fts_query: Option<PhysicalFtsScan>,
    pub table_catalog: Arc<TableCatalog>,
}

Physical operator for extending from a source node through a relationship.

Takes input chunks from the source node scan, and for each source row, looks up adjacency list entries in the relationship table, producing output rows that include the source fields, relationship properties, and destination node properties.

Ported from C++ ScanRelTable (the physical extend operator).

Fields

rel_table_name: String

Name of the relationship table.

rel_table_id: u64

ID of the relationship table.

rel_var: String

Variable name of the relationship (e.g., “r”); used as the field-name prefix for relationship properties. Falls back to the table name when empty.

bound_node_var: String

Variable name of the bound (source) node.

direction: EdgeDirection

Direction of the extend.

dst_node_var: String

Variable name of the destination node.

dst_table_name: String

Table name of the destination node.

dst_table_id: u64

Table ID of the destination node.

fts_query: Option<PhysicalFtsScan>

Optional FTS query applied to the destination rows of this hop, when the indexed table is only reachable as the destination (P108.4) — the document-id set from the Tantivy index filters the produced dst rows.

table_catalog: Arc<TableCatalog>

Table catalog for data access.

Implementations

impl PhysicalExtend

pub fn execute( &self, input: Vec<DataChunk>, ) -> Result<Vec<DataChunk>, ProcessorError>