JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
Hierarchy For All Packages
Package Hierarchies:
org.apache.spark
,
org.apache.spark.api.java
,
org.apache.spark.api.java.function
,
org.apache.spark.api.r
,
org.apache.spark.broadcast
,
org.apache.spark.graphx
,
org.apache.spark.graphx.impl
,
org.apache.spark.graphx.lib
,
org.apache.spark.graphx.util
,
org.apache.spark.input
,
org.apache.spark.internal
,
org.apache.spark.internal.config
,
org.apache.spark.internal.io
,
org.apache.spark.io
,
org.apache.spark.launcher
,
org.apache.spark.mapred
,
org.apache.spark.metrics.source
,
org.apache.spark.ml
,
org.apache.spark.ml.ann
,
org.apache.spark.ml.attribute
,
org.apache.spark.ml.classification
,
org.apache.spark.ml.clustering
,
org.apache.spark.ml.evaluation
,
org.apache.spark.ml.feature
,
org.apache.spark.ml.fpm
,
org.apache.spark.ml.impl
,
org.apache.spark.ml.linalg
,
org.apache.spark.ml.param
,
org.apache.spark.ml.param.shared
,
org.apache.spark.ml.r
,
org.apache.spark.ml.recommendation
,
org.apache.spark.ml.regression
,
org.apache.spark.ml.source.libsvm
,
org.apache.spark.ml.stat
,
org.apache.spark.ml.stat.distribution
,
org.apache.spark.ml.tree
,
org.apache.spark.ml.tree.impl
,
org.apache.spark.ml.tuning
,
org.apache.spark.ml.util
,
org.apache.spark.mllib
,
org.apache.spark.mllib.classification
,
org.apache.spark.mllib.classification.impl
,
org.apache.spark.mllib.clustering
,
org.apache.spark.mllib.evaluation
,
org.apache.spark.mllib.evaluation.binary
,
org.apache.spark.mllib.feature
,
org.apache.spark.mllib.fpm
,
org.apache.spark.mllib.linalg
,
org.apache.spark.mllib.linalg.distributed
,
org.apache.spark.mllib.optimization
,
org.apache.spark.mllib.pmml
,
org.apache.spark.mllib.pmml.export
,
org.apache.spark.mllib.random
,
org.apache.spark.mllib.rdd
,
org.apache.spark.mllib.recommendation
,
org.apache.spark.mllib.regression
,
org.apache.spark.mllib.regression.impl
,
org.apache.spark.mllib.stat
,
org.apache.spark.mllib.stat.correlation
,
org.apache.spark.mllib.stat.distribution
,
org.apache.spark.mllib.stat.test
,
org.apache.spark.mllib.tree
,
org.apache.spark.mllib.tree.configuration
,
org.apache.spark.mllib.tree.impurity
,
org.apache.spark.mllib.tree.loss
,
org.apache.spark.mllib.tree.model
,
org.apache.spark.mllib.util
,
org.apache.spark.partial
,
org.apache.spark.rdd
,
org.apache.spark.rpc.netty
,
org.apache.spark.scheduler
,
org.apache.spark.scheduler.cluster
,
org.apache.spark.scheduler.local
,
org.apache.spark.security
,
org.apache.spark.serializer
,
org.apache.spark.sql
,
org.apache.spark.sql.api.java
,
org.apache.spark.sql.api.r
,
org.apache.spark.sql.catalog
,
org.apache.spark.sql.expressions
,
org.apache.spark.sql.expressions.javalang
,
org.apache.spark.sql.expressions.scalalang
,
org.apache.spark.sql.hive
,
org.apache.spark.sql.hive.execution
,
org.apache.spark.sql.hive.orc
,
org.apache.spark.sql.jdbc
,
org.apache.spark.sql.sources
,
org.apache.spark.sql.streaming
,
org.apache.spark.sql.types
,
org.apache.spark.sql.util
,
org.apache.spark.status.api.v1
,
org.apache.spark.status.api.v1.streaming
,
org.apache.spark.storage
,
org.apache.spark.storage.memory
,
org.apache.spark.streaming
,
org.apache.spark.streaming.api.java
,
org.apache.spark.streaming.dstream
,
org.apache.spark.streaming.flume
,
org.apache.spark.streaming.kafka
,
org.apache.spark.streaming.kinesis
,
org.apache.spark.streaming.receiver
,
org.apache.spark.streaming.scheduler
,
org.apache.spark.streaming.ui
,
org.apache.spark.streaming.util
,
org.apache.spark.ui
,
org.apache.spark.ui.env
,
org.apache.spark.ui.exec
,
org.apache.spark.ui.jobs
,
org.apache.spark.ui.storage
,
org.apache.spark.util
,
org.apache.spark.util.random
,
org.apache.spark.util.sketch
Class Hierarchy
Object
<any>
org.apache.spark.mllib.linalg.
VectorUDT
org.apache.spark.mllib.tree.loss.
AbsoluteError
scala.runtime.AbstractFunction1<T1,R> (implements scala.Function1<T1,R>)
org.apache.spark.storage.
BlockManagerMessages.BlockManagerHeartbeat$
(implements scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.GetExecutorEndpointRef$
(implements scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.GetLocations$
(implements scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.GetLocationsMultipleBlockIds$
(implements scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.GetPeers$
(implements scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.HasCachedBlocks$
(implements scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.RemoveBlock$
(implements scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.RemoveExecutor$
(implements scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.RemoveRdd$
(implements scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.RemoveShuffle$
(implements scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.GetExecutorLossReason$
(implements scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.KillExecutors$
(implements scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.KillExecutorsOnHost$
(implements scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.LaunchTask$
(implements scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.RegisterClusterManager$
(implements scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.RegisterExecutorFailed$
(implements scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.SetupDriver$
(implements scala.Serializable)
scala.runtime.AbstractFunction2<T1,T2,R> (implements scala.Function2<T1,T2,R>)
org.apache.spark.storage.
BlockManagerMessages.GetBlockStatus$
(implements scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.GetMatchingBlockIds$
(implements scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.RemoveBroadcast$
(implements scala.Serializable)
org.apache.spark.mllib.stat.test.
ChiSqTest.Method$
(implements scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.RemoveExecutor$
(implements scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.SparkAppConfig$
(implements scala.Serializable)
org.apache.spark.sql.hive.
HiveShim.HiveFunctionWrapper$
(implements scala.Serializable)
org.apache.spark.mllib.clustering.
PowerIterationClustering.Assignment$
(implements scala.Serializable)
org.apache.spark.sql.
RelationalGroupedDataset.PivotType$
(implements scala.Serializable)
scala.runtime.AbstractFunction3<T1,T2,T3,R> (implements scala.Function3<T1,T2,T3,R>)
org.apache.spark.storage.
BlockManagerMessages.ReplicateBlock$
(implements scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.AddWebUIFilter$
(implements scala.Serializable)
org.apache.spark.streaming.kafka.
KafkaCluster.LeaderOffset$
(implements scala.Serializable)
scala.runtime.AbstractFunction4<T1,T2,T3,T4,R> (implements scala.Function4<T1,T2,T3,T4,R>)
org.apache.spark.storage.
BlockManagerMessages.RegisterBlockManager$
(implements scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.KillTask$
(implements scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.RequestExecutors$
(implements scala.Serializable)
scala.runtime.AbstractFunction5<T1,T2,T3,T4,T5,R> (implements scala.Function5<T1,T2,T3,T4,T5,R>)
org.apache.spark.storage.
BlockManagerMessages.UpdateBlockInfo$
(implements scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.RegisterExecutor$
(implements scala.Serializable)
java.util.AbstractMap<K,V> (implements java.util.Map<K,V>)
org.apache.spark.api.java.
JavaUtils.SerializableMapWrapper
<A,B> (implements java.io.Serializable)
io.netty.util.AbstractReferenceCounted (implements io.netty.util.ReferenceCounted)
org.apache.spark.storage.
ReadableChannelFileRegion
(implements io.netty.channel.FileRegion)
org.apache.spark.
Accumulable
<R,T> (implements java.io.Serializable)
org.apache.spark.
Accumulator
<T>
org.apache.spark.scheduler.
AccumulableInfo
(implements scala.Product, scala.Serializable)
org.apache.spark.status.api.v1.
AccumulableInfo
org.apache.spark.util.
AccumulatorContext
org.apache.spark.
AccumulatorParam.DoubleAccumulatorParam$
(implements org.apache.spark.
AccumulatorParam
<T>)
org.apache.spark.
AccumulatorParam.FloatAccumulatorParam$
(implements org.apache.spark.
AccumulatorParam
<T>)
org.apache.spark.
AccumulatorParam.IntAccumulatorParam$
(implements org.apache.spark.
AccumulatorParam
<T>)
org.apache.spark.
AccumulatorParam.LongAccumulatorParam$
(implements org.apache.spark.
AccumulatorParam
<T>)
org.apache.spark.
AccumulatorParam.StringAccumulatorParam$
(implements org.apache.spark.
AccumulatorParam
<T>)
org.apache.spark.util.
AccumulatorV2
<IN,OUT> (implements scala.Serializable)
org.apache.spark.util.
CollectionAccumulator
<T>
org.apache.spark.util.
DoubleAccumulator
org.apache.spark.util.
LegacyAccumulatorWrapper
<R,T>
org.apache.spark.util.
LongAccumulator
org.apache.spark.ml.regression.
AFTAggregator
(implements scala.Serializable)
org.apache.spark.ml.regression.
AFTCostFun
(implements breeze.optimize.DiffFunction<T>)
org.apache.spark.
Aggregator
<K,V,C> (implements scala.Product, scala.Serializable)
org.apache.spark.sql.expressions.
Aggregator
<IN,BUF,OUT> (implements scala.Serializable)
org.apache.spark.mllib.tree.configuration.
Algo
org.apache.spark.scheduler.
AllJobsCancelled
org.apache.spark.streaming.scheduler.
AllReceiverIds
org.apache.spark.mllib.recommendation.
ALS
(implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.ml.recommendation.
ALS.InBlock$
(implements scala.Serializable)
org.apache.spark.ml.recommendation.
ALS.Rating
<ID> (implements scala.Product, scala.Serializable)
org.apache.spark.ml.recommendation.
ALS.Rating$
(implements scala.Serializable)
org.apache.spark.ml.recommendation.
ALS.RatingBlock$
(implements scala.Serializable)
org.apache.spark.sql.types.
AnyDataType
scala.AnyVal
org.apache.spark.serializer.
SerializationDebugger.ObjectStreamClassMethods
org.apache.spark.status.api.v1.
ApplicationAttemptInfo
org.apache.spark.status.api.v1.
ApplicationEnvironmentInfo
org.apache.spark.status.api.v1.
ApplicationInfo
org.apache.spark.status.api.v1.
ApplicationsListResource
org.apache.spark.ml.ann.
ApplyInPlace
org.apache.spark.mllib.evaluation.
AreaUnderCurve
org.apache.spark.scheduler.
AskPermissionToCommitOutput
(implements scala.Product, scala.Serializable)
org.apache.spark.ml.fpm.
AssociationRules
org.apache.spark.mllib.fpm.
AssociationRules
(implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.mllib.fpm.
AssociationRules.Rule
<Item> (implements scala.Serializable)
org.apache.spark.rdd.
AsyncRDDActions
<T> (implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.ml.attribute.
Attribute
(implements scala.Serializable)
org.apache.spark.ml.attribute.
BinaryAttribute
org.apache.spark.ml.attribute.
NominalAttribute
org.apache.spark.ml.attribute.
NumericAttribute
org.apache.spark.ml.attribute.
AttributeGroup
(implements scala.Serializable)
org.apache.spark.ml.attribute.
AttributeKeys
org.apache.spark.ml.attribute.
AttributeType
org.apache.spark.sql.sources.
BaseRelation
org.apache.spark.sql.internal.BaseSessionStateBuilder
org.apache.spark.sql.hive.
HiveSessionStateBuilder
org.apache.spark.storage.
BasicBlockReplicationPolicy
(implements org.apache.spark.storage.
BlockReplicationPolicy
, org.apache.spark.internal.
Logging
)
org.apache.spark.status.api.v1.streaming.
BatchInfo
org.apache.spark.streaming.scheduler.
BatchInfo
(implements scala.Product, scala.Serializable)
org.apache.spark.util.random.
BernoulliCellSampler
<T> (implements org.apache.spark.util.random.
RandomSampler
<T,U>)
org.apache.spark.util.random.
BernoulliSampler
<T> (implements org.apache.spark.util.random.
RandomSampler
<T,U>)
org.apache.spark.mllib.evaluation.
BinaryClassificationMetrics
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.ml.classification.
BinaryLogisticRegressionSummary
(implements org.apache.spark.ml.classification.
LogisticRegressionSummary
)
org.apache.spark.ml.classification.
BinaryLogisticRegressionTrainingSummary
(implements org.apache.spark.ml.classification.
LogisticRegressionTrainingSummary
)
org.apache.spark.mllib.stat.test.
BinarySample
(implements scala.Product, scala.Serializable)
org.apache.spark.util.random.
BinomialBounds
org.apache.spark.mllib.clustering.
BisectingKMeans
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.mllib.clustering.
BisectingKMeansModel
(implements org.apache.spark.internal.
Logging
, org.apache.spark.mllib.util.
Saveable
, scala.Serializable)
org.apache.spark.mllib.clustering.
BisectingKMeansModel.SaveLoadV1_0$
org.apache.spark.scheduler.
BlacklistedExecutor
(implements scala.Product, scala.Serializable)
org.apache.spark.ml.linalg.
BLAS
org.apache.spark.mllib.linalg.
BLAS
org.apache.spark.storage.
BlockId
org.apache.spark.storage.
BroadcastBlockId
(implements scala.Product, scala.Serializable)
org.apache.spark.storage.
RDDBlockId
(implements scala.Product, scala.Serializable)
org.apache.spark.storage.
ShuffleBlockId
(implements scala.Product, scala.Serializable)
org.apache.spark.storage.
ShuffleDataBlockId
(implements scala.Product, scala.Serializable)
org.apache.spark.storage.
ShuffleIndexBlockId
(implements scala.Product, scala.Serializable)
org.apache.spark.storage.
StreamBlockId
(implements scala.Product, scala.Serializable)
org.apache.spark.storage.
TaskResultBlockId
(implements scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerId
(implements java.io.Externalizable)
org.apache.spark.storage.
BlockManagerMessages
org.apache.spark.storage.
BlockManagerMessages.BlockManagerHeartbeat
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerMaster
, scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.GetBlockStatus
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerMaster
, scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.GetExecutorEndpointRef
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerMaster
, scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.GetLocations
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerMaster
, scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.GetLocationsMultipleBlockIds
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerMaster
, scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.GetMatchingBlockIds
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerMaster
, scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.GetMemoryStatus$
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerMaster
, scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.GetPeers
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerMaster
, scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.GetStorageStatus$
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerMaster
, scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.HasCachedBlocks
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerMaster
, scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.RegisterBlockManager
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerMaster
, scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.RemoveBlock
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerSlave
, scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.RemoveBroadcast
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerSlave
, scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.RemoveExecutor
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerMaster
, scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.RemoveRdd
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerSlave
, scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.RemoveShuffle
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerSlave
, scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.ReplicateBlock
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerSlave
, scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.StopBlockManagerMaster$
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerMaster
, scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.TriggerThreadDump$
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerSlave
, scala.Product, scala.Serializable)
org.apache.spark.storage.
BlockManagerMessages.UpdateBlockInfo
(implements org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerMaster
, java.io.Externalizable, scala.Product, scala.Serializable)
org.apache.spark.mllib.linalg.distributed.
BlockMatrix
(implements org.apache.spark.mllib.linalg.distributed.
DistributedMatrix
, org.apache.spark.internal.
Logging
)
org.apache.spark.storage.
BlockReplicationUtils
org.apache.spark.storage.
BlockStatus
(implements scala.Product, scala.Serializable)
org.apache.spark.storage.BlockStatusListener
org.apache.spark.ui.storage.
StorageListener
org.apache.spark.storage.
BlockUpdatedInfo
(implements scala.Product, scala.Serializable)
org.apache.spark.util.sketch.
BloomFilter
org.apache.spark.mllib.tree.configuration.
BoostingStrategy
(implements scala.Product, scala.Serializable)
org.apache.spark.partial.
BoundedDouble
org.apache.spark.ml.ann.
BreezeUtil
org.apache.spark.broadcast.
Broadcast
<T> (implements org.apache.spark.internal.
Logging
, java.io.Serializable)
org.apache.spark.streaming.kafka.
Broker
(implements scala.Serializable)
org.apache.spark.graphx.util.
BytecodeUtils
org.apache.spark.sql.catalog.
Catalog
org.apache.spark.ml.tree.
CategoricalSplit
(implements org.apache.spark.ml.tree.
Split
)
org.apache.spark.util.
CausedBy
org.apache.spark.streaming.
CheckpointReader
org.apache.spark.rdd.
CheckpointState
org.apache.spark.mllib.feature.
ChiSqSelector
(implements scala.Serializable)
org.apache.spark.mllib.feature.
ChiSqSelectorModel
(implements org.apache.spark.mllib.util.
Saveable
, org.apache.spark.mllib.feature.
VectorTransformer
)
org.apache.spark.mllib.feature.
ChiSqSelectorModel.SaveLoadV1_0$
org.apache.spark.mllib.feature.
ChiSqSelectorModel.SaveLoadV1_0$.Data
(implements scala.Product, scala.Serializable)
org.apache.spark.mllib.stat.test.
ChiSqTest
org.apache.spark.mllib.stat.test.
ChiSqTest.Method
(implements scala.Product, scala.Serializable)
org.apache.spark.mllib.stat.test.
ChiSqTestResult
(implements org.apache.spark.mllib.stat.test.
TestResult
<DF>)
org.apache.spark.ml.stat.
ChiSquareTest
org.apache.spark.mllib.linalg.
CholeskyDecomposition
org.apache.xbean.asm5.ClassVisitor
org.apache.spark.util.
InnerClosureFinder
org.apache.spark.util.
ReturnStatementFinder
org.apache.spark.
CleanAccum
(implements org.apache.spark.
CleanupTask
, scala.Product, scala.Serializable)
org.apache.spark.
CleanBroadcast
(implements org.apache.spark.
CleanupTask
, scala.Product, scala.Serializable)
org.apache.spark.
CleanCheckpoint
(implements org.apache.spark.
CleanupTask
, scala.Product, scala.Serializable)
org.apache.spark.
CleanRDD
(implements org.apache.spark.
CleanupTask
, scala.Product, scala.Serializable)
org.apache.spark.
CleanShuffle
(implements org.apache.spark.
CleanupTask
, scala.Product, scala.Serializable)
org.apache.spark.util.
ClosureCleaner
org.apache.spark.ml.clustering.
ClusteringSummary
(implements scala.Serializable)
org.apache.spark.ml.clustering.
BisectingKMeansSummary
org.apache.spark.ml.clustering.
GaussianMixtureSummary
org.apache.spark.ml.clustering.
KMeansSummary
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.AddWebUIFilter
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.GetExecutorLossReason
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.KillExecutors
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.KillExecutorsOnHost
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.KillTask
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.LaunchTask
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.RegisterClusterManager
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.RegisteredExecutor$
(implements org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.RegisterExecutorResponse
, scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.RegisterExecutor
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.RegisterExecutorFailed
(implements org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.RegisterExecutorResponse
, scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.RemoveExecutor
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.RequestExecutors
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.RetrieveLastAllocatedExecutorId$
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.RetrieveSparkAppConfig$
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.ReviveOffers$
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.SetupDriver
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.Shutdown$
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.SparkAppConfig
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.StatusUpdate
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.StatusUpdate$
(implements scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.StopDriver$
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.StopExecutor$
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.StopExecutors$
(implements scala.Product, scala.Serializable)
org.apache.spark.metrics.source.
CodegenMetrics
org.apache.spark.util.
CollectionsUtils
org.apache.spark.sql.
Column
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.sql.
ColumnName
org.apache.spark.sql.
TypedColumn
<T,U>
org.apache.spark.sql.catalog.
Column
(implements org.apache.spark.sql.catalyst.DefinedByConstructorParams)
org.apache.spark.
ComplexFutureAction
<T> (implements org.apache.spark.
FutureAction
<T>)
org.apache.spark.internal.config.
ConfigEntryWithDefault
<T>
org.apache.spark.internal.config.
ConfigEntryWithDefaultFunction
<T>
org.apache.spark.internal.config.
ConfigEntryWithDefaultString
<T>
org.apache.spark.internal.config.
ConfigHelpers
org.apache.spark.graphx.lib.
ConnectedComponents
org.apache.spark.ml.tree.
ContinuousSplit
(implements org.apache.spark.ml.tree.
Split
)
org.apache.spark.mllib.linalg.distributed.
CoordinateMatrix
(implements org.apache.spark.mllib.linalg.distributed.
DistributedMatrix
)
org.apache.spark.ml.stat.
Correlation
org.apache.spark.mllib.stat.correlation.
CorrelationNames
org.apache.spark.mllib.stat.correlation.
Correlations
org.apache.spark.storage.
CountingWritableChannel
(implements java.nio.channels.WritableByteChannel)
org.apache.spark.util.sketch.
CountMinSketch
org.apache.spark.security.
CryptoStreamUtils
org.apache.spark.sql.catalog.
Database
(implements org.apache.spark.sql.catalyst.DefinedByConstructorParams)
org.apache.spark.sql.
DataFrameNaFunctions
org.apache.spark.sql.
DataFrameReader
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.sql.
DataFrameStatFunctions
org.apache.spark.sql.
DataFrameWriter
<T>
org.apache.spark.sql.
Dataset
<T> (implements scala.Serializable)
org.apache.spark.sql.
DatasetHolder
<T> (implements scala.Product, scala.Serializable)
org.apache.spark.sql.streaming.
DataStreamReader
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.sql.streaming.
DataStreamWriter
<T>
org.apache.spark.sql.types.
DataType
org.apache.spark.sql.types.
ArrayType
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.types.
BinaryType
org.apache.spark.sql.types.
BooleanType
org.apache.spark.sql.types.
CalendarIntervalType
org.apache.spark.sql.types.
DateType
org.apache.spark.sql.types.
HiveStringType
org.apache.spark.sql.types.
CharType
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.types.
VarcharType
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.types.
MapType
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.types.
NullType
org.apache.spark.sql.types.
NumericType
org.apache.spark.sql.types.
ByteType
org.apache.spark.sql.types.
DecimalType
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.types.
DoubleType
org.apache.spark.sql.types.
FloatType
org.apache.spark.sql.types.
IntegerType
org.apache.spark.sql.types.
LongType
org.apache.spark.sql.types.
ShortType
org.apache.spark.sql.types.
ObjectType
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.types.
StringType
org.apache.spark.sql.types.
StructType
(implements scala.Product, scala.collection.Seq<A>, scala.Serializable)
org.apache.spark.sql.types.
TimestampType
org.apache.spark.sql.types.
DataTypes
org.apache.spark.mllib.util.
DataValidators
org.apache.spark.sql.jdbc.
DB2Dialect
org.apache.spark.sql.types.
Decimal
(implements scala.math.Ordered<A>, scala.Serializable)
org.apache.spark.sql.types.
Decimal.DecimalAsIfIntegral$
(implements scala.math.Integral<T>)
org.apache.spark.sql.types.
Decimal.DecimalIsFractional$
(implements scala.math.Fractional<T>)
org.apache.spark.sql.types.
DecimalType.Expression$
org.apache.spark.sql.types.
DecimalType.Fixed$
org.apache.spark.mllib.tree.
DecisionTree
(implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.mllib.tree.model.
DecisionTreeModel
(implements org.apache.spark.mllib.util.
Saveable
, scala.Serializable)
org.apache.spark.mllib.tree.model.
DecisionTreeModel.SaveLoadV1_0$
org.apache.spark.mllib.tree.model.
DecisionTreeModel.SaveLoadV1_0$.NodeData
(implements scala.Product, scala.Serializable)
org.apache.spark.mllib.tree.model.
DecisionTreeModel.SaveLoadV1_0$.PredictData
(implements scala.Product, scala.Serializable)
org.apache.spark.mllib.tree.model.
DecisionTreeModel.SaveLoadV1_0$.SplitData
(implements scala.Product, scala.Serializable)
org.apache.spark.ml.tree.
DecisionTreeModelReadWrite
org.apache.spark.ml.tree.
DecisionTreeModelReadWrite.NodeData
(implements scala.Product, scala.Serializable)
org.apache.spark.ml.tree.
DecisionTreeModelReadWrite.NodeData$
(implements scala.Serializable)
org.apache.spark.ml.tree.
DecisionTreeModelReadWrite.SplitData
(implements scala.Product, scala.Serializable)
org.apache.spark.ml.tree.
DecisionTreeModelReadWrite.SplitData$
(implements scala.Serializable)
org.apache.spark.streaming.kinesis.
DefaultCredentials
org.apache.spark.rdd.
DefaultPartitionCoalescer
(implements org.apache.spark.rdd.
PartitionCoalescer
)
org.apache.spark.rdd.
DefaultPartitionCoalescer.PartitionLocations
org.apache.spark.ml.linalg.
DenseMatrix
(implements org.apache.spark.ml.linalg.
Matrix
)
org.apache.spark.mllib.linalg.
DenseMatrix
(implements org.apache.spark.mllib.linalg.
Matrix
)
org.apache.spark.ml.linalg.
DenseVector
(implements org.apache.spark.ml.linalg.
Vector
)
org.apache.spark.mllib.linalg.
DenseVector
(implements org.apache.spark.mllib.linalg.
Vector
)
org.apache.spark.
Dependency
<T> (implements scala.Serializable)
org.apache.spark.
NarrowDependency
<T>
org.apache.spark.
OneToOneDependency
<T>
org.apache.spark.
RangeDependency
<T>
org.apache.spark.
ShuffleDependency
<K,V,C>
org.apache.spark.sql.jdbc.
DerbyDialect
org.apache.spark.serializer.
DeserializationStream
(implements java.io.Closeable)
org.apache.spark.storage.memory.
DeserializedMemoryEntry
<T> (implements org.apache.spark.storage.memory.
MemoryEntry
<T>, scala.Product, scala.Serializable)
org.apache.spark.ml.feature.
Dot
org.apache.spark.rdd.
DoubleRDDFunctions
(implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.streaming.dstream.
DStream
<T> (implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.streaming.dstream.
InputDStream
<T>
org.apache.spark.streaming.dstream.
ConstantInputDStream
<T>
org.apache.spark.streaming.dstream.
ReceiverInputDStream
<T>
org.apache.spark.streaming.dstream.
MapWithStateDStream
<KeyType,ValueType,StateType,MappedType>
org.apache.spark.streaming.
Duration
(implements scala.Product, scala.Serializable)
org.apache.spark.streaming.
Durations
org.apache.spark.graphx.
Edge
<ED> (implements scala.Product, scala.Serializable)
org.apache.spark.graphx.
EdgeTriplet
<VD,ED>
org.apache.spark.graphx.
EdgeContext
<VD,ED,A>
org.apache.spark.graphx.impl.
AggregatingEdgeContext
<VD,ED,A>
org.apache.spark.graphx.
EdgeDirection
(implements scala.Serializable)
org.apache.spark.mllib.linalg.
EigenValueDecomposition
org.apache.spark.mllib.feature.
ElementwiseProduct
(implements org.apache.spark.mllib.feature.
VectorTransformer
)
org.apache.spark.mllib.clustering.
EMLDAOptimizer
(implements org.apache.spark.mllib.clustering.
LDAOptimizer
)
org.apache.spark.sql.
Encoders
org.apache.spark.storage.
EncryptedBlockData
org.apache.spark.mllib.tree.configuration.
EnsembleCombiningStrategy
org.apache.spark.ml.tree.
EnsembleModelReadWrite
org.apache.spark.ml.tree.
EnsembleModelReadWrite.EnsembleNodeData
(implements scala.Product, scala.Serializable)
org.apache.spark.ml.tree.
EnsembleModelReadWrite.EnsembleNodeData$
(implements scala.Serializable)
org.apache.spark.mllib.tree.impurity.
Entropy
scala.Enumeration (implements scala.Serializable)
org.apache.spark.mllib.stat.test.
ChiSqTest.NullHypothesis$
org.apache.spark.mllib.stat.test.
KolmogorovSmirnovTest.NullHypothesis$
org.apache.spark.util.
EnumUtil
org.apache.spark.ml.evaluation.
Evaluator
(implements org.apache.spark.ml.param.
Params
)
org.apache.spark.ml.evaluation.
BinaryClassificationEvaluator
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.evaluation.
MulticlassClassificationEvaluator
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.evaluation.
RegressionEvaluator
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.streaming.flume.
EventTransformer
org.apache.spark.
ExceptionFailure
(implements scala.Product, scala.Serializable, org.apache.spark.
TaskFailedReason
)
org.apache.spark.sql.util.
ExecutionListenerManager
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.scheduler.cluster.
ExecutorInfo
org.apache.spark.scheduler.
ExecutorKilled
org.apache.spark.
ExecutorLostFailure
(implements scala.Product, scala.Serializable, org.apache.spark.
TaskFailedReason
)
org.apache.spark.
ExecutorRegistered
(implements scala.Product, scala.Serializable)
org.apache.spark.
ExecutorRemoved
(implements scala.Product, scala.Serializable)
org.apache.spark.status.api.v1.
ExecutorStageSummary
org.apache.spark.status.api.v1.
ExecutorSummary
org.apache.spark.ml.clustering.
ExpectationAggregator
(implements scala.Serializable)
org.apache.spark.mllib.clustering.
ExpectationSum
(implements scala.Serializable)
org.apache.spark.sql.
ExperimentalMethods
org.apache.spark.
ExpireDeadHosts
org.apache.spark.mllib.random.
ExponentialGenerator
(implements org.apache.spark.mllib.random.
RandomDataGenerator
<T>)
org.apache.spark.internal.config.
FallbackConfigEntry
<T>
org.apache.spark.mllib.evaluation.binary.
FalsePositiveRate
org.apache.spark.mllib.tree.configuration.
FeatureType
org.apache.spark.
FetchFailed
(implements scala.Product, scala.Serializable, org.apache.spark.
TaskFailedReason
)
org.apache.spark.internal.io.
FileCommitProtocol
org.apache.spark.internal.io.
HadoopMapReduceCommitProtocol
(implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.internal.io.
FileCommitProtocol.TaskCommitMessage
(implements scala.Serializable)
org.apache.spark.internal.io.
FileCommitProtocol.EmptyTaskCommitMessage$
org.apache.spark.sql.sources.
Filter
org.apache.spark.sql.sources.
And
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.sources.
EqualNullSafe
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.sources.
EqualTo
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.sources.
GreaterThan
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.sources.
GreaterThanOrEqual
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.sources.
In
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.sources.
IsNotNull
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.sources.
IsNull
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.sources.
LessThan
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.sources.
LessThanOrEqual
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.sources.
Not
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.sources.
Or
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.sources.
StringContains
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.sources.
StringEndsWith
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.sources.
StringStartsWith
(implements scala.Product, scala.Serializable)
org.apache.spark.streaming.flume.
FlumeUtils
org.apache.spark.sql.
ForeachWriter
<T> (implements scala.Serializable)
org.apache.spark.mllib.fpm.
FPGrowth
(implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.mllib.fpm.
FPGrowth.FreqItemset
<Item> (implements scala.Serializable)
org.apache.spark.mllib.fpm.
FPGrowthModel
<Item> (implements org.apache.spark.mllib.util.
Saveable
, scala.Serializable)
org.apache.spark.mllib.fpm.
FPGrowthModel.SaveLoadV1_0$
org.apache.spark.sql.catalog.
Function
(implements org.apache.spark.sql.catalyst.DefinedByConstructorParams)
org.apache.spark.sql.
functions
org.apache.spark.mllib.random.
GammaGenerator
(implements org.apache.spark.mllib.random.
RandomDataGenerator
<T>)
org.apache.spark.mllib.clustering.
GaussianMixture
(implements scala.Serializable)
org.apache.spark.mllib.clustering.
GaussianMixtureModel
(implements org.apache.spark.mllib.util.
Saveable
, scala.Serializable)
org.apache.spark.mllib.regression.
GeneralizedLinearAlgorithm
<M> (implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.mllib.regression.
LassoWithSGD
(implements scala.Serializable)
org.apache.spark.mllib.regression.
LinearRegressionWithSGD
(implements scala.Serializable)
org.apache.spark.mllib.classification.
LogisticRegressionWithLBFGS
(implements scala.Serializable)
org.apache.spark.mllib.classification.
LogisticRegressionWithSGD
(implements scala.Serializable)
org.apache.spark.mllib.regression.
RidgeRegressionWithSGD
(implements scala.Serializable)
org.apache.spark.mllib.classification.
SVMWithSGD
(implements scala.Serializable)
org.apache.spark.mllib.regression.
GeneralizedLinearModel
(implements scala.Serializable)
org.apache.spark.mllib.regression.
LassoModel
(implements org.apache.spark.mllib.pmml.
PMMLExportable
, org.apache.spark.mllib.regression.
RegressionModel
, org.apache.spark.mllib.util.
Saveable
, scala.Serializable)
org.apache.spark.mllib.regression.
LinearRegressionModel
(implements org.apache.spark.mllib.pmml.
PMMLExportable
, org.apache.spark.mllib.regression.
RegressionModel
, org.apache.spark.mllib.util.
Saveable
, scala.Serializable)
org.apache.spark.mllib.classification.
LogisticRegressionModel
(implements org.apache.spark.mllib.classification.
ClassificationModel
, org.apache.spark.mllib.pmml.
PMMLExportable
, org.apache.spark.mllib.util.
Saveable
, scala.Serializable)
org.apache.spark.mllib.regression.
RidgeRegressionModel
(implements org.apache.spark.mllib.pmml.
PMMLExportable
, org.apache.spark.mllib.regression.
RegressionModel
, org.apache.spark.mllib.util.
Saveable
, scala.Serializable)
org.apache.spark.mllib.classification.
SVMModel
(implements org.apache.spark.mllib.classification.
ClassificationModel
, org.apache.spark.mllib.pmml.
PMMLExportable
, org.apache.spark.mllib.util.
Saveable
, scala.Serializable)
org.apache.spark.ml.regression.
GeneralizedLinearRegression.Binomial$
org.apache.spark.ml.regression.
GeneralizedLinearRegression.CLogLog$
org.apache.spark.ml.regression.
GeneralizedLinearRegression.Family$
(implements scala.Serializable)
org.apache.spark.ml.regression.
GeneralizedLinearRegression.FamilyAndLink$
(implements scala.Serializable)
org.apache.spark.ml.regression.
GeneralizedLinearRegression.Gamma$
org.apache.spark.ml.regression.
GeneralizedLinearRegression.Gaussian$
org.apache.spark.ml.regression.
GeneralizedLinearRegression.Identity$
org.apache.spark.ml.regression.
GeneralizedLinearRegression.Inverse$
org.apache.spark.ml.regression.
GeneralizedLinearRegression.Link$
(implements scala.Serializable)
org.apache.spark.ml.regression.
GeneralizedLinearRegression.Log$
org.apache.spark.ml.regression.
GeneralizedLinearRegression.Logit$
org.apache.spark.ml.regression.
GeneralizedLinearRegression.Poisson$
org.apache.spark.ml.regression.
GeneralizedLinearRegression.Probit$
org.apache.spark.ml.regression.
GeneralizedLinearRegression.Sqrt$
org.apache.spark.ml.regression.
GeneralizedLinearRegression.Tweedie$
(implements scala.Serializable)
org.apache.spark.ml.regression.
GeneralizedLinearRegressionSummary
(implements scala.Serializable)
org.apache.spark.ml.regression.
GeneralizedLinearRegressionTrainingSummary
(implements scala.Serializable)
org.apache.spark.streaming.scheduler.
GetAllReceiverInfo
org.apache.spark.mllib.tree.impurity.
Gini
org.apache.spark.mllib.classification.impl.
GLMClassificationModel
org.apache.spark.mllib.classification.impl.
GLMClassificationModel.SaveLoadV1_0$
org.apache.spark.mllib.classification.impl.
GLMClassificationModel.SaveLoadV1_0$.Data
(implements scala.Product, scala.Serializable)
org.apache.spark.mllib.regression.impl.
GLMRegressionModel
org.apache.spark.mllib.regression.impl.
GLMRegressionModel.SaveLoadV1_0$
org.apache.spark.mllib.regression.impl.
GLMRegressionModel.SaveLoadV1_0$.Data
(implements scala.Product, scala.Serializable)
org.apache.spark.mllib.optimization.
Gradient
(implements scala.Serializable)
org.apache.spark.mllib.optimization.
HingeGradient
org.apache.spark.mllib.optimization.
LeastSquaresGradient
org.apache.spark.mllib.optimization.
LogisticGradient
org.apache.spark.ml.tree.impl.
GradientBoostedTrees
org.apache.spark.mllib.tree.
GradientBoostedTrees
(implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.mllib.tree.model.
GradientBoostedTreesModel
(implements org.apache.spark.mllib.util.
Saveable
)
org.apache.spark.mllib.optimization.
GradientDescent
(implements org.apache.spark.internal.
Logging
, org.apache.spark.mllib.optimization.
Optimizer
)
org.apache.spark.graphx.
Graph
<VD,ED> (implements scala.Serializable)
org.apache.spark.graphx.impl.
GraphImpl
<VD,ED> (implements scala.Serializable)
org.apache.spark.graphx.util.
GraphGenerators
org.apache.spark.graphx.
GraphLoader
org.apache.spark.graphx.
GraphOps
<VD,ED> (implements scala.Serializable)
org.apache.spark.graphx.
GraphXUtils
org.apache.spark.sql.streaming.
GroupStateTimeout
org.apache.spark.rdd.
HadoopRDD.HadoopMapPartitionsWithSplitRDD$
(implements scala.Serializable)
org.apache.spark.mllib.feature.
HashingTF
(implements scala.Serializable)
org.apache.spark.streaming.util.
HdfsUtils
org.apache.spark.sql.hive.
HiveAnalysis
org.apache.spark.metrics.source.
HiveCatalogMetrics
org.apache.spark.sql.hive.execution.
HiveFileFormat
(implements org.apache.spark.sql.sources.
DataSourceRegister
, org.apache.spark.sql.execution.datasources.FileFormat, org.apache.spark.internal.
Logging
)
org.apache.spark.sql.hive.execution.
HiveOptions
(implements scala.Serializable)
org.apache.spark.sql.hive.execution.
HiveScriptIOSchema
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.hive.
HiveShim
org.apache.spark.sql.hive.
HiveTableUtil
org.apache.spark.sql.hive.
HiveUtils
org.apache.spark.mllib.feature.
IDF
org.apache.spark.mllib.feature.
IDF.DocumentFrequencyAggregator
(implements scala.Serializable)
org.apache.spark.mllib.feature.
IDFModel
(implements scala.Serializable)
org.apache.spark.mllib.tree.impurity.
Impurities
org.apache.spark.mllib.linalg.distributed.
IndexedRow
(implements scala.Product, scala.Serializable)
org.apache.spark.mllib.linalg.distributed.
IndexedRowMatrix
(implements org.apache.spark.mllib.linalg.distributed.
DistributedMatrix
)
org.apache.spark.mllib.tree.model.
InformationGainStats
(implements scala.Serializable)
org.apache.spark.rdd.
InputFileBlockHolder
org.apache.spark.scheduler.
InputFormatInfo
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.status.api.v1.
InputMetricDistributions
org.apache.spark.status.api.v1.
InputMetrics
java.io.InputStream (implements java.io.Closeable)
org.apache.spark.storage.
BufferReleasingInputStream
java.io.FilterInputStream
org.apache.spark.io.
LZ4BlockInputStream
org.apache.spark.io.
NioBufferedFileInputStream
org.apache.spark.
InternalAccumulator
org.apache.spark.
InternalAccumulator.input$
org.apache.spark.
InternalAccumulator.output$
org.apache.spark.
InternalAccumulator.shuffleRead$
org.apache.spark.
InternalAccumulator.shuffleWrite$
org.apache.spark.
InterruptibleIterator
<T> (implements scala.collection.Iterator<A>)
org.apache.spark.util.
IntParam
org.apache.spark.mllib.regression.
IsotonicRegression
(implements java.io.Serializable)
org.apache.spark.mllib.regression.
IsotonicRegressionModel
(implements org.apache.spark.mllib.util.
Saveable
, java.io.Serializable)
org.apache.spark.api.java.
JavaDoubleRDD
org.apache.spark.streaming.api.java.
JavaDStream
<T>
org.apache.spark.streaming.api.java.
JavaInputDStream
<T>
org.apache.spark.streaming.api.java.
JavaReceiverInputDStream
<T>
org.apache.spark.streaming.api.java.
JavaMapWithStateDStream
<KeyType,ValueType,StateType,MappedType>
org.apache.spark.mllib.
JavaPackage
org.apache.spark.streaming.api.java.
JavaPairDStream
<K,V>
org.apache.spark.streaming.api.java.
JavaPairInputDStream
<K,V>
org.apache.spark.streaming.api.java.
JavaPairReceiverInputDStream
<K,V>
org.apache.spark.api.java.
JavaPairRDD
<K,V>
org.apache.spark.api.java.
JavaHadoopRDD
<K,V>
org.apache.spark.api.java.
JavaNewHadoopRDD
<K,V>
org.apache.spark.ml.param.
JavaParams
(implements org.apache.spark.ml.param.
Params
)
org.apache.spark.api.java.
JavaRDD
<T>
org.apache.spark.api.java.
JavaSparkContext
(implements java.io.Closeable)
org.apache.spark.api.java.
JavaSparkStatusTracker
org.apache.spark.streaming.api.java.
JavaStreamingContext
(implements java.io.Closeable)
org.apache.spark.api.java.
JavaUtils
org.apache.spark.sql.jdbc.
JdbcDialect
(implements scala.Serializable)
org.apache.spark.sql.jdbc.
AggregatedDialect
org.apache.spark.sql.jdbc.
JdbcDialects
org.apache.spark.sql.jdbc.
JdbcType
(implements scala.Product, scala.Serializable)
org.apache.spark.ui.
JettyUtils
org.apache.spark.ui.
JettyUtils.ServletParams
<T>
org.apache.spark.ui.
JettyUtils.ServletParams$
org.apache.spark.status.api.v1.
JobData
org.apache.spark.scheduler.
JobSucceeded
org.apache.spark.util.
JsonProtocol
org.apache.spark.ml.linalg.
JsonVectorConverter
org.apache.spark.streaming.kafka.
KafkaCluster
(implements scala.Serializable)
org.apache.spark.streaming.kafka.
KafkaCluster.LeaderOffset
(implements scala.Product, scala.Serializable)
org.apache.spark.streaming.kafka.
KafkaCluster.SimpleConsumerConfig$
org.apache.spark.streaming.kafka.
KafkaUtils
org.apache.spark.mllib.stat.
KernelDensity
(implements scala.Serializable)
org.apache.spark.sql.
KeyValueGroupedDataset
<K,V> (implements scala.Serializable)
org.apache.spark.scheduler.local.
KillTask
(implements scala.Product, scala.Serializable)
org.apache.spark.streaming.kinesis.
KinesisUtils
org.apache.spark.streaming.kinesis.
KinesisUtilsPythonHelper
org.apache.spark.mllib.clustering.
KMeans
(implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.mllib.util.
KMeansDataGenerator
org.apache.spark.mllib.clustering.
KMeansModel
(implements org.apache.spark.mllib.pmml.
PMMLExportable
, org.apache.spark.mllib.util.
Saveable
, scala.Serializable)
org.apache.spark.mllib.clustering.
StreamingKMeansModel
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.mllib.clustering.
KMeansModel.SaveLoadV1_0$
org.apache.spark.mllib.stat.test.
KolmogorovSmirnovTest
org.apache.spark.mllib.stat.test.
KolmogorovSmirnovTestResult
(implements org.apache.spark.mllib.stat.test.
TestResult
<DF>)
org.apache.spark.ml.classification.
LabelConverter
org.apache.spark.ml.feature.
LabeledPoint
(implements scala.Product, scala.Serializable)
org.apache.spark.mllib.regression.
LabeledPoint
(implements scala.Product, scala.Serializable)
org.apache.spark.graphx.lib.
LabelPropagation
org.apache.spark.mllib.optimization.
LBFGS
(implements org.apache.spark.internal.
Logging
, org.apache.spark.mllib.optimization.
Optimizer
)
org.apache.spark.mllib.clustering.
LDA
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.mllib.clustering.
LDAModel
(implements org.apache.spark.mllib.util.
Saveable
)
org.apache.spark.mllib.clustering.
DistributedLDAModel
org.apache.spark.mllib.clustering.
LocalLDAModel
(implements scala.Serializable)
org.apache.spark.mllib.clustering.
LDAUtils
org.apache.spark.ml.regression.
LeastSquaresAggregator
(implements scala.Serializable)
org.apache.spark.ml.regression.
LeastSquaresCostFun
(implements breeze.optimize.DiffFunction<T>)
org.apache.spark.ml.source.libsvm.
LibSVMDataSource
org.apache.spark.mllib.util.
LinearDataGenerator
org.apache.spark.ml.regression.
LinearRegressionSummary
(implements scala.Serializable)
org.apache.spark.ml.regression.
LinearRegressionTrainingSummary
org.apache.spark.ml.classification.
LinearSVCAggregator
(implements scala.Serializable)
org.apache.spark.ml.classification.
LinearSVCCostFun
(implements breeze.optimize.DiffFunction<T>)
org.apache.spark.mllib.clustering.
LocalKMeans
org.apache.spark.ml.classification.
LogisticAggregator
(implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.ml.classification.
LogisticCostFun
(implements breeze.optimize.DiffFunction<T>)
org.apache.spark.mllib.util.
LogisticRegressionDataGenerator
org.apache.spark.mllib.tree.loss.
LogLoss
org.apache.spark.mllib.random.
LogNormalGenerator
(implements org.apache.spark.mllib.random.
RandomDataGenerator
<T>)
org.apache.spark.mllib.tree.loss.
Losses
org.apache.spark.scheduler.
LossReasonPending
org.apache.spark.io.
LZ4CompressionCodec
(implements org.apache.spark.io.
CompressionCodec
)
org.apache.spark.io.
LZFCompressionCodec
(implements org.apache.spark.io.
CompressionCodec
)
org.apache.spark.ml.linalg.
Matrices
org.apache.spark.mllib.linalg.
Matrices
org.apache.spark.mllib.linalg.distributed.
MatrixEntry
(implements scala.Product, scala.Serializable)
org.apache.spark.mllib.recommendation.
MatrixFactorizationModel
(implements org.apache.spark.internal.
Logging
, org.apache.spark.mllib.util.
Saveable
, scala.Serializable)
org.apache.spark.mllib.recommendation.
MatrixFactorizationModel.SaveLoadV1_0$
org.apache.spark.mllib.linalg.
MatrixImplicits
org.apache.spark.status.api.v1.
MemoryMetrics
org.apache.spark.util.
MemoryParam
org.apache.spark.ml.util.
MetaAlgorithmReadWrite
org.apache.spark.sql.types.
Metadata
(implements scala.Serializable)
org.apache.spark.sql.types.
MetadataBuilder
org.apache.spark.ml.util.
MetadataUtils
org.apache.spark.util.
MethodIdentifier
<T> (implements scala.Product, scala.Serializable)
org.apache.spark.mllib.util.
MFDataGenerator
org.apache.spark.streaming.
Milliseconds
org.apache.spark.streaming.
Minutes
org.apache.spark.mllib.rdd.
MLPairRDDFunctions
<K,V> (implements scala.Serializable)
org.apache.spark.ml.util.
MLReader
<T>
org.apache.spark.mllib.util.
MLUtils
org.apache.spark.ml.util.
MLWriter
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.sql.jdbc.
MsSqlServerDialect
org.apache.spark.mllib.evaluation.
MulticlassMetrics
org.apache.spark.mllib.evaluation.
MultilabelMetrics
org.apache.spark.ml.stat.distribution.
MultivariateGaussian
(implements scala.Serializable)
org.apache.spark.mllib.stat.distribution.
MultivariateGaussian
(implements scala.Serializable)
org.apache.spark.mllib.stat.
MultivariateOnlineSummarizer
(implements org.apache.spark.mllib.stat.
MultivariateStatisticalSummary
, scala.Serializable)
org.apache.spark.sql.expressions.
MutableAggregationBuffer
(implements org.apache.spark.sql.
Row
)
org.apache.spark.util.
MutablePair
<T1,T2> (implements scala.Product, scala.Product2<T1,T2>, scala.Serializable)
org.apache.spark.sql.jdbc.
MySQLDialect
org.apache.spark.mllib.classification.
NaiveBayes
(implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.mllib.classification.
NaiveBayesModel
(implements org.apache.spark.mllib.classification.
ClassificationModel
, org.apache.spark.mllib.util.
Saveable
, scala.Serializable)
org.apache.spark.mllib.classification.
NaiveBayesModel.SaveLoadV1_0$
org.apache.spark.mllib.classification.
NaiveBayesModel.SaveLoadV1_0$.Data
(implements scala.Product, scala.Serializable)
org.apache.spark.mllib.classification.
NaiveBayesModel.SaveLoadV2_0$
org.apache.spark.mllib.classification.
NaiveBayesModel.SaveLoadV2_0$.Data
(implements scala.Product, scala.Serializable)
org.apache.spark.rdd.
NewHadoopRDD.NewHadoopMapPartitionsWithSplitRDD$
(implements scala.Serializable)
org.apache.spark.mllib.optimization.
NNLS
org.apache.spark.mllib.optimization.
NNLS.Workspace
org.apache.spark.ml.tree.
Node
(implements scala.Serializable)
org.apache.spark.ml.tree.
InternalNode
org.apache.spark.ml.tree.
LeafNode
org.apache.spark.mllib.tree.model.
Node
(implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.sql.jdbc.
NoopDialect
org.apache.spark.mllib.feature.
Normalizer
(implements org.apache.spark.mllib.feature.
VectorTransformer
)
org.apache.spark.mllib.util.
NumericParser
org.apache.spark.streaming.kafka.
OffsetRange
(implements scala.Serializable)
org.apache.spark.mllib.clustering.
OnlineLDAOptimizer
(implements org.apache.spark.mllib.clustering.
LDAOptimizer
)
org.apache.spark.rpc.netty.
OnStart
org.apache.spark.rpc.netty.
OnStop
org.apache.spark.api.java.
Optional
<T> (implements java.io.Serializable)
org.apache.spark.sql.jdbc.
OracleDialect
org.apache.spark.sql.hive.orc.
OrcFileFormat
(implements org.apache.spark.sql.sources.
DataSourceRegister
, org.apache.spark.sql.execution.datasources.FileFormat, scala.Serializable)
org.apache.spark.sql.hive.orc.
OrcFileOperator
org.apache.spark.sql.hive.orc.
OrcFilters
org.apache.spark.sql.hive.orc.
OrcRelation
org.apache.spark.rdd.
OrderedRDDFunctions
<K,V,P> (implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.status.api.v1.
OutputMetricDistributions
org.apache.spark.status.api.v1.
OutputMetrics
org.apache.spark.sql.streaming.
OutputMode
org.apache.spark.status.api.v1.streaming.
OutputOperationInfo
org.apache.spark.streaming.scheduler.
OutputOperationInfo
(implements scala.Product, scala.Serializable)
java.io.OutputStream (implements java.io.Closeable, java.io.Flushable)
org.apache.spark.io.
SnappyOutputStreamWrapper
org.apache.spark.storage.
TimeTrackingOutputStream
org.apache.spark.sql.execution.datasources.OutputWriter
org.apache.spark.sql.hive.execution.
HiveOutputWriter
org.apache.spark.graphx.lib.
PageRank
org.apache.spark.streaming.dstream.
PairDStreamFunctions
<K,V> (implements scala.Serializable)
org.apache.spark.rdd.
PairRDDFunctions
<K,V> (implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.ml.param.
Param
<T> (implements scala.Serializable)
org.apache.spark.ml.param.
BooleanParam
org.apache.spark.ml.param.
DoubleArrayParam
org.apache.spark.ml.param.
DoubleParam
org.apache.spark.ml.param.
FloatParam
org.apache.spark.ml.param.
IntArrayParam
org.apache.spark.ml.param.
IntParam
org.apache.spark.ml.param.
LongParam
org.apache.spark.ml.param.
StringArrayParam
org.apache.spark.ml.tuning.
ParamGridBuilder
org.apache.spark.ml.param.
ParamMap
(implements scala.Serializable)
org.apache.spark.ml.param.
ParamPair
<T> (implements scala.Product, scala.Serializable)
org.apache.spark.ml.param.
ParamValidators
org.apache.spark.partial.
PartialResult
<R>
org.apache.spark.
Partitioner
(implements scala.Serializable)
org.apache.spark.
HashPartitioner
org.apache.spark.
RangePartitioner
<K,V>
org.apache.spark.rdd.
PartitionGroup
org.apache.spark.graphx.
PartitionStrategy.CanonicalRandomVertexCut$
(implements org.apache.spark.graphx.
PartitionStrategy
, scala.Product, scala.Serializable)
org.apache.spark.graphx.
PartitionStrategy.EdgePartition1D$
(implements org.apache.spark.graphx.
PartitionStrategy
, scala.Product, scala.Serializable)
org.apache.spark.graphx.
PartitionStrategy.EdgePartition2D$
(implements org.apache.spark.graphx.
PartitionStrategy
, scala.Product, scala.Serializable)
org.apache.spark.graphx.
PartitionStrategy.RandomVertexCut$
(implements org.apache.spark.graphx.
PartitionStrategy
, scala.Product, scala.Serializable)
org.apache.spark.mllib.feature.
PCA
org.apache.spark.mllib.feature.
PCAModel
(implements org.apache.spark.mllib.feature.
VectorTransformer
)
org.apache.spark.mllib.stat.correlation.
PearsonCorrelation
org.apache.spark.ml.
Pipeline.SharedReadWrite$
org.apache.spark.ml.
PipelineStage
(implements org.apache.spark.internal.
Logging
, org.apache.spark.ml.param.
Params
)
org.apache.spark.ml.
Estimator
<M>
org.apache.spark.ml.regression.
AFTSurvivalRegression
(implements org.apache.spark.ml.util.
DefaultParamsWritable
, org.apache.spark.internal.
Logging
)
org.apache.spark.ml.recommendation.
ALS
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.clustering.
BisectingKMeans
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
BucketedRandomProjectionLSH
org.apache.spark.ml.feature.
ChiSqSelector
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
CountVectorizer
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.tuning.
CrossValidator
(implements org.apache.spark.internal.
Logging
, org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.fpm.
FPGrowth
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.clustering.
GaussianMixture
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
IDF
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
Imputer
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.regression.
IsotonicRegression
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.clustering.
KMeans
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.clustering.
LDA
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
MaxAbsScaler
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
MinHashLSH
org.apache.spark.ml.feature.
MinMaxScaler
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.classification.
OneVsRest
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.feature.
PCA
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.
Pipeline
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.
Predictor
<FeaturesType,Learner,M>
org.apache.spark.ml.classification.
Classifier
<FeaturesType,E,M>
org.apache.spark.ml.classification.
LinearSVC
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.classification.
ProbabilisticClassifier
<FeaturesType,E,M>
org.apache.spark.ml.classification.
DecisionTreeClassifier
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.classification.
GBTClassifier
(implements org.apache.spark.ml.util.
DefaultParamsWritable
, org.apache.spark.internal.
Logging
)
org.apache.spark.ml.classification.
LogisticRegression
(implements org.apache.spark.ml.util.
DefaultParamsWritable
, org.apache.spark.internal.
Logging
)
org.apache.spark.ml.classification.
NaiveBayes
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.classification.
RandomForestClassifier
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.regression.
DecisionTreeRegressor
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.regression.
GBTRegressor
(implements org.apache.spark.ml.util.
DefaultParamsWritable
, org.apache.spark.internal.
Logging
)
org.apache.spark.ml.regression.
GeneralizedLinearRegression
(implements org.apache.spark.ml.util.
DefaultParamsWritable
, org.apache.spark.internal.
Logging
)
org.apache.spark.ml.regression.
LinearRegression
(implements org.apache.spark.ml.util.
DefaultParamsWritable
, org.apache.spark.internal.
Logging
)
org.apache.spark.ml.classification.
MultilayerPerceptronClassifier
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.regression.
RandomForestRegressor
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
QuantileDiscretizer
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
RFormula
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
StandardScaler
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
StringIndexer
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.tuning.
TrainValidationSplit
(implements org.apache.spark.internal.
Logging
, org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.feature.
VectorIndexer
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
Word2Vec
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.
Transformer
org.apache.spark.ml.feature.
Binarizer
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
ColumnPruner
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.feature.
HashingTF
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
IndexToString
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
Interaction
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.
Model
<M>
org.apache.spark.ml.regression.
AFTSurvivalRegressionModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.recommendation.
ALSModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.clustering.
BisectingKMeansModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.feature.
BucketedRandomProjectionLSHModel
org.apache.spark.ml.feature.
Bucketizer
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
ChiSqSelectorModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.feature.
CountVectorizerModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.tuning.
CrossValidatorModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.fpm.
FPGrowthModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.clustering.
GaussianMixtureModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.feature.
IDFModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.feature.
ImputerModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.regression.
IsotonicRegressionModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.clustering.
KMeansModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.clustering.
LDAModel
(implements org.apache.spark.internal.
Logging
, org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.clustering.
DistributedLDAModel
org.apache.spark.ml.clustering.
LocalLDAModel
org.apache.spark.ml.feature.
MaxAbsScalerModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.feature.
MinHashLSHModel
org.apache.spark.ml.feature.
MinMaxScalerModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.classification.
OneVsRestModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.feature.
PCAModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.
PipelineModel
(implements org.apache.spark.internal.
Logging
, org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.
PredictionModel
<FeaturesType,M>
org.apache.spark.ml.classification.
ClassificationModel
<FeaturesType,M>
org.apache.spark.ml.classification.
LinearSVCModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.classification.
ProbabilisticClassificationModel
<FeaturesType,M>
org.apache.spark.ml.classification.
DecisionTreeClassificationModel
(implements org.apache.spark.ml.util.
MLWritable
, scala.Serializable)
org.apache.spark.ml.classification.
GBTClassificationModel
(implements org.apache.spark.ml.util.
MLWritable
, scala.Serializable)
org.apache.spark.ml.classification.
LogisticRegressionModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.classification.
NaiveBayesModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.classification.
RandomForestClassificationModel
(implements org.apache.spark.ml.util.
MLWritable
, scala.Serializable)
org.apache.spark.ml.regression.
DecisionTreeRegressionModel
(implements org.apache.spark.ml.util.
MLWritable
, scala.Serializable)
org.apache.spark.ml.regression.
GBTRegressionModel
(implements org.apache.spark.ml.util.
MLWritable
, scala.Serializable)
org.apache.spark.ml.classification.
MultilayerPerceptronClassificationModel
(implements org.apache.spark.ml.util.
MLWritable
, scala.Serializable)
org.apache.spark.ml.regression.
RandomForestRegressionModel
(implements org.apache.spark.ml.util.
MLWritable
, scala.Serializable)
org.apache.spark.ml.regression.
RegressionModel
<FeaturesType,M>
org.apache.spark.ml.regression.
GeneralizedLinearRegressionModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.regression.
LinearRegressionModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.feature.
RFormulaModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.feature.
StandardScalerModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.feature.
StringIndexerModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.tuning.
TrainValidationSplitModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.feature.
VectorIndexerModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.feature.
Word2VecModel
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.feature.
OneHotEncoder
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
SQLTransformer
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
StopWordsRemover
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.
UnaryTransformer
<IN,OUT,T> (implements org.apache.spark.internal.
Logging
)
org.apache.spark.ml.feature.
DCT
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
ElementwiseProduct
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
NGram
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
Normalizer
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
PolynomialExpansion
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
RegexTokenizer
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
Tokenizer
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
VectorAssembler
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.ml.feature.
VectorAttributeRewriter
(implements org.apache.spark.ml.util.
MLWritable
)
org.apache.spark.ml.feature.
VectorSlicer
(implements org.apache.spark.ml.util.
DefaultParamsWritable
)
org.apache.spark.mllib.pmml.export.
PMMLModelExportFactory
org.apache.spark.util.random.
PoissonBounds
org.apache.spark.mllib.random.
PoissonGenerator
(implements org.apache.spark.mllib.random.
RandomDataGenerator
<T>)
org.apache.spark.util.random.
PoissonSampler
<T> (implements org.apache.spark.util.random.
RandomSampler
<T,U>)
org.apache.spark.input.
PortableDataStream
(implements scala.Serializable)
org.apache.spark.sql.jdbc.
PostgresDialect
org.apache.spark.mllib.clustering.
PowerIterationClustering
(implements scala.Serializable)
org.apache.spark.mllib.clustering.
PowerIterationClustering.Assignment
(implements scala.Product, scala.Serializable)
org.apache.spark.mllib.clustering.
PowerIterationClusteringModel
(implements org.apache.spark.mllib.util.
Saveable
, scala.Serializable)
org.apache.spark.mllib.clustering.
PowerIterationClusteringModel.SaveLoadV1_0$
org.apache.spark.mllib.evaluation.binary.
Precision
org.apache.spark.mllib.tree.model.
Predict
(implements scala.Serializable)
org.apache.spark.mllib.fpm.
PrefixSpan
(implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.mllib.fpm.
PrefixSpan.FreqSequence
<Item> (implements scala.Serializable)
org.apache.spark.mllib.fpm.
PrefixSpan.Postfix$
(implements scala.Serializable)
org.apache.spark.mllib.fpm.
PrefixSpan.Prefix$
(implements scala.Serializable)
org.apache.spark.mllib.fpm.
PrefixSpanModel
<Item> (implements org.apache.spark.mllib.util.
Saveable
, scala.Serializable)
org.apache.spark.mllib.fpm.
PrefixSpanModel.SaveLoadV1_0$
org.apache.spark.graphx.
Pregel
org.apache.spark.mllib.linalg.
QRDecomposition
<QType,RType> (implements scala.Product, scala.Serializable)
org.apache.spark.mllib.tree.configuration.
QuantileStrategy
org.apache.spark.storage.
RandomBlockReplicationPolicy
(implements org.apache.spark.storage.
BlockReplicationPolicy
, org.apache.spark.internal.
Logging
)
org.apache.spark.ml.tree.impl.
RandomForest
org.apache.spark.mllib.tree.
RandomForest
(implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.mllib.tree.model.
RandomForestModel
(implements org.apache.spark.mllib.util.
Saveable
)
org.apache.spark.mllib.random.
RandomRDDs
org.apache.spark.mllib.evaluation.
RankingMetrics
<T> (implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.mllib.recommendation.
Rating
(implements scala.Product, scala.Serializable)
org.apache.spark.streaming.util.
RawTextHelper
org.apache.spark.streaming.util.
RawTextSender
org.apache.spark.rdd.
RDD
<T> (implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.api.r.
BaseRRDD
<T,U> (implements org.apache.spark.internal.
Logging
)
org.apache.spark.api.r.
PairwiseRRDD
<T>
org.apache.spark.api.r.
RRDD
<T>
org.apache.spark.api.r.
StringRRDD
<T>
org.apache.spark.rdd.
CoGroupedRDD
<K>
org.apache.spark.graphx.
EdgeRDD
<ED>
org.apache.spark.graphx.impl.
EdgeRDDImpl
<ED,VD>
org.apache.spark.rdd.
HadoopRDD
<K,V> (implements org.apache.spark.internal.
Logging
)
org.apache.spark.rdd.
JdbcRDD
<T> (implements org.apache.spark.internal.
Logging
)
org.apache.spark.rdd.
NewHadoopRDD
<K,V> (implements org.apache.spark.internal.
Logging
)
org.apache.spark.rdd.
PartitionPruningRDD
<T>
org.apache.spark.rdd.
ShuffledRDD
<K,V,C>
org.apache.spark.rdd.
UnionRDD
<T>
org.apache.spark.graphx.
VertexRDD
<VD>
org.apache.spark.graphx.impl.
VertexRDDImpl
<VD>
org.apache.spark.status.api.v1.
RDDDataDistribution
org.apache.spark.mllib.rdd.
RDDFunctions
<T> (implements scala.Serializable)
org.apache.spark.storage.
RDDInfo
(implements scala.math.Ordered<A>)
org.apache.spark.status.api.v1.
RDDPartitionInfo
org.apache.spark.status.api.v1.
RDDStorageInfo
org.apache.spark.mllib.evaluation.binary.
Recall
org.apache.spark.streaming.receiver.
Receiver
<T> (implements scala.Serializable)
org.apache.spark.status.api.v1.streaming.
ReceiverInfo
org.apache.spark.streaming.scheduler.
ReceiverInfo
(implements scala.Product, scala.Serializable)
org.apache.spark.streaming.scheduler.
ReceiverState
java.lang.ref.Reference<T>
java.lang.ref.WeakReference<T>
org.apache.spark.
CleanupTaskWeakReference
org.apache.spark.mllib.evaluation.
RegressionMetrics
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.sql.
RelationalGroupedDataset
org.apache.spark.sql.
RelationalGroupedDataset.CubeType$
org.apache.spark.sql.
RelationalGroupedDataset.GroupByType$
org.apache.spark.sql.
RelationalGroupedDataset.RollupType$
org.apache.spark.scheduler.
ResubmitFailedStages
org.apache.spark.
Resubmitted
org.apache.spark.scheduler.local.
ReviveOffers
(implements scala.Product, scala.Serializable)
org.apache.spark.ml.feature.
RFormulaParser
org.apache.spark.sql.
RowFactory
org.apache.spark.mllib.linalg.distributed.
RowMatrix
(implements org.apache.spark.mllib.linalg.distributed.
DistributedMatrix
, org.apache.spark.internal.
Logging
)
org.apache.spark.util.
RpcUtils
org.apache.spark.api.r.
RRunnerModes
org.apache.spark.sql.catalyst.rules.Rule<TreeType> (implements org.apache.spark.internal.
Logging
)
org.apache.spark.sql.hive.
DetermineTableStats
org.apache.spark.sql.hive.
RelationConversions
(implements scala.Product, scala.Serializable)
org.apache.spark.sql.hive.
ResolveHiveSerdeTable
org.apache.spark.sql.
RuntimeConfig
org.apache.spark.status.api.v1.
RuntimeInfo
org.apache.spark.scheduler.
RuntimePercentage
(implements scala.Product, scala.Serializable)
org.apache.spark.api.r.
RUtils
org.apache.spark.ml.r.
RWrappers
org.apache.spark.ml.r.
RWrapperUtils
org.apache.spark.util.random.
SamplingUtils
org.apache.spark.scheduler.
SchedulingMode
org.apache.spark.ml.util.
SchemaUtils
org.apache.spark.sql.util.
SchemaUtils
org.apache.spark.streaming.
Seconds
org.apache.spark.rdd.
SequenceFileRDDFunctions
<K,V> (implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.api.r.
SerDe
org.apache.spark.
SerializableWritable
<T> (implements java.io.Serializable)
org.apache.spark.serializer.
SerializationDebugger
org.apache.spark.serializer.
SerializationDebugger.ObjectStreamClassMethods$
org.apache.spark.api.r.
SerializationFormats
org.apache.spark.serializer.
SerializationStream
(implements java.io.Closeable)
org.apache.spark.storage.memory.
SerializedMemoryEntry
<T> (implements org.apache.spark.storage.memory.
MemoryEntry
<T>, scala.Product, scala.Serializable)
com.esotericsoftware.kryo.Serializer<T>
org.apache.spark.serializer.
JavaIterableWrapperSerializer
org.apache.spark.serializer.
Serializer
org.apache.spark.serializer.
JavaSerializer
(implements java.io.Externalizable)
org.apache.spark.serializer.
KryoSerializer
(implements org.apache.spark.internal.
Logging
, java.io.Serializable)
org.apache.spark.serializer.
SerializerInstance
org.apache.spark.serializer.
DummySerializerInstance
org.apache.spark.sql.internal.SessionResourceLoader (implements org.apache.spark.sql.catalyst.catalog.FunctionResourceLoader)
org.apache.spark.sql.hive.
HiveSessionResourceLoader
org.apache.spark.ml.param.shared.
SharedParamsCodeGen
org.apache.spark.graphx.lib.
ShortestPaths
org.apache.spark.status.api.v1.
ShuffleReadMetricDistributions
org.apache.spark.status.api.v1.
ShuffleReadMetrics
org.apache.spark.status.api.v1.
ShuffleWriteMetricDistributions
org.apache.spark.status.api.v1.
ShuffleWriteMetrics
org.apache.spark.util.
ShutdownHookManager
org.apache.spark.util.
SignalUtils
org.apache.spark.
SimpleFutureAction
<T> (implements org.apache.spark.
FutureAction
<T>)
org.apache.spark.mllib.linalg.
SingularValueDecomposition
<UType,VType> (implements scala.Product, scala.Serializable)
org.apache.spark.sql.streaming.
SinkProgress
(implements scala.Serializable)
org.apache.spark.util.
SizeEstimator
org.apache.spark.io.
SnappyCompressionCodec
(implements org.apache.spark.io.
CompressionCodec
)
org.apache.spark.sql.streaming.
SourceProgress
(implements scala.Serializable)
org.apache.spark.
SparkConf
(implements scala.Cloneable, org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.
SparkContext
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.
SparkEnv
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.
SparkExecutorInfoImpl
(implements org.apache.spark.
SparkExecutorInfo
)
org.apache.spark.util.
SparkExitCode
org.apache.spark.
SparkFiles
org.apache.spark.
SparkFirehoseListener
org.apache.spark.streaming.flume.
SparkFlumeEvent
(implements java.io.Externalizable)
org.apache.spark.internal.io.
SparkHadoopMapReduceWriter
org.apache.spark.mapred.
SparkHadoopMapRedUtil
org.apache.spark.internal.io.
SparkHadoopWriterUtils
org.apache.spark.
SparkJobInfoImpl
(implements org.apache.spark.
SparkJobInfo
)
org.apache.spark.launcher.
SparkLauncher
org.apache.spark.scheduler.
SparkListener
org.apache.spark.ui.env.
EnvironmentListener
org.apache.spark.ui.exec.
ExecutorsListener
org.apache.spark.ui.jobs.
JobProgressListener
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.
SpillListener
org.apache.spark.scheduler.
StatsReportListener
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.storage.
StorageStatusListener
org.apache.spark.scheduler.
SparkListenerApplicationEnd
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerApplicationStart
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerBlockManagerAdded
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerBlockManagerRemoved
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerBlockUpdated
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerEnvironmentUpdate
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerExecutorAdded
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerExecutorBlacklisted
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerExecutorMetricsUpdate
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerExecutorRemoved
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerExecutorUnblacklisted
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerJobEnd
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerJobStart
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerNodeBlacklisted
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerNodeUnblacklisted
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerStageCompleted
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerStageSubmitted
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerTaskEnd
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerTaskGettingResult
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerTaskStart
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.scheduler.
SparkListenerUnpersistRDD
(implements scala.Product, scala.Serializable, org.apache.spark.scheduler.
SparkListenerEvent
)
org.apache.spark.
SparkMasterRegex
org.apache.spark.api.r.
SparkRDefaults
org.apache.spark.sql.
SparkSession
(implements java.io.Closeable, org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.sql.
SparkSession.Builder
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.sql.
SparkSessionExtensions
org.apache.spark.util.
SparkShutdownHook
(implements Comparable<T>)
org.apache.spark.
SparkStageInfoImpl
(implements org.apache.spark.
SparkStageInfo
)
org.apache.spark.
SparkStatusTracker
org.apache.spark.util.
SparkUncaughtExceptionHandler
org.apache.spark.ml.linalg.
SparseMatrix
(implements org.apache.spark.ml.linalg.
Matrix
)
org.apache.spark.mllib.linalg.
SparseMatrix
(implements org.apache.spark.mllib.linalg.
Matrix
)
org.apache.spark.ml.linalg.
SparseVector
(implements org.apache.spark.ml.linalg.
Vector
)
org.apache.spark.mllib.linalg.
SparseVector
(implements org.apache.spark.mllib.linalg.
Vector
)
org.apache.spark.mllib.stat.correlation.
SpearmanCorrelation
org.apache.spark.api.r.
SpecialLengths
org.apache.spark.mllib.tree.model.
Split
(implements scala.Product, scala.Serializable)
org.apache.spark.scheduler.
SplitInfo
org.apache.spark.sql.
SQLContext
(implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.sql.hive.
HiveContext
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.ml.linalg.
SQLDataTypes
org.apache.spark.sql.
SQLImplicits
(implements org.apache.spark.sql.
LowPrioritySQLImplicits
)
org.apache.spark.sql.
SparkSession.implicits$
(implements scala.Serializable)
org.apache.spark.sql.
SQLContext.implicits$
(implements scala.Serializable)
org.apache.spark.sql.
SQLImplicits.StringToColumn
org.apache.spark.sql.api.r.
SQLUtils
org.apache.spark.mllib.tree.loss.
SquaredError
org.apache.spark.status.api.v1.
StageData
org.apache.spark.scheduler.
StageInfo
org.apache.spark.mllib.random.
StandardNormalGenerator
(implements org.apache.spark.mllib.random.
RandomDataGenerator
<T>)
org.apache.spark.mllib.feature.
StandardScaler
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.mllib.feature.
StandardScalerModel
(implements org.apache.spark.mllib.feature.
VectorTransformer
)
org.apache.spark.util.
StatCounter
(implements scala.Serializable)
org.apache.spark.streaming.
State
<S>
org.apache.spark.sql.streaming.
StateOperatorProgress
(implements scala.Serializable)
org.apache.spark.streaming.
StateSpec
<KeyType,ValueType,StateType,MappedType> (implements scala.Serializable)
org.apache.spark.metrics.source.
StaticSources
org.apache.spark.mllib.stat.
Statistics
org.apache.spark.streaming.scheduler.
StatsReportListener
(implements org.apache.spark.streaming.scheduler.
StreamingListener
)
org.apache.spark.scheduler.local.
StatusUpdate
(implements scala.Product, scala.Serializable)
org.apache.spark.streaming.scheduler.
StopAllReceivers
org.apache.spark.scheduler.
StopCoordinator
org.apache.spark.scheduler.local.
StopExecutor
(implements scala.Product, scala.Serializable)
org.apache.spark.
StopMapOutputTracker
org.apache.spark.streaming.receiver.
StopReceiver
org.apache.spark.storage.
StorageLevel
(implements java.io.Externalizable)
org.apache.spark.api.java.
StorageLevels
org.apache.spark.storage.
StorageStatus
org.apache.spark.storage.
StorageUtils
org.apache.spark.mllib.tree.configuration.
Strategy
(implements scala.Serializable)
org.apache.spark.util.random.
StratifiedSamplingUtils
org.apache.spark.streaming.
StreamingContext
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.streaming.
StreamingContextPythonHelper
org.apache.spark.mllib.clustering.
StreamingKMeans
(implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.mllib.regression.
StreamingLinearAlgorithm
<M,A> (implements org.apache.spark.internal.
Logging
)
org.apache.spark.mllib.regression.
StreamingLinearRegressionWithSGD
(implements scala.Serializable)
org.apache.spark.mllib.classification.
StreamingLogisticRegressionWithSGD
(implements scala.Serializable)
org.apache.spark.streaming.scheduler.
StreamingListenerBatchCompleted
(implements scala.Product, scala.Serializable, org.apache.spark.streaming.scheduler.
StreamingListenerEvent
)
org.apache.spark.streaming.scheduler.
StreamingListenerBatchStarted
(implements scala.Product, scala.Serializable, org.apache.spark.streaming.scheduler.
StreamingListenerEvent
)
org.apache.spark.streaming.scheduler.
StreamingListenerBatchSubmitted
(implements scala.Product, scala.Serializable, org.apache.spark.streaming.scheduler.
StreamingListenerEvent
)
org.apache.spark.streaming.scheduler.
StreamingListenerOutputOperationCompleted
(implements scala.Product, scala.Serializable, org.apache.spark.streaming.scheduler.
StreamingListenerEvent
)
org.apache.spark.streaming.scheduler.
StreamingListenerOutputOperationStarted
(implements scala.Product, scala.Serializable, org.apache.spark.streaming.scheduler.
StreamingListenerEvent
)
org.apache.spark.streaming.scheduler.
StreamingListenerReceiverError
(implements scala.Product, scala.Serializable, org.apache.spark.streaming.scheduler.
StreamingListenerEvent
)
org.apache.spark.streaming.scheduler.
StreamingListenerReceiverStarted
(implements scala.Product, scala.Serializable, org.apache.spark.streaming.scheduler.
StreamingListenerEvent
)
org.apache.spark.streaming.scheduler.
StreamingListenerReceiverStopped
(implements scala.Product, scala.Serializable, org.apache.spark.streaming.scheduler.
StreamingListenerEvent
)
org.apache.spark.streaming.scheduler.
StreamingListenerStreamingStarted
(implements scala.Product, scala.Serializable, org.apache.spark.streaming.scheduler.
StreamingListenerEvent
)
org.apache.spark.sql.streaming.
StreamingQueryListener
org.apache.spark.sql.streaming.
StreamingQueryListener.QueryProgressEvent
(implements org.apache.spark.sql.streaming.
StreamingQueryListener.Event
)
org.apache.spark.sql.streaming.
StreamingQueryListener.QueryStartedEvent
(implements org.apache.spark.sql.streaming.
StreamingQueryListener.Event
)
org.apache.spark.sql.streaming.
StreamingQueryListener.QueryTerminatedEvent
(implements org.apache.spark.sql.streaming.
StreamingQueryListener.Event
)
org.apache.spark.sql.streaming.
StreamingQueryManager
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.sql.streaming.
StreamingQueryProgress
(implements scala.Serializable)
org.apache.spark.sql.streaming.
StreamingQueryStatus
(implements scala.Serializable)
org.apache.spark.status.api.v1.streaming.
StreamingStatistics
org.apache.spark.mllib.stat.test.
StreamingTest
(implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.streaming.scheduler.
StreamInputInfo
(implements scala.Product, scala.Serializable)
org.apache.spark.graphx.lib.
StronglyConnectedComponents
org.apache.spark.sql.types.
StructField
(implements scala.Product, scala.Serializable)
org.apache.spark.mllib.stat.test.
StudentTTest
org.apache.spark.
Success
org.apache.spark.graphx.lib.
SVDPlusPlus
org.apache.spark.graphx.lib.
SVDPlusPlus.Conf
(implements scala.Serializable)
org.apache.spark.mllib.util.
SVMDataGenerator
org.apache.spark.sql.catalog.
Table
(implements org.apache.spark.sql.catalyst.DefinedByConstructorParams)
org.apache.spark.
TaskCommitDenied
(implements scala.Product, scala.Serializable, org.apache.spark.
TaskFailedReason
)
org.apache.spark.
TaskContext
(implements java.io.Serializable)
org.apache.spark.status.api.v1.
TaskData
org.apache.spark.ui.jobs.
TaskDetailsClassNames
org.apache.spark.scheduler.
TaskInfo
org.apache.spark.
TaskKilled
(implements scala.Product, scala.Serializable, org.apache.spark.
TaskFailedReason
)
org.apache.spark.scheduler.
TaskLocality
org.apache.spark.status.api.v1.
TaskMetricDistributions
org.apache.spark.status.api.v1.
TaskMetrics
org.apache.spark.
TaskResultLost
org.apache.spark.
TaskSchedulerIsSet
org.apache.spark.
TaskState
org.apache.spark.
TestUtils
Thread (implements Runnable)
org.apache.spark.sql.hive.execution.
ScriptTransformationWriterThread
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.util.
ThreadUtils
Throwable (implements java.io.Serializable)
Exception
org.apache.spark.sql.
AnalysisException
(implements scala.Serializable)
org.apache.spark.storage.
BlockNotFoundException
org.apache.spark.util.sketch.
IncompatibleMergeException
RuntimeException
org.apache.spark.
TaskKilledException
org.apache.spark.
SparkException
org.apache.spark.sql.streaming.
StreamingQueryException
org.apache.spark.streaming.
Time
(implements scala.Product, scala.Serializable)
org.apache.spark.ui.
ToolTips
org.apache.spark.storage.
TopologyMapper
org.apache.spark.storage.
DefaultTopologyMapper
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.storage.
FileBasedTopologyMapper
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.sql.catalyst.trees.TreeNode<BaseType> (implements scala.Product)
org.apache.spark.sql.catalyst.plans.QueryPlan<PlanType>
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan (implements org.apache.spark.internal.
Logging
)
org.apache.spark.sql.catalyst.plans.logical.LeafNode
org.apache.spark.sql.hive.execution.
CreateHiveTableAsSelectCommand
(implements scala.Product, org.apache.spark.sql.execution.command.RunnableCommand, scala.Serializable)
org.apache.spark.sql.hive.execution.
InsertIntoHiveTable
(implements scala.Product, org.apache.spark.sql.execution.command.RunnableCommand, scala.Serializable)
org.apache.spark.sql.execution.SparkPlan (implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.sql.hive.execution.
ScriptTransformationExec
(implements scala.Product, scala.Serializable, org.apache.spark.sql.execution.UnaryExecNode)
org.apache.spark.graphx.lib.
TriangleCount
org.apache.spark.sql.streaming.
Trigger
org.apache.spark.sql.streaming.
ProcessingTime
(implements scala.Product, scala.Serializable)
org.apache.spark.graphx.
TripletFields
(implements java.io.Serializable)
org.apache.spark.sql.expressions.javalang.
typed
org.apache.spark.sql.expressions.scalalang.
typed
org.apache.spark.sql.
UDFRegistration
(implements org.apache.spark.internal.
Logging
)
org.apache.spark.sql.types.
UDTRegistration
org.apache.spark.ui.jobs.
UIData
org.apache.spark.ui.jobs.
UIData.ExecutorSummary
org.apache.spark.ui.jobs.
UIData.InputMetricsUIData
(implements scala.Product, scala.Serializable)
org.apache.spark.ui.jobs.
UIData.InputMetricsUIData$
(implements scala.Serializable)
org.apache.spark.ui.jobs.
UIData.JobUIData
org.apache.spark.ui.jobs.
UIData.JobUIData$
org.apache.spark.ui.jobs.
UIData.OutputMetricsUIData
(implements scala.Product, scala.Serializable)
org.apache.spark.ui.jobs.
UIData.OutputMetricsUIData$
(implements scala.Serializable)
org.apache.spark.ui.jobs.
UIData.ShuffleReadMetricsUIData
(implements scala.Product, scala.Serializable)
org.apache.spark.ui.jobs.
UIData.ShuffleReadMetricsUIData$
(implements scala.Serializable)
org.apache.spark.ui.jobs.
UIData.ShuffleWriteMetricsUIData
(implements scala.Product, scala.Serializable)
org.apache.spark.ui.jobs.
UIData.ShuffleWriteMetricsUIData$
(implements scala.Serializable)
org.apache.spark.ui.jobs.
UIData.StageUIData
org.apache.spark.ui.jobs.
UIData.TaskMetricsUIData
(implements scala.Product, scala.Serializable)
org.apache.spark.ui.jobs.
UIData.TaskMetricsUIData$
(implements scala.Serializable)
org.apache.spark.ui.jobs.
UIData.TaskUIData
org.apache.spark.ui.jobs.
UIData.TaskUIData$
org.apache.spark.status.api.v1.
UIRootFromServletContext
org.apache.spark.ui.
UIUtils
org.apache.spark.streaming.ui.
UIUtils
org.apache.spark.ui.
UIWorkloadGenerator
org.apache.spark.mllib.random.
UniformGenerator
(implements org.apache.spark.mllib.random.
RandomDataGenerator
<T>)
org.apache.spark.
UnknownReason
org.apache.spark.ml.attribute.
UnresolvedAttribute
org.apache.spark.mllib.optimization.
Updater
(implements scala.Serializable)
org.apache.spark.mllib.optimization.
L1Updater
org.apache.spark.mllib.optimization.
SimpleUpdater
org.apache.spark.mllib.optimization.
SquaredL2Updater
org.apache.spark.sql.expressions.
UserDefinedAggregateFunction
(implements scala.Serializable)
org.apache.spark.sql.expressions.
UserDefinedFunction
(implements scala.Product, scala.Serializable)
org.apache.spark.util.
Utils
org.apache.spark.ml.impl.
Utils
org.apache.spark.mllib.tree.impurity.
Variance
org.apache.spark.mllib.linalg.
VectorImplicits
org.apache.spark.ml.linalg.
Vectors
org.apache.spark.mllib.linalg.
Vectors
org.apache.spark.status.api.v1.
VersionInfo
org.apache.spark.util.
VersionUtils
org.apache.spark.mllib.feature.
VocabWord
(implements scala.Product, scala.Serializable)
org.apache.spark.mllib.random.
WeibullGenerator
(implements org.apache.spark.mllib.random.
RandomDataGenerator
<T>)
org.apache.spark.mllib.stat.test.
WelchTTest
org.apache.spark.sql.expressions.
Window
org.apache.spark.sql.expressions.
WindowSpec
org.apache.spark.mllib.feature.
Word2Vec
(implements org.apache.spark.internal.
Logging
, scala.Serializable)
org.apache.spark.mllib.feature.
Word2VecModel
(implements org.apache.spark.mllib.util.
Saveable
, scala.Serializable)
org.apache.spark.ml.feature.
Word2VecModel.Word2VecModelWriter$
org.apache.spark.streaming.util.
WriteAheadLog
org.apache.spark.streaming.util.
WriteAheadLogRecordHandle
(implements java.io.Serializable)
org.apache.spark.streaming.util.
WriteAheadLogUtils
kafka.utils.ZKConfig
kafka.consumer.ConsumerConfig
org.apache.spark.streaming.kafka.
KafkaCluster.SimpleConsumerConfig
Interface Hierarchy
scala.concurrent.Awaitable<T>
scala.concurrent.Future<T>
org.apache.spark.
FutureAction
<T>
org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerMaster
org.apache.spark.storage.
BlockManagerMessages.ToBlockManagerSlave
org.apache.spark.storage.
BlockReplicationPolicy
org.apache.spark.sql.sources.
CatalystScan
org.apache.spark.
CleanupTask
Cloneable
scala.Cloneable
org.apache.spark.util.random.
RandomSampler
<T,U> (also extends org.apache.spark.util.random.
Pseudorandom
, scala.Serializable)
org.apache.spark.scheduler.cluster.
CoarseGrainedClusterMessages.RegisterExecutorResponse
org.apache.spark.io.
CompressionCodec
org.apache.spark.sql.sources.
CreatableRelationProvider
org.apache.spark.sql.sources.
DataSourceRegister
java.util.EventListener
org.apache.spark.util.
TaskCompletionListener
org.apache.spark.util.
TaskFailureListener
java.util.concurrent.Future<V>
org.apache.spark.api.java.
JavaFutureAction
<T>
org.apache.spark.security.
GroupMappingServiceProvider
org.apache.spark.streaming.kafka.
HasOffsetRanges
org.apache.spark.ml.util.
Identifiable
org.apache.spark.ml.param.
Params
(also extends scala.Serializable)
org.apache.spark.sql.sources.
InsertableRelation
org.apache.spark.scheduler.
JobResult
org.apache.spark.
JobSubmitter
org.apache.spark.serializer.
KryoRegistrator
org.apache.spark.mllib.clustering.
LDAOptimizer
org.apache.spark.mllib.util.
Loader
<M>
org.apache.spark.internal.
Logging
org.apache.spark.sql.catalyst.plans.logical.LogicalGroupState<S>
org.apache.spark.sql.streaming.
GroupState
<S>
org.apache.spark.sql.
LowPrioritySQLImplicits
org.apache.spark.storage.memory.
MemoryEntry
<T>
org.apache.spark.ml.util.
MLReadable
<T>
org.apache.spark.ml.util.
DefaultParamsReadable
<T>
org.apache.spark.ml.util.
MLWritable
org.apache.spark.ml.util.
DefaultParamsWritable
org.apache.spark.mllib.stat.
MultivariateStatisticalSummary
org.apache.spark.rdd.
PartitionCoalescer
org.apache.spark.mllib.pmml.
PMMLExportable
org.apache.spark.sql.sources.
PrunedFilteredScan
org.apache.spark.sql.sources.
PrunedScan
org.apache.spark.util.random.
Pseudorandom
org.apache.spark.mllib.random.
RandomDataGenerator
<T> (also extends scala.Serializable)
org.apache.spark.util.random.
RandomSampler
<T,U> (also extends scala.Cloneable, scala.Serializable)
org.apache.spark.sql.util.
QueryExecutionListener
org.apache.spark.sql.sources.
RelationProvider
org.apache.spark.mllib.util.
Saveable
org.apache.spark.sql.sources.
SchemaRelationProvider
java.io.Serializable
org.apache.spark.
AccumulableParam
<R,T>
org.apache.spark.
AccumulatorParam
<T>
org.apache.spark.api.java.function.
CoGroupFunction
<K,V1,V2,R>
org.apache.spark.api.java.function.
DoubleFlatMapFunction
<T>
org.apache.spark.api.java.function.
DoubleFunction
<T>
org.apache.spark.api.java.function.
FilterFunction
<T>
org.apache.spark.api.java.function.
FlatMapFunction
<T,R>
org.apache.spark.api.java.function.
FlatMapFunction2
<T1,T2,R>
org.apache.spark.api.java.function.
FlatMapGroupsFunction
<K,V,R>
org.apache.spark.api.java.function.
FlatMapGroupsWithStateFunction
<K,V,S,R>
org.apache.spark.api.java.function.
ForeachFunction
<T>
org.apache.spark.api.java.function.
ForeachPartitionFunction
<T>
org.apache.spark.api.java.function.
Function
<T1,R>
org.apache.spark.api.java.function.
Function0
<R>
org.apache.spark.api.java.function.
Function2
<T1,T2,R>
org.apache.spark.api.java.function.
Function3
<T1,T2,T3,R>
org.apache.spark.api.java.function.
Function4
<T1,T2,T3,T4,R>
org.apache.spark.api.java.function.
MapFunction
<T,U>
org.apache.spark.api.java.function.
MapGroupsFunction
<K,V,R>
org.apache.spark.api.java.function.
MapGroupsWithStateFunction
<K,V,S,R>
org.apache.spark.api.java.function.
MapPartitionsFunction
<T,U>
org.apache.spark.api.java.function.
PairFlatMapFunction
<T,K,V>
org.apache.spark.api.java.function.
PairFunction
<T,K,V>
org.apache.spark.api.java.function.
ReduceFunction
<T>
scala.Serializable
org.apache.spark.mllib.classification.
ClassificationModel
org.apache.spark.mllib.linalg.distributed.
DistributedMatrix
org.apache.spark.sql.
Encoder
<T>
org.apache.spark.mllib.tree.impurity.
Impurity
org.apache.spark.streaming.api.java.
JavaDStreamLike
<T,This,R>
org.apache.spark.api.java.
JavaRDDLike
<T,This>
org.apache.spark.rdd.
JdbcRDD.ConnectionFactory
org.apache.spark.ml.classification.
LogisticRegressionSummary
org.apache.spark.ml.classification.
LogisticRegressionTrainingSummary
org.apache.spark.mllib.tree.loss.
Loss
org.apache.spark.ml.linalg.
Matrix
org.apache.spark.mllib.linalg.
Matrix
org.apache.spark.mllib.optimization.
Optimizer
org.apache.spark.scheduler.
OutputCommitCoordinationMessage
org.apache.spark.ml.param.
Params
(also extends org.apache.spark.ml.util.
Identifiable
)
org.apache.spark.
Partition
org.apache.spark.graphx.
PartitionStrategy
org.apache.spark.mllib.random.
RandomDataGenerator
<T> (also extends org.apache.spark.util.random.
Pseudorandom
)
org.apache.spark.util.random.
RandomSampler
<T,U> (also extends scala.Cloneable, org.apache.spark.util.random.
Pseudorandom
)
org.apache.spark.mllib.regression.
RegressionModel
org.apache.spark.sql.
Row
org.apache.spark.ml.tree.
Split
org.apache.spark.ml.linalg.
Vector
org.apache.spark.mllib.linalg.
Vector
org.apache.spark.mllib.feature.
VectorTransformer
org.apache.spark.
SparkExecutorInfo
org.apache.spark.
SparkJobInfo
org.apache.spark.
SparkStageInfo
org.apache.spark.sql.api.java.
UDF1
<T1,R>
org.apache.spark.sql.api.java.
UDF10
<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,R>
org.apache.spark.sql.api.java.
UDF11
<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,R>
org.apache.spark.sql.api.java.
UDF12
<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,R>
org.apache.spark.sql.api.java.
UDF13
<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,R>
org.apache.spark.sql.api.java.
UDF14
<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,R>
org.apache.spark.sql.api.java.
UDF15
<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,R>
org.apache.spark.sql.api.java.
UDF16
<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,R>
org.apache.spark.sql.api.java.
UDF17
<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,R>
org.apache.spark.sql.api.java.
UDF18
<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,R>
org.apache.spark.sql.api.java.
UDF19
<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,R>
org.apache.spark.sql.api.java.
UDF2
<T1,T2,R>
org.apache.spark.sql.api.java.
UDF20
<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,R>
org.apache.spark.sql.api.java.
UDF21
<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,R>
org.apache.spark.sql.api.java.
UDF22
<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,R>
org.apache.spark.sql.api.java.
UDF3
<T1,T2,T3,R>
org.apache.spark.sql.api.java.
UDF4
<T1,T2,T3,T4,R>
org.apache.spark.sql.api.java.
UDF5
<T1,T2,T3,T4,T5,R>
org.apache.spark.sql.api.java.
UDF6
<T1,T2,T3,T4,T5,T6,R>
org.apache.spark.sql.api.java.
UDF7
<T1,T2,T3,T4,T5,T6,T7,R>
org.apache.spark.sql.api.java.
UDF8
<T1,T2,T3,T4,T5,T6,T7,T8,R>
org.apache.spark.sql.api.java.
UDF9
<T1,T2,T3,T4,T5,T6,T7,T8,T9,R>
org.apache.spark.api.java.function.
VoidFunction
<T>
org.apache.spark.api.java.function.
VoidFunction2
<T1,T2>
org.apache.spark.launcher.
SparkAppHandle
org.apache.spark.launcher.
SparkAppHandle.Listener
org.apache.spark.scheduler.
SparkListenerEvent
org.apache.spark.sql.streaming.
StreamingQueryListener.Event
org.apache.spark.streaming.scheduler.
StreamingListener
org.apache.spark.streaming.scheduler.
StreamingListenerEvent
org.apache.spark.sql.streaming.
StreamingQuery
org.apache.spark.sql.sources.
StreamSinkProvider
org.apache.spark.sql.sources.
StreamSourceProvider
org.apache.spark.sql.sources.
TableScan
org.apache.spark.
TaskEndReason
org.apache.spark.
TaskFailedReason
org.apache.spark.mllib.stat.test.
TestResult
<DF>
Annotation Type Hierarchy
org.apache.spark.sql.types.
SQLUserDefinedType
(implements java.lang.annotation.Annotation)
Enum Hierarchy
Object
Enum<E> (implements Comparable<T>, java.io.Serializable)
org.apache.spark.util.sketch.
BloomFilter.Version
org.apache.spark.util.sketch.
CountMinSketch.Version
org.apache.spark.
JobExecutionStatus
org.apache.spark.status.api.v1.
ApplicationStatus
org.apache.spark.status.api.v1.
StageStatus
org.apache.spark.status.api.v1.
TaskSorting
org.apache.spark.graphx.impl.
EdgeActiveness
org.apache.spark.launcher.
SparkAppHandle.State
org.apache.spark.sql.
SaveMode
org.apache.spark.status.api.v1.streaming.
BatchStatus
org.apache.spark.streaming.
StreamingContextState
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes