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.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	GraphRegistrationContext.DatasetType

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
String	defaultCatalog()
String	defaultDatabase()
scala.collection.immutable.Map<String,String>	defaultSqlConf()
void	registerFlow(UnresolvedFlow flowDef)
void	registerTable(Table tableDef)
void	registerView(View viewDef)
DataflowGraph	toDataflowGraph()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)

registerFlow

public void registerFlow(UnresolvedFlow flowDef)

toDataflowGraph

public DataflowGraph toDataflowGraph()