RangeDependency
spark
RangePartitioner
spark
RateLimitedOutputStream
util
rdd
JavaDoubleRDD JavaPairRDD JavaRDD JavaRDDLike Dependency spark CoalescedRDDPartition rdd
rdd1
ZippedPartitionsRDD2 ZippedPartitionsRDD3 ZippedPartitionsRDD4 ZippedRDD
rdd2
ZippedPartitionsRDD2 ZippedPartitionsRDD3 ZippedPartitionsRDD4 ZippedRDD
rdd3
ZippedPartitionsRDD3 ZippedPartitionsRDD4
rdd4
ZippedPartitionsRDD4
RDDInfo
storage
rdds
CoGroupedRDD UnionRDD ZippedPartitionsBaseRDD
rddToOrderedRDDFunctions
SparkContext
rddToPairRDDFunctions
SparkContext
rddToSequenceFileRDDFunctions
SparkContext
readExternal
StorageLevel
readObject
DeserializationStream
readResolve
SparkHadoopWriter VoidFunction JavaDoubleRDD JavaPairRDD JavaRDD TaskMetrics Partitioner JdbcRDD PartitionPruningRDD PipedRDD RuntimePercentage DoubleAccumulatorParam FloatAccumulatorParam IntAccumulatorParam LongAccumulatorParam StorageLevel StatCounter Vector VectorAccumParam
reason
SparkListenerTaskEnd
receive
BlockManagerSlaveActor
recordJobProperties
JobLogger
recordRddInStageGraph
JobLogger
recordStageDep
JobLogger
recordStageDepGraph
JobLogger
recordTaskMetrics
JobLogger
reduce
JavaRDDLike RDD
reduceByKey
JavaPairRDD PairRDDFunctions
reduceByKeyLocally
JavaPairRDD PairRDDFunctions
reduceByKeyToDriver
PairRDDFunctions
registerClasses
KryoRegistrator
registerCloseEventHandler
BlockObjectWriter
registry
ConsoleSink CsvSink GangliaSink JmxSink MetricsServlet
remoteBlocksFetched
ShuffleReadMetrics
remoteBytesRead
ShuffleReadMetrics
remoteFetchTime
ShuffleReadMetrics
replication
StorageLevel
reporter
ConsoleSink CsvSink GangliaSink JmxSink
resultSetToObjectArray
JdbcRDD
resultSize
TaskMetrics
returnType
Function Function2
revertPartialWrites
BlockObjectWriter
rightOuterJoin
JavaPairRDD PairRDDFunctions
runApproximateJob
SparkContext
runJob
SparkContext
runningLocally
TaskContext
RuntimePercentage
scheduler