cache
JavaDoubleRDD JavaPairRDD JavaRDD RDD
cacheManager
SparkEnv
call
Function3 Function4 VoidFunction
cancel
ComplexFutureAction FutureAction SimpleFutureAction MetadataCleaner
cancelAllJobs
SparkContext
cancelJobGroup
SparkContext
cancelled
ComplexFutureAction
canEqual
Aggregator CoalescedRDDPartition RuntimePercentage SparkListenerJobEnd SparkListenerJobStart SparkListenerStageSubmitted SparkListenerTaskEnd SparkListenerTaskGettingResult SparkListenerTaskStart StageCompleted RDDInfo MutablePair
cardinality
BitSet
cartesian
JavaRDDLike RDD
checkpoint
JavaRDDLike HadoopRDD RDD
checkpointFile
JavaSparkContext SparkContext
CHUNK_SIZE
RateLimitedOutputStream
classManifest
JavaDoubleRDD JavaPairRDD JavaRDD JavaRDDLike
clear
BoundedPriorityQueue
clearDependencies
CoalescedRDD CoGroupedRDD RDD ShuffledRDD ZippedPartitionsBaseRDD ZippedPartitionsRDD2 ZippedPartitionsRDD3 ZippedPartitionsRDD4 ZippedRDD
clearFiles
JavaSparkContext SparkContext
clearJars
JavaSparkContext SparkContext
clearJobGroup
SparkContext
clearOldValues
TimeStampedHashMap TimeStampedHashSet
clone
StorageLevel
close
ZooKeeperPersistenceEngine DeserializationStream SerializationStream BlockObjectWriter DiskBlockObjectWriter RateLimitedOutputStream
closeLogWriter
JobLogger
closureSerializer
SparkEnv
cluster
scheduler
ClusterScheduler
cluster
coalesce
JavaDoubleRDD JavaPairRDD JavaRDD RDD
CoalescedRDD
rdd
CoalescedRDDPartition
rdd
cogroup
JavaPairRDD PairRDDFunctions
CoGroupedRDD
rdd
cogroupResult2ToJava
JavaPairRDD
cogroupResultToJava
JavaPairRDD
collect
JavaRDDLike RDD
collectAsMap
JavaPairRDD PairRDDFunctions
collectAsync
AsyncRDDActions
collection
util
combineByKey
JavaPairRDD PairRDDFunctions
combineCombinersByKey
Aggregator
combineValuesByKey
Aggregator
commit
BlockObjectWriter DiskBlockObjectWriter
compare
RDDInfo
completion
CompletionIterator
CompletionIterator
util
completionTime
StageInfo
ComplexFutureAction
spark
compressedInputStream
CompressionCodec LZFCompressionCodec SnappyCompressionCodec
compressedOutputStream
CompressionCodec LZFCompressionCodec SnappyCompressionCodec
CompressionCodec
io
compute
CoalescedRDD CoGroupedRDD EmptyRDD HadoopRDD JdbcRDD NewHadoopRDD PartitionPruningRDD PipedRDD RDD SampledRDD ShuffledRDD UnionRDD ZippedPartitionsRDD2 ZippedPartitionsRDD3 ZippedPartitionsRDD4 ZippedRDD
computePreferredLocations
InputFormatInfo
confidence
BoundedDouble
configuration
InputFormatInfo
connectionManager
SparkEnv
CONSOLE_DEFAULT_PERIOD
ConsoleSink
CONSOLE_DEFAULT_UNIT
ConsoleSink
CONSOLE_KEY_PERIOD
ConsoleSink
CONSOLE_KEY_UNIT
ConsoleSink
ConsoleSink
sink
contains
TimeStampedHashSet
context
JavaRDDLike InterruptibleIterator RDD
copy
StatCounter
count
JavaRDDLike RDD StatCounter
countApprox
JavaRDDLike RDD
countAsync
AsyncRDDActions
countByKey
JavaPairRDD PairRDDFunctions
countByKeyApprox
JavaPairRDD PairRDDFunctions
countByValue
JavaRDDLike RDD
countByValueApprox
JavaRDDLike RDD
create
StorageLevels PartitionPruningRDD
createCombiner
Aggregator
createFromSystemProperties
SparkEnv
createLogDir
JobLogger
createLogWriter
JobLogger
createPythonWorker
SparkEnv
CSV_DEFAULT_DIR
CsvSink
CSV_DEFAULT_PERIOD
CsvSink
CSV_DEFAULT_UNIT
CsvSink
CSV_KEY_DIR
CsvSink
CSV_KEY_PERIOD
CsvSink
CSV_KEY_UNIT
CsvSink
CsvSink
sink