RACK_LOCAL
TaskLocality
RANDOM
KMeans
RDD
rdd BlockId
RDDBlockId
storage
RDDConversions
execution
RDDFunctions
rdd
RDDInfo
storage
RETRY_WAIT_MILLIS
SparkCuratorUtil
RMATa
GraphGenerators
RMATb
GraphGenerators
RMATc
GraphGenerators
RMATd
GraphGenerators
RandomDataGenerator
random
RandomForest
tree
RandomForestModel
model
RandomRDDs
random
RandomSampler
random
RandomVertexCut
PartitionStrategy
RangeDependency
spark
RangePartitioner
spark
RankingMetrics
evaluation
Rating
recommendation
Receiver
receiver
ReceiverInfo
scheduler
ReceiverInputDStream
dstream
RegisterExecutor
protocol
Regression
Algo
RegressionMetrics
evaluation
RegressionModel
regression
RelationProvider
sources
RequestMessage
protocol
ResponseMessage
protocol
Resubmitted
spark
RetryingBlockFetcher
shuffle
RidgeRegressionModel
regression
RidgeRegressionWithSGD
regression
Row
sql java
RowMatrix
distributed
RpcFailure
protocol
RpcHandler
server
RpcRequest
protocol
RpcResponse
protocol
RpcResponseCallback
client
RunnableCommand
execution
r2
RegressionMetrics
rand
Matrices
randn
Matrices
random
mllib Vector util
randomRDD
RandomRDDs
randomSplit
JavaRDD RDD
randomVectorRDD
RandomRDDs
rank
Conf MatrixFactorizationModel
rating
Rating
rawSocketStream
StreamingContext JavaStreamingContext
rdd
Dependency NarrowDependency ShuffleDependency JavaDoubleRDD JavaPairRDD JavaRDD JavaRDDLike mllib spark JavaSchemaRDD ExistingRdd LogicalRDD PhysicalRDD
rddBlocks
StorageStatus
rddBlocksById
StorageStatus
rddId
SparkListenerUnpersistRDD RDDBlockId
rddInfoList
StorageListener
rddInfos
StageInfo
rddStorageLevel
StorageStatus
rddToAsyncRDDActions
SparkContext
rddToOrderedRDDFunctions
SparkContext
rddToPairRDDFunctions
SparkContext
rddToSequenceFileRDDFunctions
SparkContext
rdds
CoGroupedRDD UnionRDD
read
LimitedInputStream
readExternal
JavaSerializer HiveFunctionWrapper BlockManagerId StorageLevel SparkFlumeEvent
readFields
TestWritable
readMethod
InputMetrics
readObject
DeserializationStream
readPersistedData
ZooKeeperPersistenceEngine
ready
ComplexFutureAction FutureAction SimpleFutureAction
reason
SparkListenerTaskEnd
recall
MulticlassMetrics MultilabelMetrics
recallByThreshold
BinaryClassificationMetrics
receive
NettyBlockRpcServer SaslRpcHandler NoOpRpcHandler RpcHandler ExternalShuffleBlockHandler
receiveBuf
TransportConf
receivedBlockInfo
BatchInfo
receiver
streaming
receiverInfo
StreamingListenerReceiverError StreamingListenerReceiverStarted StreamingListenerReceiverStopped
receiverInputDStream
JavaPairReceiverInputDStream JavaReceiverInputDStream
receiverStream
StreamingContext JavaStreamingContext
recommendProducts
MatrixFactorizationModel
recommendUsers
MatrixFactorizationModel
recommendation
mllib
recordJobProperties
JobLogger
recordTaskMetrics
JobLogger
reduce
JavaRDDLike RDD JavaDStreamLike DStream
reduceByKey
JavaPairRDD PairRDDFunctions JavaPairDStream PairDStreamFunctions
reduceByKeyAndWindow
JavaPairDStream PairDStreamFunctions
reduceByKeyLocally
JavaPairRDD PairRDDFunctions
reduceByKeyToDriver
PairRDDFunctions
reduceByWindow
JavaDStreamLike DStream
reduceId
FetchFailed ShuffleBlockId ShuffleDataBlockId ShuffleIndexBlockId
registerApp
ShuffleSecretManager
registerClasses
GraphKryoRegistrator KryoRegistrator
registerExecutor
ExternalShuffleBlockManager
registerKryoClasses
SparkConf GraphXUtils
registerRDDAsTable
SQLContext JavaSQLContext
registerStream
OneForOneStreamManager
registerTestTable
TestHiveContext
registerWithShuffleServer
ExternalShuffleClient
regression
mllib
reindex
VertexRDD VertexRDDImpl
relation
HiveTableScan InsertIntoParquetTable ParquetTableScan
relativeDirection
Edge
release
FileSegmentManagedBuffer ManagedBuffer NettyManagedBuffer NioManagedBuffer
remember
StreamingContext JavaStreamingContext
remoteBlocksFetched
ShuffleReadMetrics
remoteBytesRead
ShuffleReadMetrics
remove
SparkConf
removeApplication
ZooKeeperPersistenceEngine
removeDriver
ZooKeeperPersistenceEngine
removeFetchRequest
TransportResponseHandler
removeRpcRequest
TransportResponseHandler
removeWorker
ZooKeeperPersistenceEngine
repartition
JavaDoubleRDD JavaPairRDD JavaRDD RDD SchemaRDD JavaSchemaRDD JavaDStream JavaPairDStream DStream
repartitionAndSortWithinPartitions
JavaPairRDD OrderedRDDFunctions
replicatedVertexView
GraphImpl
replication
StorageLevel
reportError
Receiver
requestExecutors
SparkContext
requestedAttributes
HiveTableScan
requiredChildDistribution
Aggregate Distinct ExternalSort GeneratedAggregate Sort SparkPlan BroadcastHashJoin HashOuterJoin LeftSemiJoinHash ShuffledHashJoin
reset
LimitedInputStream TestHiveContext
response
SparkSaslClient SparkSaslServer
restart
Receiver
result
ComplexFutureAction FutureAction SimpleFutureAction AggregateEvaluation
resultAttribute
ComputedAggregate EvaluatePython
resultSerializationTime
TaskMetrics
resultSetToObjectArray
JdbcRDD
resultSize
TaskMetrics
retain
FileSegmentManagedBuffer ManagedBuffer NettyManagedBuffer NioManagedBuffer
retainedJobs
JobProgressListener
retainedStages
JobProgressListener
reverse
EdgeDirection EdgeRDD Graph EdgeRDDImpl GraphImpl
reverseRoutingTables
VertexRDD VertexRDDImpl
right
Except Intersect BroadcastHashJoin BroadcastNestedLoopJoin CartesianProduct HashJoin HashOuterJoin LeftSemiJoinBNL LeftSemiJoinHash ShuffledHashJoin
rightImpurity
InformationGainStats
rightKeys
BroadcastHashJoin HashJoin HashOuterJoin LeftSemiJoinHash ShuffledHashJoin
rightNode
Node
rightOuterJoin
JavaPairRDD PairRDDFunctions JavaPairDStream PairDStreamFunctions
rightPredict
InformationGainStats
rmatGraph
GraphGenerators
roc
BinaryClassificationMetrics
rootMeanSquaredError
RegressionMetrics
rowIndices
SparseMatrix
rowToArray
EvaluatePython
rows
IndexedRowMatrix RowMatrix
run
ComplexFutureAction Bagel ConnectedComponents LabelPropagation PageRank SVDPlusPlus ShortestPaths StronglyConnectedComponents TriangleCount NaiveBayes KMeans ALS GeneralizedLinearAlgorithm DecisionTree GradientBoostedTrees RunnableCommand
runApproximateJob
SparkContext
runAsSparkUser
SparkHadoopUtil
runHive
HiveContext
runJob
ComplexFutureAction SparkContext
runLBFGS
LBFGS
runMiniBatchSGD
GradientDescent
runSqlHive
HiveContext TestHiveContext
runUntilConvergence
PageRank
running
TaskInfo
runningLocally
TaskContext