Module materialize.zippy.sink_capabilities
Expand source code Browse git
# Copyright Materialize, Inc. and contributors. All rights reserved.
#
# Use of this software is governed by the Business Source License
# included in the LICENSE file at the root of this repository.
#
# As of the Change Date specified in that file, in accordance with
# the Business Source License, use of this software will be governed
# by the Apache License, Version 2.0.
from materialize.zippy.framework import Capability
from materialize.zippy.view_capabilities import ViewExists
class SinkExists(Capability):
"""A sink exists in Materialize."""
name: str
source_view: ViewExists
dest_view: ViewExists
@classmethod
def format_str(cls) -> str:
return "sink_{}"
def __init__(
self,
name: str,
source_view: ViewExists,
dest_view: ViewExists,
cluster_name_out: str,
cluster_name_in: str,
) -> None:
self.name = name
self.source_view = source_view
self.dest_view = dest_view
self.cluster_name_out = cluster_name_out
self.cluster_name_in = cluster_name_in
Classes
class SinkExists (name: str, source_view: ViewExists, dest_view: ViewExists, cluster_name_out: str, cluster_name_in: str)
-
A sink exists in Materialize.
Expand source code Browse git
class SinkExists(Capability): """A sink exists in Materialize.""" name: str source_view: ViewExists dest_view: ViewExists @classmethod def format_str(cls) -> str: return "sink_{}" def __init__( self, name: str, source_view: ViewExists, dest_view: ViewExists, cluster_name_out: str, cluster_name_in: str, ) -> None: self.name = name self.source_view = source_view self.dest_view = dest_view self.cluster_name_out = cluster_name_out self.cluster_name_in = cluster_name_in
Ancestors
Class variables
var dest_view : ViewExists
var name : str
var source_view : ViewExists
Static methods
def format_str() ‑> str
-
Expand source code Browse git
@classmethod def format_str(cls) -> str: return "sink_{}"