CacheCommand
execution
CanonicalRandomVertexCut
PartitionStrategy
CartesianProduct
execution
Categorical
FeatureType
ChiSqTestResult
test
Classification
Algo
ClassificationModel
classification
Client
deploy
ClientArguments
deploy
CoGroupedRDD
rdd
Combiner
bagel
Command
execution
ComplexFutureAction
spark
CompressionCodec
io
ComputedAggregate
Aggregate
Conf
SVDPlusPlus
ConnectedComponents
lib
ConstantInputDStream
dstream
Continuous
FeatureType
Converter
python
CoordinateMatrix
distributed
cache
JavaDoubleRDD JavaPairRDD JavaRDD EdgeRDD Graph VertexRDD GraphImpl RDD JavaSchemaRDD JavaDStream JavaPairDStream DStream
cacheManager
SparkEnv
cacheTable
SQLContext
cacheTables
TestHiveContext
calculate
Entropy Gini Impurity Variance
call
DoubleFlatMapFunction DoubleFunction FlatMapFunction FlatMapFunction2 Function Function2 Function3 PairFlatMapFunction PairFunction VoidFunction UDF1 UDF10 UDF11 UDF12 UDF13 UDF14 UDF15 UDF16 UDF17 UDF18 UDF19 UDF2 UDF20 UDF21 UDF22 UDF3 UDF4 UDF5 UDF6 UDF7 UDF8 UDF9
canEqual
Row MutablePair
cancel
ComplexFutureAction FutureAction SimpleFutureAction
cancelAllJobs
SparkContext JavaSparkContext
cancelJobGroup
SparkContext JavaSparkContext
cancelled
ComplexFutureAction
capacity
BitSet
cardinality
BitSet
cartesian
JavaRDDLike RDD
catalog
SQLContext HiveContext
categoricalFeaturesInfo
Strategy
categories
Split
category
BlockStats
changeValue
AppendOnlyMap
checkpoint
JavaRDDLike HadoopRDD RDD StreamingContext JavaDStreamLike JavaStreamingContext DStream
checkpointFile
SparkContext JavaSparkContext
chiSqTest
Statistics
child
Aggregate BatchPythonEvaluation DescribeCommand Distinct EvaluatePython Exchange Filter Generate GeneratedAggregate Limit OutputFaker Project Sample Sort TakeOrdered InsertIntoHiveTable ScriptTransformation InsertIntoParquetTable
children
BatchPythonEvaluation OutputFaker SparkLogicalPlan Union
className
ExceptionFailure
classTag
JavaDoubleRDD JavaPairRDD JavaRDD JavaRDDLike JavaSchemaRDD JavaDStream JavaDStreamLike JavaInputDStream JavaPairDStream JavaReceiverInputDStream
classification
mllib
classpathEntries
EnvironmentListener
clearCallSite
SparkContext JavaSparkContext
clearDependencies
CoGroupedRDD RDD ShuffledRDD UnionRDD
clearFiles
SparkContext JavaSparkContext
clearJars
SparkContext JavaSparkContext
clearJobGroup
SparkContext JavaSparkContext
clearThreshold
LogisticRegressionModel SVMModel
client
netty
clone
SparkConf StorageLevel BernoulliSampler PoissonSampler RandomSampler
cloneComplement
BernoulliSampler
close
ZooKeeperPersistenceEngine DeserializationStream SerializationStream
closeLogWriter
JobLogger
closureSerializer
SparkEnv
clusterCenters
KMeansModel
clustering
mllib
cmd
SqlCmd
coalesce
JavaDoubleRDD JavaPairRDD JavaRDD RDD SchemaRDD JavaSchemaRDD
codegenEnabled
SparkPlanner SparkPlan
cogroup
JavaPairRDD PairRDDFunctions JavaPairDStream PairDStreamFunctions
colStats
PythonMLLibAPI Statistics
collect
JavaRDDLike EdgeRDD RDD SchemaRDD JavaSchemaRDD
collectAsMap
JavaPairRDD PairRDDFunctions
collectAsync
AsyncRDDActions
collectEdges
GraphOps
collectNeighborIds
GraphOps
collectNeighbors
GraphOps
collectPartitions
JavaRDDLike
collection
util
columnPruningPred
ParquetTableScan
combineByKey
JavaPairRDD PairRDDFunctions JavaPairDStream PairDStreamFunctions
combineCombinersByKey
Aggregator
combineValuesByKey
Aggregator
commands
TestTable
compare
RDDInfo
completedStages
JobProgressListener
completionTime
StageInfo
compressedInputStream
CompressionCodec LZ4CompressionCodec LZFCompressionCodec SnappyCompressionCodec
compressedOutputStream
CompressionCodec LZ4CompressionCodec LZFCompressionCodec SnappyCompressionCodec
compute
EdgeRDD VertexRDD Gradient HingeGradient L1Updater LeastSquaresGradient LogisticGradient SimpleUpdater SquaredL2Updater Updater CoGroupedRDD HadoopRDD JdbcRDD NewHadoopRDD PartitionPruningRDD RDD ShuffledRDD UnionRDD SchemaRDD JavaDStream JavaPairDStream ConstantInputDStream DStream ReceiverInputDStream
computeColumnSummaryStatistics
RowMatrix
computeCost
KMeansModel
computeCovariance
RowMatrix
computeGramianMatrix
IndexedRowMatrix RowMatrix
computePreferredLocations
InputFormatInfo
computePrincipalComponents
RowMatrix
computeSVD
IndexedRowMatrix RowMatrix
condition
BroadcastNestedLoopJoin Filter HashOuterJoin LeftSemiJoinBNL
conditionEvaluator
Filter
conf
SparkEnv SparkHadoopUtil
confidence
BoundedDouble
configuration
tree InputFormatInfo
configure
LocalHiveContext TestHiveContext
confusionMatrix
MulticlassMetrics
connectedComponents
GraphOps
connectionManager
SparkEnv
contains
SparkConf
containsBlock
StorageStatus
context
InterruptibleIterator JavaRDDLike RDD HiveTableScan JavaDStreamLike DStream
convert
Converter
copy
DenseVector SparseVector Vector PoissonGenerator RandomDataGenerator StandardNormalGenerator UniformGenerator StatCounter
corr
PythonMLLibAPI Statistics
count
JavaRDDLike VertexRDD MultivariateStatisticalSummarySerialized BlockStats MultivariateOnlineSummarizer MultivariateStatisticalSummary RDD SchemaRDD JavaDStreamLike DStream StatCounter
countApprox
JavaRDDLike RDD
countApproxDistinct
JavaRDDLike RDD
countApproxDistinctByKey
JavaPairRDD PairRDDFunctions
countAsync
AsyncRDDActions
countByKey
JavaPairRDD PairRDDFunctions
countByKeyApprox
JavaPairRDD PairRDDFunctions
countByValue
JavaRDDLike RDD JavaDStreamLike DStream
countByValueAndWindow
JavaDStreamLike DStream
countByValueApprox
JavaRDDLike RDD
countByWindow
JavaDStreamLike DStream
create
PartitionPruningRDD Row JavaStreamingContextFactory
createAggregator
Aggregator
createCombiner
Aggregator Combiner DefaultCombiner
createLogDir
JobLogger
createLogWriter
JobLogger
createModel
LogisticRegressionWithLBFGS LogisticRegressionWithSGD SVMWithSGD GeneralizedLinearAlgorithm LassoWithSGD LinearRegressionWithSGD RidgeRegressionWithSGD
createParquetFile
SQLContext JavaSQLContext
createPollingStream
FlumeUtils
createSchemaRDD
SQLContext
createStream
FlumeUtils KafkaUtils KinesisUtils MQTTUtils TwitterUtils ZeroMQUtils
createTable
HiveContext
currentContext
SparkPlan