Class Insert

misc/python/materialize/zippy/table_actions.py:150–159

Inserts rows into a table.

class Insert(DML):
    """Inserts rows into a table."""

    def run(self, c: Composition, state: State) -> None:
        prev_max = self.table.watermarks.max
        self.table.watermarks.max = prev_max + self.delta
        c.testdrive(
            f"> INSERT INTO {self.table.name} SELECT * FROM generate_series({prev_max + 1}, {self.table.watermarks.max});",
            mz_service=state.mz_service,
        )


class ShiftForward(DML):