Package org.apache.spark.sql.pipelines.graph

Class GraphRegistrationContext

Object
org.apache.spark.sql.pipelines.graph.GraphRegistrationContext
public class GraphRegistrationContext extends Object
A mutable context for registering tables, views, and flows in a dataflow graph.

param: defaultCatalog The pipeline's default catalog. param: defaultDatabase The pipeline's default schema.

  • Constructor Details

    • GraphRegistrationContext

      public GraphRegistrationContext(String defaultCatalog, String defaultDatabase, scala.collection.immutable.Map<String,String> defaultSqlConf)

  • Method Details

    • defaultCatalog

      public String defaultCatalog()

    • defaultDatabase

      public String defaultDatabase()

    • defaultSqlConf

      public scala.collection.immutable.Map<String,String> defaultSqlConf()

    • registerTable

      public void registerTable(Table tableDef)

    • registerView

      public void registerView(View viewDef)

    • registerSink

      public void registerSink(Sink sinkDef)

    • getViews

      public scala.collection.immutable.Seq<View> getViews()

    • getSinks

      public scala.collection.immutable.Seq<Sink> getSinks()

    • registerFlow

      public void registerFlow(UnresolvedFlow flowDef)

    • toDataflowGraph

      public DataflowGraph toDataflowGraph()