Package org.rumbledb.spark

Class SparkSessionManager

java.lang.Object

org.rumbledb.spark.SparkSessionManager

public class SparkSessionManager
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	countColumnName
static final String	emptyObjectJSONiqItemColumnName
static final String	leftHandSideHashColumnName
static final String	mutabilityLevelColumnName
static final String	nonObjectJSONiqItemColumnName
static final String	pathInColumnName
static final String	rightHandSideHashColumnName
static final String	rowIdColumnName
static final String	rowOrderColumnName
static final String	sequenceColumnName
static final String	sparkSqlVariableName
static final String	tableLocationColumnName
static final String	tempMaxRowIdColumnName
static final String	tempMaxRowOrderColumnName
static final String	tempMinRowOrderColumnName
static final String	temporaryColumnName
static final String	tempRowNumColumnName
static final String	tempRowNumOrderColumnName
static final String	tempRowNumSeqColumnName

Method Summary

Modifier and Type	Method	Description
static SparkSessionManager	getInstance()
static SparkSessionManager	getInstance(org.apache.spark.SparkConf conf)
static SparkSessionManager	getInstance(org.apache.spark.sql.SparkSession session)
org.apache.spark.api.java.JavaSparkContext	getJavaSparkContext()
org.apache.spark.sql.SparkSession	getOrCreateSession()
void	initializeConfigurationAndSession(org.apache.spark.SparkConf conf, boolean setAppName)
void	resetSession()

Methods inherited from class java.lang.Object

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

Field Details

nonObjectJSONiqItemColumnName

public static final String nonObjectJSONiqItemColumnName

See Also:

• Constant Field Values

emptyObjectJSONiqItemColumnName

public static final String emptyObjectJSONiqItemColumnName

See Also:

• Constant Field Values

temporaryColumnName

public static final String temporaryColumnName

See Also:

• Constant Field Values

countColumnName

public static final String countColumnName

See Also:

• Constant Field Values

rightHandSideHashColumnName

public static final String rightHandSideHashColumnName

See Also:

• Constant Field Values

leftHandSideHashColumnName

public static final String leftHandSideHashColumnName

See Also:

• Constant Field Values

sparkSqlVariableName

public static final String sparkSqlVariableName

See Also:

• Constant Field Values

sequenceColumnName

public static final String sequenceColumnName

See Also:

• Constant Field Values

tempMaxRowIdColumnName

public static final String tempMaxRowIdColumnName

See Also:

• Constant Field Values

tempMinRowOrderColumnName

public static final String tempMinRowOrderColumnName

See Also:

• Constant Field Values

tempMaxRowOrderColumnName

public static final String tempMaxRowOrderColumnName

See Also:

• Constant Field Values

tempRowNumColumnName

public static final String tempRowNumColumnName

See Also:

• Constant Field Values

tempRowNumSeqColumnName

public static final String tempRowNumSeqColumnName

See Also:

• Constant Field Values

tempRowNumOrderColumnName

public static final String tempRowNumOrderColumnName

See Also:

• Constant Field Values

mutabilityLevelColumnName

public static final String mutabilityLevelColumnName

See Also:

• Constant Field Values

rowIdColumnName

public static final String rowIdColumnName

See Also:

• Constant Field Values

pathInColumnName

public static final String pathInColumnName

See Also:

• Constant Field Values

tableLocationColumnName

public static final String tableLocationColumnName

See Also:

• Constant Field Values

rowOrderColumnName

public static final String rowOrderColumnName

See Also:

• Constant Field Values

Method Details

getInstance

public static SparkSessionManager getInstance()

getInstance

public static SparkSessionManager getInstance(org.apache.spark.SparkConf conf)

getInstance

public static SparkSessionManager getInstance(org.apache.spark.sql.SparkSession session)

getOrCreateSession

public org.apache.spark.sql.SparkSession getOrCreateSession()

resetSession

public void resetSession()

initializeConfigurationAndSession

public void initializeConfigurationAndSession(org.apache.spark.SparkConf conf,
 boolean setAppName)

getJavaSparkContext

public org.apache.spark.api.java.JavaSparkContext getJavaSparkContext()