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.sink,
• 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.image,
• 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.image,
• 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.sources.v2,
• org.apache.spark.sql.sources.v2.reader,
• org.apache.spark.sql.sources.v2.reader.partitioning,
• org.apache.spark.sql.sources.v2.reader.streaming,
• org.apache.spark.sql.sources.v2.writer,
• org.apache.spark.sql.sources.v2.writer.streaming,
• org.apache.spark.sql.streaming,
• org.apache.spark.sql.types,
• org.apache.spark.sql.util,
• org.apache.spark.sql.vectorized,
• org.apache.spark.status,
• 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.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.jobs,
• org.apache.spark.ui.storage,
• org.apache.spark.util,
• org.apache.spark.util.kvstore,
• 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.GetLocationsAndStatus$ (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.mllib.feature.ChiSqSelectorModel.SaveLoadV1_0$.Data$ (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)
    • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.UpdateDelegationTokens$ (implements scala.Serializable)
  • scala.runtime.AbstractFunction2<T1,T2,R> (implements scala.Function2<T1,T2,R>)
    • org.apache.spark.storage.BlockManagerMessages.BlockLocationsAndStatus$ (implements scala.Serializable)
    • 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.mllib.regression.impl.GLMRegressionModel.SaveLoadV1_0$.Data$ (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.scheduler.cluster.CoarseGrainedClusterMessages.RemoveWorker$ (implements scala.Serializable)
    • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.SparkAppConfig$ (implements scala.Serializable)
    • org.apache.spark.mllib.classification.impl.GLMClassificationModel.SaveLoadV1_0$.Data$ (implements scala.Serializable)
    • org.apache.spark.mllib.classification.NaiveBayesModel.SaveLoadV1_0$.Data$ (implements scala.Serializable)
    • org.apache.spark.ml.evaluation.SquaredEuclideanSilhouette.ClusterStats$ (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)
    • org.apache.spark.mllib.classification.NaiveBayesModel.SaveLoadV2_0$.Data$ (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)
  • org.apache.spark.launcher.AbstractLauncher<T>
    • org.apache.spark.launcher.InProcessLauncher
    • org.apache.spark.launcher.SparkLauncher
  • 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.network.util.AbstractFileRegion (implements io.netty.channel.FileRegion)
      • org.apache.spark.storage.ReadableChannelFileRegion
  • 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.ui.jobs.ApiHelper
  • org.apache.spark.status.api.v1.ApplicationAttemptInfo (implements scala.Product, scala.Serializable)
  • org.apache.spark.status.api.v1.ApplicationEnvironmentInfo
  • org.apache.spark.status.api.v1.ApplicationInfo (implements scala.Product, scala.Serializable)
  • org.apache.spark.ml.ann.ApplyInPlace
  • org.apache.spark.status.AppStatusUtils
  • org.apache.spark.mllib.evaluation.AreaUnderCurve
  • org.apache.spark.sql.catalyst.util.ArrayData (implements scala.Serializable, org.apache.spark.sql.catalyst.expressions.SpecializedGetters)
    • org.apache.spark.sql.vectorized.ColumnarArray
  • 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.scheduler.AsyncEventQueue (implements org.apache.spark.internal.Logging)
  • 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.BarrierTaskInfo
  • 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.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.mllib.clustering.BisectingKMeansModel.SaveLoadV2_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.BlockLocationsAndStatus (implements scala.Product, scala.Serializable)
  • 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.GetLocationsAndStatus (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.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.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
  • io.netty.channel.ChannelHandlerAdapter (implements io.netty.channel.ChannelHandler)
    • io.netty.channel.ChannelInboundHandlerAdapter (implements io.netty.channel.ChannelInboundHandler)
      • io.netty.channel.SimpleChannelInboundHandler<I>
        • org.apache.spark.api.r.RBackendAuthHandler (implements org.apache.spark.internal.Logging)
  • 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
  • ClassLoader
    • org.apache.spark.util.ParentClassLoader
    • java.security.SecureClassLoader
      • java.net.URLClassLoader (implements java.io.Closeable)
        • org.apache.spark.util.MutableURLClassLoader
          • org.apache.spark.util.ChildFirstURLClassLoader
  • org.apache.xbean.asm6.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.ClusterData (implements scala.Product, scala.Serializable)
  • org.apache.spark.sql.sources.v2.reader.partitioning.ClusteredDistribution (implements org.apache.spark.sql.sources.v2.reader.partitioning.Distribution)
  • 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.RemoveWorker (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.scheduler.cluster.CoarseGrainedClusterMessages.UpdateDelegationTokens (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.sql.vectorized.ColumnarBatch
  • org.apache.spark.sql.vectorized.ColumnVector (implements AutoCloseable)
    • org.apache.spark.sql.vectorized.ArrowColumnVector
  • org.apache.spark.ComplexFutureAction<T> (implements org.apache.spark.FutureAction<T>)
  • org.apache.spark.status.config
  • 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.hadoop.conf.Configured (implements org.apache.hadoop.conf.Configurable)
    • org.apache.spark.ml.image.SamplePathFilter (implements org.apache.hadoop.fs.PathFilter)
  • org.apache.spark.graphx.lib.ConnectedComponents
  • org.apache.spark.ContextBarrierId (implements scala.Product, scala.Serializable)
  • 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.ml.evaluation.CosineSilhouette
  • 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.ml.util.DatasetUtils
  • org.apache.spark.sql.sources.v2.DataSourceOptions
  • 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$.NodeData$ (implements 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$.PredictData$ (implements scala.Serializable)
  • org.apache.spark.mllib.tree.model.DecisionTreeModel.SaveLoadV1_0$.SplitData (implements scala.Product, scala.Serializable)
  • org.apache.spark.mllib.tree.model.DecisionTreeModel.SaveLoadV1_0$.SplitData$ (implements 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.storage.memory.DeserializedValuesHolder<T> (implements org.apache.spark.storage.memory.ValuesHolder<T>)
  • org.apache.spark.rdd.DeterministicLevel
  • org.apache.spark.storage.DiskBlockData
  • 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.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.param.shared.HasLabelCol, org.apache.spark.ml.param.shared.HasRawPredictionCol)
    • org.apache.spark.ml.evaluation.ClusteringEvaluator (implements org.apache.spark.ml.util.DefaultParamsWritable, org.apache.spark.ml.param.shared.HasFeaturesCol, org.apache.spark.ml.param.shared.HasPredictionCol)
    • org.apache.spark.ml.evaluation.MulticlassClassificationEvaluator (implements org.apache.spark.ml.util.DefaultParamsWritable, org.apache.spark.ml.param.shared.HasLabelCol, org.apache.spark.ml.param.shared.HasPredictionCol)
    • org.apache.spark.ml.evaluation.RegressionEvaluator (implements org.apache.spark.ml.util.DefaultParamsWritable, org.apache.spark.ml.param.shared.HasLabelCol, org.apache.spark.ml.param.shared.HasPredictionCol)
  • 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.ui.storage.ExecutorStreamSummary
  • 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.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.HadoopMapRedCommitProtocol
  • 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.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.internal.io.HadoopWriteConfigUtil<K,V> (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.ml.source.image.ImageDataSource
  • org.apache.spark.ml.image.ImageSchema
  • 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.util.kvstore.InMemoryStore (implements org.apache.spark.util.kvstore.KVStore)
  • 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
    • org.apache.spark.io.NioBufferedFileInputStream
    • org.apache.spark.io.ReadAheadInputStream
  • 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.ml.clustering.InternalKMeansModelWriter (implements org.apache.spark.ml.util.MLFormatRegister, org.apache.spark.ml.util.MLWriterFormat)
  • org.apache.spark.ml.regression.InternalLinearRegressionModelWriter (implements org.apache.spark.ml.util.MLFormatRegister, org.apache.spark.ml.util.MLWriterFormat)
  • org.apache.spark.sql.catalyst.InternalRow (implements scala.Serializable, org.apache.spark.sql.catalyst.expressions.SpecializedGetters)
    • org.apache.spark.sql.vectorized.ColumnarRow
  • 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.ml.linalg.JsonMatrixConverter
  • org.apache.spark.util.JsonProtocol
  • org.apache.spark.ml.linalg.JsonVectorConverter
  • 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.KinesisInitialPositions
  • org.apache.spark.streaming.kinesis.KinesisInitialPositions.AtTimestamp (implements java.io.Serializable)
  • org.apache.spark.streaming.kinesis.KinesisInitialPositions.Latest (implements java.io.Serializable)
  • org.apache.spark.streaming.kinesis.KinesisInitialPositions.TrimHorizon (implements java.io.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.clustering.KMeansModel.SaveLoadV2_0$
  • org.apache.spark.ml.stat.KolmogorovSmirnovTest
  • 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.util.kvstore.KVStoreSerializer
  • org.apache.spark.util.kvstore.KVStoreView<T> (implements Iterable<T>)
  • org.apache.spark.util.kvstore.KVTypeInfo
  • org.apache.spark.status.KVUtils
  • 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.util.kvstore.LevelDB (implements org.apache.spark.util.kvstore.KVStore)
  • org.apache.spark.util.kvstore.LevelDB.TypeAliases
  • 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.status.LiveEntityHelpers
  • org.apache.spark.status.LiveExecutor
  • org.apache.spark.status.LiveExecutorStageSummary
  • org.apache.spark.status.LiveJob
  • org.apache.spark.status.LiveRDD
  • org.apache.spark.status.LiveRDDDistribution
  • org.apache.spark.status.LiveRDDPartition
  • org.apache.spark.status.LiveStage
  • org.apache.spark.status.LiveTask
  • org.apache.spark.mllib.clustering.LocalKMeans
  • org.apache.spark.mllib.util.LogisticRegressionDataGenerator
  • org.apache.spark.ml.classification.LogisticRegressionSummaryImpl (implements org.apache.spark.ml.classification.LogisticRegressionSummary)
    • org.apache.spark.ml.classification.BinaryLogisticRegressionSummaryImpl (implements org.apache.spark.ml.classification.BinaryLogisticRegressionSummary)
      • org.apache.spark.ml.classification.BinaryLogisticRegressionTrainingSummaryImpl (implements org.apache.spark.ml.classification.BinaryLogisticRegressionTrainingSummary)
    • org.apache.spark.ml.classification.LogisticRegressionTrainingSummaryImpl (implements org.apache.spark.ml.classification.LogisticRegressionTrainingSummary)
  • 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.sql.catalyst.util.MapData (implements scala.Serializable)
    • org.apache.spark.sql.vectorized.ColumnarMap
  • 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.ml.tuning.CrossValidatorModel.CrossValidatorModelWriter
    • org.apache.spark.ml.util.GeneralMLWriter (implements org.apache.spark.internal.Logging)
    • org.apache.spark.ml.tuning.TrainValidationSplitModel.TrainValidationSplitModelWriter
  • 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.sql.execution.streaming.Offset
    • org.apache.spark.sql.sources.v2.reader.streaming.Offset
  • org.apache.spark.ml.feature.OneHotEncoderCommon
  • org.apache.spark.mllib.clustering.OnlineLDAOptimizer (implements org.apache.spark.mllib.clustering.LDAOptimizer, org.apache.spark.internal.Logging)
  • 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.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.DoubleArrayArrayParam
    • 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.feature.PCAUtil
  • 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 (implements org.apache.spark.ml.param.shared.HasSeed)
      • 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.ml.param.shared.HasCollectSubModels, 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 (implements org.apache.spark.ml.param.shared.HasSeed)
      • org.apache.spark.ml.feature.MinMaxScaler (implements org.apache.spark.ml.util.DefaultParamsWritable)
      • org.apache.spark.ml.feature.OneHotEncoderEstimator (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.MultilayerPerceptronClassifier (implements org.apache.spark.ml.util.DefaultParamsWritable)
            • 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.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.param.shared.HasInputCols, org.apache.spark.ml.param.shared.HasOutputCols)
      • 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.ml.param.shared.HasCollectSubModels, 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.param.shared.HasInputCol, org.apache.spark.ml.param.shared.HasOutputCol)
      • org.apache.spark.ml.feature.ColumnPruner (implements org.apache.spark.ml.util.MLWritable)
      • org.apache.spark.ml.feature.FeatureHasher (implements org.apache.spark.ml.util.DefaultParamsWritable, org.apache.spark.ml.param.shared.HasInputCols, org.apache.spark.ml.param.shared.HasOutputCol)
      • org.apache.spark.ml.feature.HashingTF (implements org.apache.spark.ml.util.DefaultParamsWritable, org.apache.spark.ml.param.shared.HasInputCol, org.apache.spark.ml.param.shared.HasOutputCol)
      • org.apache.spark.ml.feature.IndexToString (implements org.apache.spark.ml.util.DefaultParamsWritable, org.apache.spark.ml.param.shared.HasInputCol, org.apache.spark.ml.param.shared.HasOutputCol)
      • org.apache.spark.ml.feature.Interaction (implements org.apache.spark.ml.util.DefaultParamsWritable, org.apache.spark.ml.param.shared.HasInputCols, org.apache.spark.ml.param.shared.HasOutputCol)
      • 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.param.shared.HasHandleInvalid, org.apache.spark.ml.param.shared.HasInputCol, org.apache.spark.ml.param.shared.HasInputCols, org.apache.spark.ml.param.shared.HasOutputCol, org.apache.spark.ml.param.shared.HasOutputCols)
        • 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.GeneralMLWritable)
        • 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.feature.OneHotEncoderModel (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.MultilayerPerceptronClassificationModel (implements org.apache.spark.ml.util.MLWritable, scala.Serializable)
              • 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.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.GeneralMLWritable)
        • 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.param.shared.HasInputCol, org.apache.spark.ml.param.shared.HasOutputCol)
      • 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.param.shared.HasInputCol, org.apache.spark.ml.param.shared.HasOutputCol)
      • org.apache.spark.ml.UnaryTransformer<IN,OUT,T> (implements org.apache.spark.ml.param.shared.HasInputCol, org.apache.spark.ml.param.shared.HasOutputCol, 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.param.shared.HasHandleInvalid, org.apache.spark.ml.param.shared.HasInputCols, org.apache.spark.ml.param.shared.HasOutputCol)
      • org.apache.spark.ml.feature.VectorAttributeRewriter (implements org.apache.spark.ml.util.MLWritable)
      • org.apache.spark.ml.feature.VectorSizeHint (implements org.apache.spark.ml.util.DefaultParamsWritable, org.apache.spark.ml.param.shared.HasHandleInvalid, org.apache.spark.ml.param.shared.HasInputCol)
      • org.apache.spark.ml.feature.VectorSlicer (implements org.apache.spark.ml.util.DefaultParamsWritable, org.apache.spark.ml.param.shared.HasInputCol, org.apache.spark.ml.param.shared.HasOutputCol)
  • org.apache.spark.ml.clustering.PMMLKMeansModelWriter (implements org.apache.spark.ml.util.MLFormatRegister, org.apache.spark.ml.util.MLWriterFormat)
  • org.apache.spark.ml.regression.PMMLLinearRegressionModelWriter (implements org.apache.spark.ml.util.MLFormatRegister, org.apache.spark.ml.util.MLWriterFormat)
  • 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.ml.clustering.PowerIterationClustering (implements org.apache.spark.ml.util.DefaultParamsWritable)
  • 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.ml.fpm.PrefixSpan (implements org.apache.spark.ml.param.Params)
  • 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.rdd.RDDBarrier<T>
  • 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.RDDPartitionSeq (implements scala.collection.Seq<A>)
  • 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
  • org.apache.spark.ml.image.RecursiveFlag
  • 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.cluster.SchedulerBackendUtils
  • org.apache.spark.status.SchedulerPool
  • 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)
  • org.apache.spark.storage.memory.SerializedValuesHolder<T> (implements org.apache.spark.storage.memory.ValuesHolder<T>)
  • 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.ShuffleStatus
  • 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.mapred.SparkHadoopMapRedUtil
  • org.apache.spark.internal.io.SparkHadoopWriter
  • org.apache.spark.internal.io.SparkHadoopWriterUtils
  • org.apache.spark.SparkJobInfoImpl (implements org.apache.spark.SparkJobInfo)
  • org.apache.spark.scheduler.SparkListener
    • org.apache.spark.SpillListener
    • org.apache.spark.scheduler.StatsReportListener (implements org.apache.spark.internal.Logging)
  • 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.SparkListenerExecutorBlacklistedForStage (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.SparkListenerLogStart (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.SparkListenerNodeBlacklistedForStage (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.SparkListenerSpeculativeTaskSubmitted (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.sql.expressions.SparkUserDefinedFunction
  • 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.ml.evaluation.SquaredEuclideanSilhouette
  • org.apache.spark.ml.evaluation.SquaredEuclideanSilhouette.ClusterStats (implements scala.Product, scala.Serializable)
  • org.apache.spark.status.api.v1.StackTrace (implements scala.Product, scala.Serializable)
  • 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.metrics.sink.StatsdMetricType
  • 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.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.ml.stat.Summarizer
  • org.apache.spark.ml.stat.SummaryBuilder
  • 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.BarrierTaskContext (implements org.apache.spark.internal.Logging)
  • org.apache.spark.status.api.v1.TaskData
  • org.apache.spark.ui.jobs.TaskDetailsClassNames
  • org.apache.spark.status.TaskIndexNames
  • 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.sql.jdbc.TeradataDialect
  • org.apache.spark.TestUtils
  • Thread (implements Runnable)
    • org.apache.spark.sql.hive.execution.ScriptTransformationWriterThread (implements org.apache.spark.internal.Logging)
  • org.apache.spark.status.api.v1.ThreadStackTrace (implements scala.Product, scala.Serializable)
  • 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
      • java.io.IOException
        • org.apache.spark.util.kvstore.UnsupportedStoreVersionException
      • RuntimeException
        • org.apache.spark.TaskKilledException
      • org.apache.spark.SparkException
        • org.apache.spark.storage.UnrecognizedBlockId
      • 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.sql.catalyst.plans.logical.AnalysisHelper, org.apache.spark.internal.Logging, org.apache.spark.sql.catalyst.plans.logical.statsEstimation.LogicalPlanStats, org.apache.spark.sql.catalyst.plans.logical.QueryPlanConstraints)
        • org.apache.spark.sql.hive.execution.CreateHiveTableAsSelectCommand (implements org.apache.spark.sql.execution.command.DataWritingCommand, scala.Product, scala.Serializable)
        • org.apache.spark.sql.hive.execution.InsertIntoHiveDirCommand (implements scala.Product, scala.Serializable)
        • org.apache.spark.sql.hive.execution.InsertIntoHiveTable (implements scala.Product, 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.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
  • org.apache.spark.io.ZStdCompressionCodec (implements org.apache.spark.io.CompressionCodec)

Interface Hierarchy

• AutoCloseable
  • java.io.Closeable
    • org.apache.spark.sql.sources.v2.reader.InputPartitionReader<T>
      • org.apache.spark.sql.sources.v2.reader.streaming.ContinuousInputPartitionReader<T>
    • org.apache.spark.util.kvstore.KVStore
    • org.apache.spark.util.kvstore.KVStoreIterator<T> (also extends java.util.Iterator<E>)
• scala.concurrent.Awaitable<T>
  • scala.concurrent.Future<T>
    • org.apache.spark.FutureAction<T>
• org.apache.spark.sql.execution.streaming.BaseStreamingSink
  • org.apache.spark.sql.sources.v2.StreamWriteSupport (also extends org.apache.spark.sql.sources.v2.DataSourceV2)
• org.apache.spark.sql.execution.streaming.BaseStreamingSource
  • org.apache.spark.sql.sources.v2.reader.streaming.ContinuousReader (also extends org.apache.spark.sql.sources.v2.reader.DataSourceReader)
  • org.apache.spark.sql.sources.v2.reader.streaming.MicroBatchReader (also extends org.apache.spark.sql.sources.v2.reader.DataSourceReader)
• 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.v2.reader.DataSourceReader
  • org.apache.spark.sql.sources.v2.reader.streaming.ContinuousReader (also extends org.apache.spark.sql.execution.streaming.BaseStreamingSource)
  • org.apache.spark.sql.sources.v2.reader.streaming.MicroBatchReader (also extends org.apache.spark.sql.execution.streaming.BaseStreamingSource)
  • org.apache.spark.sql.sources.v2.reader.SupportsPushDownFilters
  • org.apache.spark.sql.sources.v2.reader.SupportsPushDownRequiredColumns
  • org.apache.spark.sql.sources.v2.reader.SupportsReportPartitioning
  • org.apache.spark.sql.sources.v2.reader.SupportsReportStatistics
  • org.apache.spark.sql.sources.v2.reader.SupportsScanColumnarBatch
• org.apache.spark.sql.sources.DataSourceRegister
• org.apache.spark.sql.sources.v2.DataSourceV2
  • org.apache.spark.sql.sources.v2.ContinuousReadSupport
  • org.apache.spark.sql.sources.v2.MicroBatchReadSupport
  • org.apache.spark.sql.sources.v2.ReadSupport
  • org.apache.spark.sql.sources.v2.SessionConfigSupport
  • org.apache.spark.sql.sources.v2.StreamWriteSupport (also extends org.apache.spark.sql.execution.streaming.BaseStreamingSink)
  • org.apache.spark.sql.sources.v2.WriteSupport
• org.apache.spark.sql.sources.v2.writer.DataSourceWriter
  • org.apache.spark.sql.sources.v2.writer.streaming.StreamWriter
• org.apache.spark.sql.sources.v2.writer.DataWriter<T>
• org.apache.spark.sql.sources.v2.reader.partitioning.Distribution
• java.util.EventListener
  • org.apache.spark.util.TaskCompletionListener
  • org.apache.spark.util.TaskFailureListener
• org.apache.spark.ExecutorPlugin
• java.util.concurrent.Future<V>
  • org.apache.spark.api.java.JavaFutureAction<T>
• org.apache.spark.security.GroupMappingServiceProvider
• org.apache.spark.ml.util.Identifiable
  • org.apache.spark.ml.param.shared.HasAggregationDepth
  • org.apache.spark.ml.param.shared.HasCheckpointInterval
  • org.apache.spark.ml.param.shared.HasCollectSubModels
  • org.apache.spark.ml.param.shared.HasDistanceMeasure
  • org.apache.spark.ml.param.shared.HasElasticNetParam
  • org.apache.spark.ml.param.shared.HasFeaturesCol
  • org.apache.spark.ml.param.shared.HasFitIntercept
  • org.apache.spark.ml.param.shared.HasHandleInvalid
  • org.apache.spark.ml.param.shared.HasInputCol
  • org.apache.spark.ml.param.shared.HasInputCols
  • org.apache.spark.ml.param.shared.HasLabelCol
  • org.apache.spark.ml.param.shared.HasLoss
  • org.apache.spark.ml.param.shared.HasMaxIter
  • org.apache.spark.ml.param.shared.HasOutputCol
  • org.apache.spark.ml.param.shared.HasOutputCols
  • org.apache.spark.ml.param.shared.HasPredictionCol
  • org.apache.spark.ml.param.shared.HasProbabilityCol
  • org.apache.spark.ml.param.shared.HasRawPredictionCol
  • org.apache.spark.ml.param.shared.HasRegParam
  • org.apache.spark.ml.param.shared.HasSeed
  • org.apache.spark.ml.param.shared.HasSolver
  • org.apache.spark.ml.param.shared.HasStandardization
  • org.apache.spark.ml.param.shared.HasStepSize
  • org.apache.spark.ml.param.shared.HasThreshold
  • org.apache.spark.ml.param.shared.HasThresholds
  • org.apache.spark.ml.param.shared.HasTol
  • org.apache.spark.ml.param.shared.HasValidationIndicatorCol
  • org.apache.spark.ml.param.shared.HasVarianceCol
  • org.apache.spark.ml.param.shared.HasWeightCol
  • org.apache.spark.ml.param.Params (also extends scala.Serializable)
    • org.apache.spark.ml.param.shared.HasAggregationDepth
    • org.apache.spark.ml.param.shared.HasCheckpointInterval
    • org.apache.spark.ml.param.shared.HasCollectSubModels
    • org.apache.spark.ml.param.shared.HasDistanceMeasure
    • org.apache.spark.ml.param.shared.HasElasticNetParam
    • org.apache.spark.ml.param.shared.HasFeaturesCol
    • org.apache.spark.ml.param.shared.HasFitIntercept
    • org.apache.spark.ml.param.shared.HasHandleInvalid
    • org.apache.spark.ml.param.shared.HasInputCol
    • org.apache.spark.ml.param.shared.HasInputCols
    • org.apache.spark.ml.param.shared.HasLabelCol
    • org.apache.spark.ml.param.shared.HasLoss
    • org.apache.spark.ml.param.shared.HasMaxIter
    • org.apache.spark.ml.param.shared.HasOutputCol
    • org.apache.spark.ml.param.shared.HasOutputCols
    • org.apache.spark.ml.param.shared.HasPredictionCol
    • org.apache.spark.ml.param.shared.HasProbabilityCol
    • org.apache.spark.ml.param.shared.HasRawPredictionCol
    • org.apache.spark.ml.param.shared.HasRegParam
    • org.apache.spark.ml.param.shared.HasSeed
    • org.apache.spark.ml.param.shared.HasSolver
    • org.apache.spark.ml.param.shared.HasStandardization
    • org.apache.spark.ml.param.shared.HasStepSize
    • org.apache.spark.ml.param.shared.HasThreshold
    • org.apache.spark.ml.param.shared.HasThresholds
    • org.apache.spark.ml.param.shared.HasTol
    • org.apache.spark.ml.param.shared.HasValidationIndicatorCol
    • org.apache.spark.ml.param.shared.HasVarianceCol
    • org.apache.spark.ml.param.shared.HasWeightCol
• org.apache.spark.sql.sources.InsertableRelation
• java.util.Iterator<E>
  • org.apache.spark.util.kvstore.KVStoreIterator<T> (also extends java.io.Closeable)
• 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.storage.memory.MemoryEntryBuilder<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.ml.util.GeneralMLWritable
• org.apache.spark.ml.util.MLWriterFormat
  • org.apache.spark.ml.util.MLFormatRegister
• org.apache.spark.mllib.stat.MultivariateStatisticalSummary
• org.apache.spark.rdd.PartitionCoalescer
• org.apache.spark.sql.sources.v2.reader.partitioning.Partitioning
• 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.sql.sources.v2.writer.DataWriterFactory<T>
  • 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.sql.sources.v2.reader.InputPartition<T>
    • org.apache.spark.sql.sources.v2.reader.ContinuousInputPartition<T>
  • 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.sql.sources.v2.reader.streaming.PartitionOffset
  • 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.BinaryLogisticRegressionSummary
        • org.apache.spark.ml.classification.BinaryLogisticRegressionTrainingSummary (also extends org.apache.spark.ml.classification.LogisticRegressionTrainingSummary)
      • org.apache.spark.ml.classification.BinaryLogisticRegressionTrainingSummary (also extends org.apache.spark.ml.classification.BinaryLogisticRegressionSummary, org.apache.spark.ml.classification.LogisticRegressionTrainingSummary)
      • org.apache.spark.ml.classification.LogisticRegressionTrainingSummary
        • org.apache.spark.ml.classification.BinaryLogisticRegressionTrainingSummary (also extends org.apache.spark.ml.classification.BinaryLogisticRegressionSummary)
    • 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.ml.param.shared.HasAggregationDepth
      • org.apache.spark.ml.param.shared.HasCheckpointInterval
      • org.apache.spark.ml.param.shared.HasCollectSubModels
      • org.apache.spark.ml.param.shared.HasDistanceMeasure
      • org.apache.spark.ml.param.shared.HasElasticNetParam
      • org.apache.spark.ml.param.shared.HasFeaturesCol
      • org.apache.spark.ml.param.shared.HasFitIntercept
      • org.apache.spark.ml.param.shared.HasHandleInvalid
      • org.apache.spark.ml.param.shared.HasInputCol
      • org.apache.spark.ml.param.shared.HasInputCols
      • org.apache.spark.ml.param.shared.HasLabelCol
      • org.apache.spark.ml.param.shared.HasLoss
      • org.apache.spark.ml.param.shared.HasMaxIter
      • org.apache.spark.ml.param.shared.HasOutputCol
      • org.apache.spark.ml.param.shared.HasOutputCols
      • org.apache.spark.ml.param.shared.HasPredictionCol
      • org.apache.spark.ml.param.shared.HasProbabilityCol
      • org.apache.spark.ml.param.shared.HasRawPredictionCol
      • org.apache.spark.ml.param.shared.HasRegParam
      • org.apache.spark.ml.param.shared.HasSeed
      • org.apache.spark.ml.param.shared.HasSolver
      • org.apache.spark.ml.param.shared.HasStandardization
      • org.apache.spark.ml.param.shared.HasStepSize
      • org.apache.spark.ml.param.shared.HasThreshold
      • org.apache.spark.ml.param.shared.HasThresholds
      • org.apache.spark.ml.param.shared.HasTol
      • org.apache.spark.ml.param.shared.HasValidationIndicatorCol
      • org.apache.spark.ml.param.shared.HasVarianceCol
      • org.apache.spark.ml.param.shared.HasWeightCol
    • 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.UDF0<R>
  • 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.sql.sources.v2.writer.WriterCommitMessage
• 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.sql.sources.v2.reader.Statistics
• 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>
• org.apache.spark.storage.memory.ValuesHolder<T>

Annotation Type Hierarchy

• org.apache.spark.util.kvstore.KVIndex (implements java.lang.annotation.Annotation)
• 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.status.api.v1.ApplicationStatus
    • org.apache.spark.status.api.v1.streaming.BatchStatus
    • org.apache.spark.util.sketch.BloomFilter.Version
    • org.apache.spark.util.sketch.CountMinSketch.Version
    • org.apache.spark.graphx.impl.EdgeActiveness
    • org.apache.spark.JobExecutionStatus
    • org.apache.spark.sql.SaveMode
    • org.apache.spark.launcher.SparkAppHandle.State
    • org.apache.spark.status.api.v1.StageStatus
    • org.apache.spark.streaming.StreamingContextState
    • org.apache.spark.status.api.v1.TaskSorting