org.apache.pig.backend.hadoop.executionengine.spark

Class SparkPigContext

java.lang.Object

org.apache.pig.backend.hadoop.executionengine.spark.SparkPigContext

public class SparkPigContext
extends java.lang.Object

singleton class like PigContext

Constructor Summary

Constructors

Constructor and Description
SparkPigContext()

Method Summary

Modifier and Type	Method and Description
static SparkPigContext	get()
static java.util.concurrent.ConcurrentHashMap<java.lang.String,<any>>	getBroadcastedVars()
static int	getDefaultParallelism()
static int	getParallelism(java.util.List<<any>> predecessors, PhysicalOperator physicalOperator)
static void	setDefaultParallelism(int defaultParallelism)

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkPigContext

public SparkPigContext()

Method Detail

get

public static SparkPigContext get()

getDefaultParallelism

public static int getDefaultParallelism()

getParallelism

public static int getParallelism(java.util.List<<any>> predecessors,
                                 PhysicalOperator physicalOperator)

setDefaultParallelism

public static void setDefaultParallelism(int defaultParallelism)

getBroadcastedVars

public static java.util.concurrent.ConcurrentHashMap<java.lang.String,<any>> getBroadcastedVars()