com.splicemachine.derby.impl

Class SpliceSpark

java.lang.Object

com.splicemachine.derby.impl.SpliceSpark

public class SpliceSpark
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static org.apache.spark.broadcast.Broadcast<org.apache.spark.SerializableWritable<org.apache.hadoop.security.Credentials>>	credentials
(package private) static org.apache.spark.api.java.JavaSparkContext	ctx
(package private) static boolean	initialized
(package private) static org.apache.spark.sql.SparkSession	session
(package private) static boolean	spliceStaticComponentsSetup

Method Summary

Modifier and Type	Method and Description
static org.apache.spark.api.java.JavaSparkContext	getContext()
static org.apache.spark.api.java.JavaSparkContext	getContextUnsafe() This method is unsafe, it should only be used on tests are as a convenience when trying to get a local Spark Context, it should never be used when implementing Splice operations or functions
static org.apache.spark.broadcast.Broadcast<org.apache.spark.SerializableWritable<org.apache.hadoop.security.Credentials>>	getCredentials()
static org.apache.spark.sql.SparkSession	getSession()
static org.apache.spark.sql.SparkSession	getSessionUnsafe() This method is unsafe, it should only be used on tests are as a convenience when trying to get a local Spark Context, it should never be used when implementing Splice operations or functions
static boolean	isRunningOnSpark()
static void	logCredentialsInformation(org.apache.hadoop.security.Credentials credentials)
static void	popScope()
static void	pushScope(java.lang.String displayString)
static void	setContext(org.apache.spark.api.java.JavaSparkContext sparkContext)
static void	setContext(org.apache.spark.SparkContext sparkContext)
static void	setCredentials(org.apache.spark.broadcast.Broadcast<org.apache.spark.SerializableWritable<org.apache.hadoop.security.Credentials>> creds)
static void	setupSpliceStaticComponents()
static void	setupSpliceStaticComponents(org.apache.hadoop.security.Credentials credentials)

Methods inherited from class java.lang.Object

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

Field Detail

ctx

static org.apache.spark.api.java.JavaSparkContext ctx

session

static org.apache.spark.sql.SparkSession session

initialized

static boolean initialized

spliceStaticComponentsSetup

static boolean spliceStaticComponentsSetup

credentials

static org.apache.spark.broadcast.Broadcast<org.apache.spark.SerializableWritable<org.apache.hadoop.security.Credentials>> credentials

Method Detail

getSession

public static org.apache.spark.sql.SparkSession getSession()

setCredentials

public static void setCredentials(org.apache.spark.broadcast.Broadcast<org.apache.spark.SerializableWritable<org.apache.hadoop.security.Credentials>> creds)

getCredentials

public static org.apache.spark.broadcast.Broadcast<org.apache.spark.SerializableWritable<org.apache.hadoop.security.Credentials>> getCredentials()

getSessionUnsafe

public static org.apache.spark.sql.SparkSession getSessionUnsafe()

This method is unsafe, it should only be used on tests are as a convenience when trying to get a local Spark Context, it should never be used when implementing Splice operations or functions

getContext

public static org.apache.spark.api.java.JavaSparkContext getContext()

getContextUnsafe

public static org.apache.spark.api.java.JavaSparkContext getContextUnsafe()

This method is unsafe, it should only be used on tests are as a convenience when trying to get a local Spark Context, it should never be used when implementing Splice operations or functions

isRunningOnSpark

public static boolean isRunningOnSpark()

logCredentialsInformation

public static void logCredentialsInformation(org.apache.hadoop.security.Credentials credentials)

setupSpliceStaticComponents

public static void setupSpliceStaticComponents(org.apache.hadoop.security.Credentials credentials)
                                        throws java.io.IOException

Throws:

java.io.IOException

setupSpliceStaticComponents

public static void setupSpliceStaticComponents()
                                        throws java.io.IOException

Throws:

java.io.IOException

pushScope

public static void pushScope(java.lang.String displayString)

popScope

public static void popScope()

setContext

public static void setContext(org.apache.spark.api.java.JavaSparkContext sparkContext)

setContext

public static void setContext(org.apache.spark.SparkContext sparkContext)