Class CreateView

misc/python/materialize/zippy/view_actions.py:91–137

Creates a view that is a join over one or more sources or tables

class CreateView(Action):
    """Creates a view that is a join over one or more sources or tables"""

    def __init__(self, capabilities: Capabilities, view: ViewExists) -> None:
        self.view = view
        super().__init__(capabilities)

    def run(self, c: Composition, state: State) -> None:
        first_input = self.view.inputs[0]
        outer_join = " ".join(
            f"JOIN {f.get_name_for_query()} USING (f1)" for f in self.view.inputs[1:]
        )

        index = (
            f"> CREATE DEFAULT INDEX ON {self.view.name}" if self.view.has_index else ""
        )

        aggregates = [f"COUNT({first_input.get_name_for_query()}.f1) AS count_all"]

        if self.view.expensive_aggregates:
            aggregates.extend(
                [
                    f"COUNT(DISTINCT {first_input.get_name_for_query()}.f1) AS count_distinct",
                    f"MIN({first_input.get_name_for_query()}.f1) AS min_value",
                    f"MAX({first_input.get_name_for_query()}.f1) AS max_value",
                ]
            )

        aggregates = ", ".join(aggregates)

        refresh = random.choice(
            ["ON COMMIT", f"EVERY '{random.randint(1, 5)} seconds'"]
        )

        c.testdrive(
            dedent(f"""
                > CREATE MATERIALIZED VIEW {self.view.name}
                  WITH (REFRESH {refresh}) AS
                  SELECT {aggregates}
                  FROM {first_input.get_name_for_query()}
                  {outer_join}
                """) + index,
            mz_service=state.mz_service,
        )

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


class ValidateView(Action):