GraphElementRegistry¶

GraphElementRegistry is an abstraction of graph element registries.

Contract¶

Register Output¶

register_output(
    self,
    output: Output,
) -> None

See:

• SparkConnectGraphElementRegistry

Used when:

• create_sink is used
• @create_streaming_table, @table, @materialized_view, @temporary_view decorators are used

register_flow¶

register_flow(
    self,
    flow: Flow,
) -> None

See:

• SparkConnectGraphElementRegistry

Used when:

• @append_flow, @table, @materialized_view, @temporary_view decorators are used

register_sql¶

register_sql(
    self,
    sql_text: str,
    file_path: Path,
) -> None

See:

• SparkConnectGraphElementRegistry

Used when:

• pyspark.pipelines.cli is requested to register_definitions

Implementations¶

• SparkConnectGraphElementRegistry