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
partitionId
TaskContext
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
prev
CoalescedRDD ShuffledRDD
prioritizeContainers
ClusterScheduler
probabilities
StatsReportListener
productArity
Aggregator CoalescedRDDPartition RuntimePercentage SparkListenerJobEnd SparkListenerJobStart SparkListenerStageSubmitted SparkListenerTaskEnd SparkListenerTaskGettingResult SparkListenerTaskStart StageCompleted RDDInfo
productElement
Aggregator CoalescedRDDPartition RuntimePercentage SparkListenerJobEnd SparkListenerJobStart SparkListenerStageSubmitted SparkListenerTaskEnd SparkListenerTaskGettingResult SparkListenerTaskStart StageCompleted RDDInfo
productPrefix
Aggregator CoalescedRDDPartition RuntimePercentage SparkListenerJobEnd SparkListenerJobStart SparkListenerStageSubmitted SparkListenerTaskEnd SparkListenerTaskGettingResult SparkListenerTaskStart StageCompleted RDDInfo MutablePair
properties
SparkListenerJobStart SparkListenerStageSubmitted
property
ConsoleSink CsvSink GangliaSink JmxSink MetricsServlet
propertyToOption
GangliaSink
PruneDependency
rdd
putIfAbsent
TimeStampedHashMap