Class CreateTable

misc/python/materialize/zippy/table_actions.py:59–89

Creates a table on the Mz instance. 50% of the tables have a default index.

class CreateTable(Action):
    """Creates a table on the Mz instance. 50% of the tables have a default index."""

    @classmethod
    def requires(cls) -> set[type[Capability]]:
        return {BalancerdIsRunning, MzIsRunning}

    def __init__(self, table: TableExists, capabilities: Capabilities) -> None:
        assert (
            table is not None
        ), "CreateTable Action can not be referenced directly, it is produced by CreateTableParameterized factory"
        self.table = table
        super().__init__(capabilities)

    def run(self, c: Composition, state: State) -> None:
        index = (
            f"> CREATE DEFAULT INDEX ON {self.table.name}"
            if self.table.has_index
            else ""
        )
        c.testdrive(
            dedent(f"""
                > CREATE TABLE {self.table.name} (f1 INTEGER);
                {index}
                > INSERT INTO {self.table.name} VALUES ({self.table.watermarks.max});
                """),
            mz_service=state.mz_service,
        )

    def provides(self) -> list[Capability]:
        return [self.table]


class ValidateTable(Action):