Struct VertexTransform 

pub struct VertexTransform {
    pub label: String,
    pub id_column: String,
    pub properties: Vec<String>,
    pub rename: HashMap<String, String>,
}

Rows → nodes. Selects id_column + properties, applies rename.

Fields

label: String

id_column: String

properties: Vec<String>

rename: HashMap<String, String>

Trait Implementations

impl Clone for VertexTransform

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for VertexTransform

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for VertexTransform

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for VertexTransform

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Transform for VertexTransform

fn apply( &self, _ctx: &TableContext, batches: &[RecordBatch], ) -> Result<GraphMutation>

fn apply_deletes( &self, ctx: &TableContext, batches: &[RecordBatch], ) -> Result<GraphMutation>

The same step over a changelog round’s DELETE rows, whose nodes and edges are then removed. Such a row may carry only its key — every other column null — so a step that filters or computes on other columns must not let that drop the delete. The default is Self::apply, right for every step that only picks columns.