[frames] | no frames]

Identifier Index

[ A B C D E F G H I J K L M N O P Q R S T U V W X Y Z _ ]

A

Accumulator (in pyspark.accumulators)	add() (in Accumulator)	addInPlace() (in AddingAccumulatorParam)
accumulator() (in SparkContext)	addFile() (in SparkContext)	addPyFile() (in SparkContext)
AccumulatorParam (in pyspark.accumulators)	AddingAccumulatorParam (in pyspark.accumulators)
accumulators (in pyspark)	addInPlace() (in AccumulatorParam)

B

broadcast (in pyspark)	Broadcast (in pyspark.broadcast)	broadcast() (in SparkContext)

C

cache() (in RDD)	collectAsMap() (in RDD)	count() (in RDD)
cartesian() (in RDD)	combineByKey() (in RDD)	count() (in StatCounter)
checkpoint() (in RDD)	COMPLEX_ACCUMULATOR_PARAM (in pyspark.accumulators)	countByKey() (in RDD)
clearFiles() (in SparkContext)	context (in pyspark)	countByValue() (in RDD)
cogroup() (in RDD)	context() (in RDD)
collect() (in RDD)	copy() (in StatCounter)

D

defaultParallelism() (in SparkContext)	DISK_ONLY_2 (in StorageLevel)
DISK_ONLY (in StorageLevel)	distinct() (in RDD)

F

files (in pyspark)	flatMap() (in RDD)	fold() (in RDD)
filter() (in RDD)	flatMapValues() (in RDD)	foreach() (in RDD)
first() (in RDD)	FLOAT_ACCUMULATOR_PARAM (in pyspark.accumulators)

G

get() (in SparkFiles)	glom() (in RDD)	groupWith() (in RDD)
getCheckpointFile() (in RDD)	groupBy() (in RDD)
getRootDirectory() (in SparkFiles)	groupByKey() (in RDD)

I

INT_ACCUMULATOR_PARAM (in pyspark.accumulators)	isCheckpointed() (in RDD)

J

join() (in RDD)

K

keyBy() (in RDD)

L

leftOuterJoin() (in RDD)

M

map() (in RDD)	MEMORY_AND_DISK (in StorageLevel)	MEMORY_ONLY_SER (in StorageLevel)
mapPartitions() (in RDD)	MEMORY_AND_DISK_2 (in StorageLevel)	MEMORY_ONLY_SER_2 (in StorageLevel)
mapPartitionsWithSplit() (in RDD)	MEMORY_AND_DISK_SER (in StorageLevel)	merge() (in StatCounter)
mapValues() (in RDD)	MEMORY_AND_DISK_SER_2 (in StorageLevel)	mergeStats() (in StatCounter)
mean() (in RDD)	MEMORY_ONLY (in StorageLevel)
mean() (in StatCounter)	MEMORY_ONLY_2 (in StorageLevel)

P

parallelize() (in SparkContext)	persist() (in RDD)	pyspark
partitionBy() (in RDD)	pipe() (in RDD)

R

rdd (in pyspark)	reduce() (in RDD)	reduceByKeyLocally() (in RDD)
RDD (in pyspark.rdd)	reduceByKey() (in RDD)	rightOuterJoin() (in RDD)

S

sample() (in RDD)	sortByKey() (in RDD)	stop() (in SparkContext)
sampleStdev() (in RDD)	SparkContext (in pyspark.context)	storagelevel (in pyspark)
sampleStdev() (in StatCounter)	SparkFiles (in pyspark.files)	StorageLevel (in pyspark.storagelevel)
sampleVariance() (in RDD)	statcounter (in pyspark)	subtract() (in RDD)
sampleVariance() (in StatCounter)	StatCounter (in pyspark.statcounter)	subtractByKey() (in RDD)
saveAsTextFile() (in RDD)	stats() (in RDD)	sum() (in RDD)
setCheckpointDir() (in SparkContext)	stdev() (in RDD)	sum() (in StatCounter)
setSystemProperty() (in SparkContext)	stdev() (in StatCounter)

T

take() (in RDD)	takeSample() (in RDD)	textFile() (in SparkContext)

U

union() (in SparkContext)	union() (in RDD)	unpersist() (in RDD)

V

value() (in Accumulator)	variance() (in RDD)	variance() (in StatCounter)

Z

zero() (in AccumulatorParam)	zero() (in AddingAccumulatorParam)

_

__add__() (in RDD)	__init__() (in StorageLevel)	_is_running_on_worker (in SparkFiles)
__del__() (in SparkContext)	__reduce__() (in Accumulator)	_jvm (in SparkContext)
__iadd__() (in Accumulator)	__reduce__() (in Broadcast)	_lock (in SparkContext)
__init__() (in Accumulator)	__repr__() (in Accumulator)	_next_accum_id (in SparkContext)
__init__() (in AddingAccumulatorParam)	__repr__() (in StatCounter)	_python_includes (in SparkContext)
__init__() (in Broadcast)	__str__() (in Accumulator)	_root_directory (in SparkFiles)
__init__() (in SparkContext)	_accumulatorRegistry (in pyspark.accumulators)	_sc (in SparkFiles)
__init__() (in SparkFiles)	_active_spark_context (in SparkContext)	_takePartition (in SparkContext)
__init__() (in RDD)	_broadcastRegistry (in pyspark.broadcast)	_writeIteratorToPickleFile (in SparkContext)
__init__() (in StatCounter)	_gateway (in SparkContext)