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 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.

table_catalog: Arc<TableCatalog>

Table catalog for data access.

Implementations

impl PhysicalExtend

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