PairFlatMapFunction
function
PairFunction
function
PairRDDFunctions
rdd
parallelize
JavaSparkContext
SparkContext
parallelizeDoubles
JavaSparkContext
parallelizePairs
JavaSparkContext
parents
CoalescedRDDPartition
parentsIndices
CoalescedRDDPartition
parentSplit
PartitionPruningRDDPartition
partial
spark
PartialResult
partial
Partition
spark
partitionBy
JavaPairRDD
PairRDDFunctions
partitioner
spark
CoGroupedRDD
RDD
ShuffledRDD
ShuffleDependency
PartitionPruningRDD
rdd
PartitionPruningRDDPartition
rdd
partitions
PruneDependency
RDD
path
InputFormatInfo
SplitInfo
PathResolver
netty
percentiles
StatsReportListener
percentilesHeader
StatsReportListener
persist
JavaDoubleRDD
JavaPairRDD
JavaRDD
RDD
pipe
JavaRDDLike
RDD
PipedRDD
rdd
plusDot
Vector
pollDir
CsvSink
pollPeriod
ConsoleSink
CsvSink
GangliaSink
pollUnit
ConsoleSink
CsvSink
GangliaSink
port
GangliaSink
preferredLocation
CoalescedRDDPartition
preferredLocations
RDD
preferredNodeLocationData
SparkContext
preSetup
SparkHadoopWriter
prev
CoalescedRDD
ShuffledRDD
prioritizeContainers
ClusterScheduler
probabilities
StatsReportListener
productArity
Aggregator
CoalescedRDDPartition
RuntimePercentage
SparkListenerJobEnd
SparkListenerJobStart
SparkListenerStageSubmitted
SparkListenerTaskEnd
SparkListenerTaskStart
StageCompleted
StageInfo
RDDInfo
productElement
Aggregator
CoalescedRDDPartition
RuntimePercentage
SparkListenerJobEnd
SparkListenerJobStart
SparkListenerStageSubmitted
SparkListenerTaskEnd
SparkListenerTaskStart
StageCompleted
StageInfo
RDDInfo
productPrefix
Aggregator
CoalescedRDDPartition
RuntimePercentage
SparkListenerJobEnd
SparkListenerJobStart
SparkListenerStageSubmitted
SparkListenerTaskEnd
SparkListenerTaskStart
StageCompleted
StageInfo
RDDInfo
MutablePair
properties
SparkListenerJobStart
SparkListenerStageSubmitted
property
ConsoleSink
CsvSink
GangliaSink
JmxSink
MetricsServlet
propertyToOption
GangliaSink
PruneDependency
rdd
putIfAbsent
TimeStampedHashMap
python
api
PythonAccumulatorParam
python