Modifier and Type | Class and Description |
---|---|
static class |
SparkContext.DoubleAccumulatorParam$ |
static class |
SparkContext.FloatAccumulatorParam$ |
static class |
SparkContext.IntAccumulatorParam$ |
static class |
SparkContext.LongAccumulatorParam$ |
Constructor and Description |
---|
SparkContext()
Create a SparkContext that loads settings from system properties (for instance, when
launching with ./bin/spark-submit).
|
SparkContext(SparkConf config) |
SparkContext(SparkConf config,
scala.collection.Map<String,scala.collection.Set<SplitInfo>> preferredNodeLocationData)
:: DeveloperApi ::
Alternative constructor for setting preferred locations where Spark will create executors.
|
SparkContext(String master,
String appName,
SparkConf conf)
Alternative constructor that allows setting common Spark properties directly
|
SparkContext(String master,
String appName,
String sparkHome,
scala.collection.Seq<String> jars,
scala.collection.Map<String,String> environment,
scala.collection.Map<String,scala.collection.Set<SplitInfo>> preferredNodeLocationData)
Alternative constructor that allows setting common Spark properties directly
|
Modifier and Type | Method and Description |
---|---|
<T,R> Accumulable<T,R> |
accumulable(T initialValue,
AccumulableParam<T,R> param)
Create an
Accumulable shared variable, to which tasks can add values
with += . |
<T,R> Accumulable<T,R> |
accumulable(T initialValue,
String name,
AccumulableParam<T,R> param)
Create an
Accumulable shared variable, with a name for display in the
Spark UI. |
<R,T> Accumulable<R,T> |
accumulableCollection(R initialValue,
scala.Function1<R,scala.collection.generic.Growable<T>> evidence$9,
scala.reflect.ClassTag<R> evidence$10)
Create an accumulator from a "mutable collection" type.
|
<T> Accumulator<T> |
accumulator(T initialValue,
AccumulatorParam<T> param)
Create an
Accumulator variable of a given type, which tasks can "add"
values to using the += method. |
<T> Accumulator<T> |
accumulator(T initialValue,
String name,
AccumulatorParam<T> param)
Create an
Accumulator variable of a given type, with a name for display
in the Spark UI. |
scala.collection.mutable.HashMap<String,Object> |
addedFiles() |
scala.collection.mutable.HashMap<String,Object> |
addedJars() |
void |
addFile(String path)
Add a file to be downloaded with this Spark job on every node.
|
void |
addJar(String path)
Adds a JAR dependency for all tasks to be executed on this SparkContext in the future.
|
void |
addSparkListener(SparkListener listener)
:: DeveloperApi ::
Register a listener to receive up-calls from events that happen during execution.
|
String |
appName() |
static org.apache.spark.WritableConverter<Object> |
booleanWritableConverter() |
static org.apache.hadoop.io.BooleanWritable |
boolToBoolWritable(boolean b) |
<T> Broadcast<T> |
broadcast(T value,
scala.reflect.ClassTag<T> evidence$11)
Broadcast a read-only variable to the cluster, returning a
Broadcast object for reading it in distributed functions. |
static org.apache.hadoop.io.BytesWritable |
bytesToBytesWritable(byte[] aob) |
static org.apache.spark.WritableConverter<byte[]> |
bytesWritableConverter() |
void |
cancelAllJobs()
Cancel all jobs that have been scheduled or are running.
|
void |
cancelJobGroup(String groupId)
Cancel active jobs for the specified group.
|
scala.Option<String> |
checkpointDir() |
scala.Option<org.apache.spark.ContextCleaner> |
cleaner() |
void |
clearCallSite()
Support function for API backtraces.
|
void |
clearFiles()
Clear the job's list of files added by
addFile so that they do not get downloaded to
any new nodes. |
void |
clearJars()
Clear the job's list of JARs added by
addJar so that they do not get downloaded to
any new nodes. |
void |
clearJobGroup()
Clear the current thread's job group ID and its description.
|
SparkConf |
conf() |
org.apache.spark.scheduler.DAGScheduler |
dagScheduler() |
int |
defaultMinPartitions()
Default min number of partitions for Hadoop RDDs when not given by user
|
int |
defaultMinSplits()
Default min number of partitions for Hadoop RDDs when not given by user
|
int |
defaultParallelism()
Default level of parallelism to use when not given by user (e.g.
|
static DoubleRDDFunctions |
doubleRDDToDoubleRDDFunctions(RDD<Object> rdd) |
static org.apache.hadoop.io.DoubleWritable |
doubleToDoubleWritable(double d) |
static org.apache.spark.WritableConverter<Object> |
doubleWritableConverter() |
<T> |
emptyRDD(scala.reflect.ClassTag<T> evidence$8)
Get an RDD that has no partitions or elements.
|
SparkEnv |
env() |
scala.Option<org.apache.spark.scheduler.EventLoggingListener> |
eventLogger() |
scala.collection.mutable.HashMap<String,String> |
executorEnvs() |
int |
executorMemory() |
scala.collection.Seq<String> |
files() |
static org.apache.hadoop.io.FloatWritable |
floatToFloatWritable(float f) |
static org.apache.spark.WritableConverter<Object> |
floatWritableConverter() |
scala.collection.Seq<org.apache.spark.scheduler.Schedulable> |
getAllPools()
:: DeveloperApi ::
Return pools for fair scheduler
|
scala.Option<String> |
getCheckpointDir() |
SparkConf |
getConf()
Return a copy of this SparkContext's configuration.
|
scala.collection.Map<String,scala.Tuple2<Object,Object>> |
getExecutorMemoryStatus()
Return a map from the slave to the max memory available for caching and the remaining
memory available for caching.
|
StorageStatus[] |
getExecutorStorageStatus()
:: DeveloperApi ::
Return information about blocks stored in all of the slaves
|
String |
getLocalProperty(String key)
Get a local property set in this thread, or null if it is missing.
|
scala.collection.Map<Object,RDD<?>> |
getPersistentRDDs()
Returns an immutable map of RDDs that have marked themselves as persistent via cache() call.
|
scala.Option<org.apache.spark.scheduler.Schedulable> |
getPoolForName(String pool)
:: DeveloperApi ::
Return the pool associated with the given name, if one exists
|
RDDInfo[] |
getRDDStorageInfo()
:: DeveloperApi ::
Return information about what RDDs are cached, if they are in mem or on disk, how much space
they take, etc.
|
scala.Enumeration.Value |
getSchedulingMode()
Return current scheduling mode
|
org.apache.hadoop.conf.Configuration |
hadoopConfiguration()
A default Hadoop Configuration for the Hadoop code (e.g.
|
<K,V> RDD<scala.Tuple2<K,V>> |
hadoopFile(String path,
Class<? extends org.apache.hadoop.mapred.InputFormat<K,V>> inputFormatClass,
Class<K> keyClass,
Class<V> valueClass,
int minPartitions)
Get an RDD for a Hadoop file with an arbitrary InputFormat
|
<K,V,F extends org.apache.hadoop.mapred.InputFormat<K,V>> |
hadoopFile(String path,
scala.reflect.ClassTag<K> km,
scala.reflect.ClassTag<V> vm,
scala.reflect.ClassTag<F> fm)
Smarter version of hadoopFile() that uses class tags to figure out the classes of keys,
values and the InputFormat so that users don't need to pass them directly.
|
<K,V,F extends org.apache.hadoop.mapred.InputFormat<K,V>> |
hadoopFile(String path,
int minPartitions,
scala.reflect.ClassTag<K> km,
scala.reflect.ClassTag<V> vm,
scala.reflect.ClassTag<F> fm)
Smarter version of hadoopFile() that uses class tags to figure out the classes of keys,
values and the InputFormat so that users don't need to pass them directly.
|
<K,V> RDD<scala.Tuple2<K,V>> |
hadoopRDD(org.apache.hadoop.mapred.JobConf conf,
Class<? extends org.apache.hadoop.mapred.InputFormat<K,V>> inputFormatClass,
Class<K> keyClass,
Class<V> valueClass,
int minPartitions)
Get an RDD for a Hadoop-readable dataset from a Hadoop JobConf given its InputFormat and other
necessary info (e.g.
|
void |
initLocalProperties() |
static org.apache.hadoop.io.IntWritable |
intToIntWritable(int i) |
static org.apache.spark.WritableConverter<Object> |
intWritableConverter() |
boolean |
isLocal() |
static scala.Option<String> |
jarOfClass(Class<?> cls)
Find the JAR from which a given class was loaded, to make it easy for users to pass
their JARs to SparkContext.
|
static scala.Option<String> |
jarOfObject(Object obj)
Find the JAR that contains the class of a particular object, to make it easy for users
to pass their JARs to SparkContext.
|
scala.collection.Seq<String> |
jars() |
org.apache.spark.scheduler.LiveListenerBus |
listenerBus() |
static org.apache.hadoop.io.LongWritable |
longToLongWritable(long l) |
static org.apache.spark.WritableConverter<Object> |
longWritableConverter() |
<T> RDD<T> |
makeRDD(scala.collection.Seq<T> seq,
int numSlices,
scala.reflect.ClassTag<T> evidence$2)
Distribute a local Scala collection to form an RDD.
|
<T> RDD<T> |
makeRDD(scala.collection.Seq<scala.Tuple2<T,scala.collection.Seq<String>>> seq,
scala.reflect.ClassTag<T> evidence$3)
Distribute a local Scala collection to form an RDD, with one or more
location preferences (hostnames of Spark nodes) for each object.
|
String |
master() |
org.apache.spark.util.MetadataCleaner |
metadataCleaner() |
<K,V,F extends org.apache.hadoop.mapreduce.InputFormat<K,V>> |
newAPIHadoopFile(String path,
Class<F> fClass,
Class<K> kClass,
Class<V> vClass,
org.apache.hadoop.conf.Configuration conf)
Get an RDD for a given Hadoop file with an arbitrary new API InputFormat
and extra configuration options to pass to the input format.
|
<K,V,F extends org.apache.hadoop.mapreduce.InputFormat<K,V>> |
newAPIHadoopFile(String path,
scala.reflect.ClassTag<K> km,
scala.reflect.ClassTag<V> vm,
scala.reflect.ClassTag<F> fm)
Get an RDD for a Hadoop file with an arbitrary new API InputFormat.
|
<K,V,F extends org.apache.hadoop.mapreduce.InputFormat<K,V>> |
newAPIHadoopRDD(org.apache.hadoop.conf.Configuration conf,
Class<F> fClass,
Class<K> kClass,
Class<V> vClass)
Get an RDD for a given Hadoop file with an arbitrary new API InputFormat
and extra configuration options to pass to the input format.
|
static <T> DoubleRDDFunctions |
numericRDDToDoubleRDDFunctions(RDD<T> rdd,
scala.math.Numeric<T> num) |
<T> RDD<T> |
objectFile(String path,
int minPartitions,
scala.reflect.ClassTag<T> evidence$4)
Load an RDD saved as a SequenceFile containing serialized objects, with NullWritable keys and
BytesWritable values that contain a serialized partition.
|
<T> RDD<T> |
parallelize(scala.collection.Seq<T> seq,
int numSlices,
scala.reflect.ClassTag<T> evidence$1)
Distribute a local Scala collection to form an RDD.
|
|
persistentRdds() |
scala.collection.Map<String,scala.collection.Set<SplitInfo>> |
preferredNodeLocationData() |
static <T> AsyncRDDActions<T> |
rddToAsyncRDDActions(RDD<T> rdd,
scala.reflect.ClassTag<T> evidence$19) |
static <K,V> OrderedRDDFunctions<K,V,scala.Tuple2<K,V>> |
rddToOrderedRDDFunctions(RDD<scala.Tuple2<K,V>> rdd,
scala.math.Ordering<K> evidence$24,
scala.reflect.ClassTag<K> evidence$25,
scala.reflect.ClassTag<V> evidence$26) |
static <K,V> PairRDDFunctions<K,V> |
rddToPairRDDFunctions(RDD<scala.Tuple2<K,V>> rdd,
scala.reflect.ClassTag<K> kt,
scala.reflect.ClassTag<V> vt,
scala.math.Ordering<K> ord) |
static <K,V> SequenceFileRDDFunctions<K,V> |
rddToSequenceFileRDDFunctions(RDD<scala.Tuple2<K,V>> rdd,
scala.Function1<K,org.apache.hadoop.io.Writable> evidence$20,
scala.reflect.ClassTag<K> evidence$21,
scala.Function1<V,org.apache.hadoop.io.Writable> evidence$22,
scala.reflect.ClassTag<V> evidence$23) |
<T,U,R> PartialResult<R> |
runApproximateJob(RDD<T> rdd,
scala.Function2<TaskContext,scala.collection.Iterator<T>,U> func,
:: DeveloperApi ::
Run a job that can return approximate results.
|
<T,U> Object |
runJob(RDD<T> rdd,
scala.Function1<scala.collection.Iterator<T>,U> func,
scala.reflect.ClassTag<U> evidence$16)
Run a job on all partitions in an RDD and return the results in an array.
|
<T,U> void |
runJob(RDD<T> rdd,
scala.Function1<scala.collection.Iterator<T>,U> processPartition,
scala.Function2<Object,U,scala.runtime.BoxedUnit> resultHandler,
scala.reflect.ClassTag<U> evidence$18)
Run a job on all partitions in an RDD and pass the results to a handler function.
|
<T,U> Object |
runJob(RDD<T> rdd,
scala.Function1<scala.collection.Iterator<T>,U> func,
scala.collection.Seq<Object> partitions,
boolean allowLocal,
scala.reflect.ClassTag<U> evidence$14)
Run a job on a given set of partitions of an RDD, but take a function of type
Iterator[T] => U instead of (TaskContext, Iterator[T]) => U . |
<T,U> Object |
runJob(RDD<T> rdd,
scala.Function2<TaskContext,scala.collection.Iterator<T>,U> func,
scala.reflect.ClassTag<U> evidence$15)
Run a job on all partitions in an RDD and return the results in an array.
|
<T,U> void |
runJob(RDD<T> rdd,
scala.Function2<TaskContext,scala.collection.Iterator<T>,U> processPartition,
scala.Function2<Object,U,scala.runtime.BoxedUnit> resultHandler,
scala.reflect.ClassTag<U> evidence$17)
Run a job on all partitions in an RDD and pass the results to a handler function.
|
<T,U> Object |
runJob(RDD<T> rdd,
scala.Function2<TaskContext,scala.collection.Iterator<T>,U> func,
scala.collection.Seq<Object> partitions,
boolean allowLocal,
scala.reflect.ClassTag<U> evidence$13)
Run a function on a given set of partitions in an RDD and return the results as an array.
|
<T,U> void |
runJob(RDD<T> rdd,
scala.Function2<TaskContext,scala.collection.Iterator<T>,U> func,
scala.collection.Seq<Object> partitions,
boolean allowLocal,
scala.Function2<Object,U,scala.runtime.BoxedUnit> resultHandler,
scala.reflect.ClassTag<U> evidence$12)
Run a function on a given set of partitions in an RDD and pass the results to the given
handler function.
|
<K,V> RDD<scala.Tuple2<K,V>> |
sequenceFile(String path,
Class<K> keyClass,
Class<V> valueClass)
Get an RDD for a Hadoop SequenceFile with given key and value types.
|
<K,V> RDD<scala.Tuple2<K,V>> |
sequenceFile(String path,
Class<K> keyClass,
Class<V> valueClass,
int minPartitions)
Get an RDD for a Hadoop SequenceFile with given key and value types.
|
<K,V> RDD<scala.Tuple2<K,V>> |
sequenceFile(String path,
int minPartitions,
scala.reflect.ClassTag<K> km,
scala.reflect.ClassTag<V> vm,
scala.Function0<org.apache.spark.WritableConverter<K>> kcf,
scala.Function0<org.apache.spark.WritableConverter<V>> vcf)
Version of sequenceFile() for types implicitly convertible to Writables through a
WritableConverter.
|
void |
setCallSite(String site)
Support function for API backtraces.
|
void |
setCheckpointDir(String directory)
Set the directory under which RDDs are going to be checkpointed.
|
void |
setJobDescription(String value)
Set a human readable description of the current job.
|
void |
setJobGroup(String groupId,
String description,
boolean interruptOnCancel)
Assigns a group ID to all the jobs started by this thread until the group ID is set to a
different value or cleared.
|
void |
setLocalProperty(String key,
String value)
Set a local property that affects jobs submitted from this thread, such as the
Spark fair scheduler pool.
|
static String |
SPARK_JOB_DESCRIPTION() |
static String |
SPARK_JOB_GROUP_ID() |
static String |
SPARK_JOB_INTERRUPT_ON_CANCEL() |
static String |
SPARK_UNKNOWN_USER() |
static String |
SPARK_VERSION() |
String |
sparkUser() |
long |
startTime() |
void |
stop()
Shut down the SparkContext.
|
static org.apache.hadoop.io.Text |
stringToText(String s) |
static org.apache.spark.WritableConverter<String> |
stringWritableConverter() |
<T,U,R> SimpleFutureAction<R> |
submitJob(RDD<T> rdd,
scala.Function1<scala.collection.Iterator<T>,U> processPartition,
scala.collection.Seq<Object> partitions,
scala.Function2<Object,U,scala.runtime.BoxedUnit> resultHandler,
scala.Function0<R> resultFunc)
:: Experimental ::
Submit a job for execution and return a FutureJob holding the result.
|
String |
tachyonFolderName() |
org.apache.spark.scheduler.TaskScheduler |
taskScheduler() |
RDD<String> |
textFile(String path,
int minPartitions)
Read a text file from HDFS, a local file system (available on all nodes), or any
Hadoop-supported file system URI, and return it as an RDD of Strings.
|
org.apache.spark.ui.SparkUI |
ui() |
<T> RDD<T> |
union(RDD<T> first,
scala.collection.Seq<RDD<T>> rest,
scala.reflect.ClassTag<T> evidence$7)
Build the union of a list of RDDs passed as variable-length arguments.
|
<T> RDD<T> |
union(scala.collection.Seq<RDD<T>> rdds,
scala.reflect.ClassTag<T> evidence$6)
Build the union of a list of RDDs.
|
String |
version()
The version of Spark on which this application is running.
|
RDD<scala.Tuple2<String,String>> |
wholeTextFiles(String path,
int minPartitions)
Read a directory of text files from HDFS, a local file system (available on all nodes), or any
Hadoop-supported file system URI.
|
static <T extends org.apache.hadoop.io.Writable> |
writableWritableConverter() |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
initialized, initializeIfNecessary, initializeLogging, initLock, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
public SparkContext(SparkConf config)
public SparkContext()
public SparkContext(SparkConf config, scala.collection.Map<String,scala.collection.Set<SplitInfo>> preferredNodeLocationData)
preferredNodeLocationData
- used in YARN mode to select nodes to launch containers on.
Can be generated using org.apache.spark.scheduler.InputFormatInfo.computePreferredLocations
from a list of input files or InputFormats for the application.public SparkContext(String master, String appName, SparkConf conf)
master
- Cluster URL to connect to (e.g. mesos://host:port, spark://host:port, local[4]).appName
- A name for your application, to display on the cluster web UIconf
- a SparkConf
object specifying other Spark parameterspublic SparkContext(String master, String appName, String sparkHome, scala.collection.Seq<String> jars, scala.collection.Map<String,String> environment, scala.collection.Map<String,scala.collection.Set<SplitInfo>> preferredNodeLocationData)
master
- Cluster URL to connect to (e.g. mesos://host:port, spark://host:port, local[4]).appName
- A name for your application, to display on the cluster web UI.sparkHome
- Location where Spark is installed on cluster nodes.jars
- Collection of JARs to send to the cluster. These can be paths on the local file
system or HDFS, HTTP, HTTPS, or FTP URLs.environment
- Environment variables to set on worker nodes.public static String SPARK_VERSION()
public static String SPARK_JOB_DESCRIPTION()
public static String SPARK_JOB_GROUP_ID()
public static String SPARK_JOB_INTERRUPT_ON_CANCEL()
public static String SPARK_UNKNOWN_USER()
public static <K,V> PairRDDFunctions<K,V> rddToPairRDDFunctions(RDD<scala.Tuple2<K,V>> rdd, scala.reflect.ClassTag<K> kt, scala.reflect.ClassTag<V> vt, scala.math.Ordering<K> ord)
public static <T> AsyncRDDActions<T> rddToAsyncRDDActions(RDD<T> rdd, scala.reflect.ClassTag<T> evidence$19)
public static <K,V> SequenceFileRDDFunctions<K,V> rddToSequenceFileRDDFunctions(RDD<scala.Tuple2<K,V>> rdd, scala.Function1<K,org.apache.hadoop.io.Writable> evidence$20, scala.reflect.ClassTag<K> evidence$21, scala.Function1<V,org.apache.hadoop.io.Writable> evidence$22, scala.reflect.ClassTag<V> evidence$23)
public static <K,V> OrderedRDDFunctions<K,V,scala.Tuple2<K,V>> rddToOrderedRDDFunctions(RDD<scala.Tuple2<K,V>> rdd, scala.math.Ordering<K> evidence$24, scala.reflect.ClassTag<K> evidence$25, scala.reflect.ClassTag<V> evidence$26)
public static DoubleRDDFunctions doubleRDDToDoubleRDDFunctions(RDD<Object> rdd)
public static <T> DoubleRDDFunctions numericRDDToDoubleRDDFunctions(RDD<T> rdd, scala.math.Numeric<T> num)
public static org.apache.hadoop.io.IntWritable intToIntWritable(int i)
public static org.apache.hadoop.io.LongWritable longToLongWritable(long l)
public static org.apache.hadoop.io.FloatWritable floatToFloatWritable(float f)
public static org.apache.hadoop.io.DoubleWritable doubleToDoubleWritable(double d)
public static org.apache.hadoop.io.BooleanWritable boolToBoolWritable(boolean b)
public static org.apache.hadoop.io.BytesWritable bytesToBytesWritable(byte[] aob)
public static org.apache.hadoop.io.Text stringToText(String s)
public static org.apache.spark.WritableConverter<Object> intWritableConverter()
public static org.apache.spark.WritableConverter<Object> longWritableConverter()
public static org.apache.spark.WritableConverter<Object> doubleWritableConverter()
public static org.apache.spark.WritableConverter<Object> floatWritableConverter()
public static org.apache.spark.WritableConverter<Object> booleanWritableConverter()
public static org.apache.spark.WritableConverter<byte[]> bytesWritableConverter()
public static org.apache.spark.WritableConverter<String> stringWritableConverter()
public static <T extends org.apache.hadoop.io.Writable> org.apache.spark.WritableConverter<T> writableWritableConverter()
public static scala.Option<String> jarOfClass(Class<?> cls)
public static scala.Option<String> jarOfObject(Object obj)
public scala.collection.Map<String,scala.collection.Set<SplitInfo>> preferredNodeLocationData()
public SparkConf conf()
public SparkConf getConf()
public scala.collection.Seq<String> jars()
public scala.collection.Seq<String> files()
public String master()
public String appName()
public String tachyonFolderName()
public boolean isLocal()
public org.apache.spark.scheduler.LiveListenerBus listenerBus()
public SparkEnv env()
public scala.collection.mutable.HashMap<String,Object> addedFiles()
public scala.collection.mutable.HashMap<String,Object> addedJars()
publicpersistentRdds()
public org.apache.spark.util.MetadataCleaner metadataCleaner()
public org.apache.spark.ui.SparkUI ui()
public org.apache.hadoop.conf.Configuration hadoopConfiguration()
public scala.Option<org.apache.spark.scheduler.EventLoggingListener> eventLogger()
public long startTime()
public int executorMemory()
public scala.collection.mutable.HashMap<String,String> executorEnvs()
public String sparkUser()
public org.apache.spark.scheduler.TaskScheduler taskScheduler()
public org.apache.spark.scheduler.DAGScheduler dagScheduler()
public scala.Option<org.apache.spark.ContextCleaner> cleaner()
public scala.Option<String> checkpointDir()
public void initLocalProperties()
public void setLocalProperty(String key, String value)
public String getLocalProperty(String key)
org.apache.spark.SparkContext.setLocalProperty
.public void setJobDescription(String value)
public void setJobGroup(String groupId, String description, boolean interruptOnCancel)
Often, a unit of execution in an application consists of multiple Spark actions or jobs. Application programmers can use this method to group all those jobs together and give a group description. Once set, the Spark web UI will associate such jobs with this group.
The application can also use org.apache.spark.SparkContext.cancelJobGroup
to cancel all
running jobs in this group. For example,
// In the main thread:
sc.setJobGroup("some_job_to_cancel", "some job description")
sc.parallelize(1 to 10000, 2).map { i => Thread.sleep(10); i }.count()
// In a separate thread:
sc.cancelJobGroup("some_job_to_cancel")
If interruptOnCancel is set to true for the job group, then job cancellation will result in Thread.interrupt() being called on the job's executor threads. This is useful to help ensure that the tasks are actually stopped in a timely manner, but is off by default due to HDFS-1208, where HDFS may respond to Thread.interrupt() by marking nodes as dead.
public void clearJobGroup()
public <T> RDD<T> parallelize(scala.collection.Seq<T> seq, int numSlices, scala.reflect.ClassTag<T> evidence$1)
public <T> RDD<T> makeRDD(scala.collection.Seq<T> seq, int numSlices, scala.reflect.ClassTag<T> evidence$2)
This method is identical to parallelize
.
public <T> RDD<T> makeRDD(scala.collection.Seq<scala.Tuple2<T,scala.collection.Seq<String>>> seq, scala.reflect.ClassTag<T> evidence$3)
public RDD<String> textFile(String path, int minPartitions)
public RDD<scala.Tuple2<String,String>> wholeTextFiles(String path, int minPartitions)
For example, if you have the following files:
hdfs://a-hdfs-path/part-00000
hdfs://a-hdfs-path/part-00001
...
hdfs://a-hdfs-path/part-nnnnn
Do val rdd = sparkContext.wholeTextFile("hdfs://a-hdfs-path")
,
then rdd
contains
(a-hdfs-path/part-00000, its content)
(a-hdfs-path/part-00001, its content)
...
(a-hdfs-path/part-nnnnn, its content)
minPartitions
- A suggestion value of the minimal splitting number for input data.public <K,V> RDD<scala.Tuple2<K,V>> hadoopRDD(org.apache.hadoop.mapred.JobConf conf, Class<? extends org.apache.hadoop.mapred.InputFormat<K,V>> inputFormatClass, Class<K> keyClass, Class<V> valueClass, int minPartitions)
org.apache.hadoop.mapred
).
conf
- JobConf for setting up the datasetinputFormatClass
- Class of the InputFormatkeyClass
- Class of the keysvalueClass
- Class of the valuesminPartitions
- Minimum number of Hadoop Splits to generate.
'''Note:''' Because Hadoop's RecordReader class re-uses the same Writable object for each
record, directly caching the returned RDD will create many references to the same object.
If you plan to directly cache Hadoop writable objects, you should first copy them using
a map
function.
public <K,V> RDD<scala.Tuple2<K,V>> hadoopFile(String path, Class<? extends org.apache.hadoop.mapred.InputFormat<K,V>> inputFormatClass, Class<K> keyClass, Class<V> valueClass, int minPartitions)
'''Note:''' Because Hadoop's RecordReader class re-uses the same Writable object for each
record, directly caching the returned RDD will create many references to the same object.
If you plan to directly cache Hadoop writable objects, you should first copy them using
a map
function.
public <K,V,F extends org.apache.hadoop.mapred.InputFormat<K,V>> RDD<scala.Tuple2<K,V>> hadoopFile(String path, int minPartitions, scala.reflect.ClassTag<K> km, scala.reflect.ClassTag<V> vm, scala.reflect.ClassTag<F> fm)
val file = sparkContext.hadoopFile[LongWritable, Text, TextInputFormat](path, minPartitions)
'''Note:''' Because Hadoop's RecordReader class re-uses the same Writable object for each
record, directly caching the returned RDD will create many references to the same object.
If you plan to directly cache Hadoop writable objects, you should first copy them using
a map
function.
public <K,V,F extends org.apache.hadoop.mapred.InputFormat<K,V>> RDD<scala.Tuple2<K,V>> hadoopFile(String path, scala.reflect.ClassTag<K> km, scala.reflect.ClassTag<V> vm, scala.reflect.ClassTag<F> fm)
val file = sparkContext.hadoopFile[LongWritable, Text, TextInputFormat](path)
'''Note:''' Because Hadoop's RecordReader class re-uses the same Writable object for each
record, directly caching the returned RDD will create many references to the same object.
If you plan to directly cache Hadoop writable objects, you should first copy them using
a map
function.
public <K,V,F extends org.apache.hadoop.mapreduce.InputFormat<K,V>> RDD<scala.Tuple2<K,V>> newAPIHadoopFile(String path, scala.reflect.ClassTag<K> km, scala.reflect.ClassTag<V> vm, scala.reflect.ClassTag<F> fm)
public <K,V,F extends org.apache.hadoop.mapreduce.InputFormat<K,V>> RDD<scala.Tuple2<K,V>> newAPIHadoopFile(String path, Class<F> fClass, Class<K> kClass, Class<V> vClass, org.apache.hadoop.conf.Configuration conf)
'''Note:''' Because Hadoop's RecordReader class re-uses the same Writable object for each
record, directly caching the returned RDD will create many references to the same object.
If you plan to directly cache Hadoop writable objects, you should first copy them using
a map
function.
public <K,V,F extends org.apache.hadoop.mapreduce.InputFormat<K,V>> RDD<scala.Tuple2<K,V>> newAPIHadoopRDD(org.apache.hadoop.conf.Configuration conf, Class<F> fClass, Class<K> kClass, Class<V> vClass)
'''Note:''' Because Hadoop's RecordReader class re-uses the same Writable object for each
record, directly caching the returned RDD will create many references to the same object.
If you plan to directly cache Hadoop writable objects, you should first copy them using
a map
function.
public <K,V> RDD<scala.Tuple2<K,V>> sequenceFile(String path, Class<K> keyClass, Class<V> valueClass, int minPartitions)
'''Note:''' Because Hadoop's RecordReader class re-uses the same Writable object for each
record, directly caching the returned RDD will create many references to the same object.
If you plan to directly cache Hadoop writable objects, you should first copy them using
a map
function.
public <K,V> RDD<scala.Tuple2<K,V>> sequenceFile(String path, Class<K> keyClass, Class<V> valueClass)
'''Note:''' Because Hadoop's RecordReader class re-uses the same Writable object for each
record, directly caching the returned RDD will create many references to the same object.
If you plan to directly cache Hadoop writable objects, you should first copy them using
a map
function.
public <K,V> RDD<scala.Tuple2<K,V>> sequenceFile(String path, int minPartitions, scala.reflect.ClassTag<K> km, scala.reflect.ClassTag<V> vm, scala.Function0<org.apache.spark.WritableConverter<K>> kcf, scala.Function0<org.apache.spark.WritableConverter<V>> vcf)
sparkContext.sequenceFile[String, Int](path, ...)
WritableConverters are provided in a somewhat strange way (by an implicit function) to support both subclasses of Writable and types for which we define a converter (e.g. Int to IntWritable). The most natural thing would've been to have implicit objects for the converters, but then we couldn't have an object for every subclass of Writable (you can't have a parameterized singleton object). We use functions instead to create a new converter for the appropriate type. In addition, we pass the converter a ClassTag of its type to allow it to figure out the Writable class to use in the subclass case.
'''Note:''' Because Hadoop's RecordReader class re-uses the same Writable object for each
record, directly caching the returned RDD will create many references to the same object.
If you plan to directly cache Hadoop writable objects, you should first copy them using
a map
function.
public <T> RDD<T> objectFile(String path, int minPartitions, scala.reflect.ClassTag<T> evidence$4)
public <T> RDD<T> union(scala.collection.Seq<RDD<T>> rdds, scala.reflect.ClassTag<T> evidence$6)
public <T> RDD<T> union(RDD<T> first, scala.collection.Seq<RDD<T>> rest, scala.reflect.ClassTag<T> evidence$7)
public <T>emptyRDD(scala.reflect.ClassTag<T> evidence$8)
public <T> Accumulator<T> accumulator(T initialValue, AccumulatorParam<T> param)
Accumulator
variable of a given type, which tasks can "add"
values to using the +=
method. Only the driver can access the accumulator's value
.public <T> Accumulator<T> accumulator(T initialValue, String name, AccumulatorParam<T> param)
Accumulator
variable of a given type, with a name for display
in the Spark UI. Tasks can "add" values to the accumulator using the +=
method. Only the
driver can access the accumulator's value
.public <T,R> Accumulable<T,R> accumulable(T initialValue, AccumulableParam<T,R> param)
Accumulable
shared variable, to which tasks can add values
with +=
. Only the driver can access the accumuable's value
.public <T,R> Accumulable<T,R> accumulable(T initialValue, String name, AccumulableParam<T,R> param)
Accumulable
shared variable, with a name for display in the
Spark UI. Tasks can add values to the accumuable using the +=
operator. Only the driver can
access the accumuable's value
.public <R,T> Accumulable<R,T> accumulableCollection(R initialValue, scala.Function1<R,scala.collection.generic.Growable<T>> evidence$9, scala.reflect.ClassTag<R> evidence$10)
Growable and TraversableOnce are the standard APIs that guarantee += and ++=, implemented by standard mutable collections. So you can use this with mutable Map, Set, etc.
public <T> Broadcast<T> broadcast(T value, scala.reflect.ClassTag<T> evidence$11)
Broadcast
object for reading it in distributed functions.
The variable will be sent to each cluster only once.public void addFile(String path)
path
passed can be either a local file, a file in HDFS (or other Hadoop-supported
filesystems), or an HTTP, HTTPS or FTP URI. To access the file in Spark jobs,
use SparkFiles.get(path)
to find its download location.public void addSparkListener(SparkListener listener)
public String version()
public scala.collection.Map<String,scala.Tuple2<Object,Object>> getExecutorMemoryStatus()
public RDDInfo[] getRDDStorageInfo()
public scala.collection.Map<Object,RDD<?>> getPersistentRDDs()
public StorageStatus[] getExecutorStorageStatus()
public scala.collection.Seq<org.apache.spark.scheduler.Schedulable> getAllPools()
public scala.Option<org.apache.spark.scheduler.Schedulable> getPoolForName(String pool)
public scala.Enumeration.Value getSchedulingMode()
public void clearFiles()
addFile
so that they do not get downloaded to
any new nodes.public void addJar(String path)
path
passed can be either a local file, a file in HDFS (or other Hadoop-supported
filesystems), an HTTP, HTTPS or FTP URI, or local:/path for a file on every worker node.public void clearJars()
addJar
so that they do not get downloaded to
any new nodes.public void stop()
public void setCallSite(String site)
public void clearCallSite()
public <T,U> void runJob(RDD<T> rdd, scala.Function2<TaskContext,scala.collection.Iterator<T>,U> func, scala.collection.Seq<Object> partitions, boolean allowLocal, scala.Function2<Object,U,scala.runtime.BoxedUnit> resultHandler, scala.reflect.ClassTag<U> evidence$12)
public <T,U> Object runJob(RDD<T> rdd, scala.Function2<TaskContext,scala.collection.Iterator<T>,U> func, scala.collection.Seq<Object> partitions, boolean allowLocal, scala.reflect.ClassTag<U> evidence$13)
public <T,U> Object runJob(RDD<T> rdd, scala.Function1<scala.collection.Iterator<T>,U> func, scala.collection.Seq<Object> partitions, boolean allowLocal, scala.reflect.ClassTag<U> evidence$14)
Iterator[T] => U
instead of (TaskContext, Iterator[T]) => U
.public <T,U> Object runJob(RDD<T> rdd, scala.Function2<TaskContext,scala.collection.Iterator<T>,U> func, scala.reflect.ClassTag<U> evidence$15)
public <T,U> Object runJob(RDD<T> rdd, scala.Function1<scala.collection.Iterator<T>,U> func, scala.reflect.ClassTag<U> evidence$16)
public <T,U> void runJob(RDD<T> rdd, scala.Function2<TaskContext,scala.collection.Iterator<T>,U> processPartition, scala.Function2<Object,U,scala.runtime.BoxedUnit> resultHandler, scala.reflect.ClassTag<U> evidence$17)
public <T,U> void runJob(RDD<T> rdd, scala.Function1<scala.collection.Iterator<T>,U> processPartition, scala.Function2<Object,U,scala.runtime.BoxedUnit> resultHandler, scala.reflect.ClassTag<U> evidence$18)
public <T,U,R> PartialResult<R> runApproximateJob(RDD<T> rdd, scala.Function2<TaskContext,scala.collection.Iterator<T>,U> func,evaluator, long timeout)
public <T,U,R> SimpleFutureAction<R> submitJob(RDD<T> rdd, scala.Function1<scala.collection.Iterator<T>,U> processPartition, scala.collection.Seq<Object> partitions, scala.Function2<Object,U,scala.runtime.BoxedUnit> resultHandler, scala.Function0<R> resultFunc)
public void cancelJobGroup(String groupId)
org.apache.spark.SparkContext.setJobGroup
for more information.public void cancelAllJobs()
public void setCheckpointDir(String directory)
public scala.Option<String> getCheckpointDir()
public int defaultParallelism()
public int defaultMinSplits()
public int defaultMinPartitions()