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

Class SqlGraphRegistrationContextState

Object

org.apache.spark.sql.pipelines.graph.SqlGraphRegistrationContextState

public class SqlGraphRegistrationContextState
extends Object

Data class for all state that is accumulated while processing a particular SqlGraphRegistrationContext.

param: initialCatalogOpt The initial catalog to assume. param: initialDatabaseOpt The initial database to assume. param: initialSqlConf The initial sql confs to assume.

Constructor Summary

Constructors

Constructor	Description
SqlGraphRegistrationContextState(scala.Option<String> initialCatalogOpt, scala.Option<String> initialDatabaseOpt, scala.collection.immutable.Map<String,String> initialSqlConf)

Method Summary

Modifier and Type	Method	Description
void	clearCurrentDatabase()
scala.Option<String>	getCurrentCatalogOpt()
scala.Option<String>	getCurrentDatabaseOpt()
scala.collection.immutable.Map<String,String>	getSqlConf()
void	setCurrentCatalog(String catalogName)
void	setCurrentDatabase(String databaseName)
void	setSqlConf(String k, String v)

Methods inherited from class java.lang.Object

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

Constructor Details

SqlGraphRegistrationContextState

public SqlGraphRegistrationContextState(scala.Option<String> initialCatalogOpt,
 scala.Option<String> initialDatabaseOpt,
 scala.collection.immutable.Map<String,String> initialSqlConf)

Method Details

clearCurrentDatabase

public void clearCurrentDatabase()

getCurrentCatalogOpt

public scala.Option<String> getCurrentCatalogOpt()

getCurrentDatabaseOpt

public scala.Option<String> getCurrentDatabaseOpt()

getSqlConf

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

setCurrentCatalog

public void setCurrentCatalog(String catalogName)

setCurrentDatabase

public void setCurrentDatabase(String databaseName)

setSqlConf

public void setSqlConf(String k,
 String v)