io.Changes

Rows to insert into and delete from one table (bag semantics: each

Usage

Source

io.Changes(
    inserts=list(),
    deletes=list(),
)

deleted row removes one occurrence).

Rows are an Arrow table with the table’s columns, or tuples in the table’s column order. An update is a delete of the old row plus an insert of the new one. StaticSource.apply takes one.

Attributes

inserts: pa.Table | Sequence[Row]

Rows to add. Default: none.

deletes: pa.Table | Sequence[Row]

Rows to remove, one occurrence each; every one must be in the table, or StaticSource.apply raises ValueError. Default: none.