Hierarchy For All Packages

Package Hierarchies:

• org.apache.spark,
• org.apache.spark.annotation,
• org.apache.spark.api.java,
• org.apache.spark.api.java.function,
• org.apache.spark.api.r,
• org.apache.spark.broadcast,
• org.apache.spark.examples.streaming,
• 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.io,
• org.apache.spark.launcher,
• org.apache.spark.ml,
• org.apache.spark.ml.attribute,
• org.apache.spark.ml.classification,
• org.apache.spark.ml.evaluation,
• org.apache.spark.ml.feature,
• org.apache.spark.ml.param,
• org.apache.spark.ml.recommendation,
• org.apache.spark.ml.regression,
• org.apache.spark.ml.tree,
• org.apache.spark.ml.tuning,
• org.apache.spark.mllib.classification,
• org.apache.spark.mllib.clustering,
• org.apache.spark.mllib.evaluation,
• 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.random,
• org.apache.spark.mllib.rdd,
• org.apache.spark.mllib.recommendation,
• org.apache.spark.mllib.regression,
• org.apache.spark.mllib.stat,
• 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.scheduler,
• org.apache.spark.scheduler.cluster,
• org.apache.spark.scheduler.local,
• org.apache.spark.serializer,
• org.apache.spark.sql,
• org.apache.spark.sql.api.java,
• org.apache.spark.sql.expressions,
• org.apache.spark.sql.hive,
• org.apache.spark.sql.jdbc,
• org.apache.spark.sql.json,
• org.apache.spark.sql.sources,
• org.apache.spark.sql.test,
• org.apache.spark.sql.types,
• org.apache.spark.status.api.v1,
• org.apache.spark.storage,
• org.apache.spark.streaming,
• org.apache.spark.streaming.api.java,
• org.apache.spark.streaming.dstream,
• org.apache.spark.streaming.flume,
• org.apache.spark.streaming.kafka,
• org.apache.spark.streaming.kinesis,
• org.apache.spark.streaming.mqtt,
• org.apache.spark.streaming.receiver,
• org.apache.spark.streaming.scheduler,
• org.apache.spark.streaming.twitter,
• org.apache.spark.streaming.ui,
• org.apache.spark.streaming.util,
• org.apache.spark.streaming.zeromq,
• org.apache.spark.ui.env,
• org.apache.spark.ui.exec,
• org.apache.spark.ui.jobs,
• org.apache.spark.ui.storage,
• org.apache.spark.util,
• org.apache.spark.util.random

Class Hierarchy

• Object
  • org.apache.spark.mllib.tree.loss.AbsoluteError (implements org.apache.spark.mllib.tree.loss.Loss)
  • scala.runtime.AbstractFunction2<T1,T2,R> (implements scala.Function2<T1,T2,R>)
    • org.apache.spark.mllib.clustering.PowerIterationClustering.Assignment$ (implements scala.Serializable)
  • org.apache.spark.Accumulable<R,T> (implements java.io.Serializable)
    • org.apache.spark.Accumulator<T>
  • org.apache.spark.scheduler.AccumulableInfo
  • org.apache.spark.status.api.v1.AccumulableInfo
  • 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.streaming.receiver.ActorSupervisorStrategy
  • org.apache.spark.Aggregator<K,V,C> (implements scala.Product, scala.Serializable)
  • org.apache.spark.mllib.recommendation.ALS (implements org.apache.spark.Logging, 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.status.api.v1.ApplicationAttemptInfo
  • org.apache.spark.status.api.v1.ApplicationInfo
  • org.apache.spark.scheduler.AskPermissionToCommitOutput (implements scala.Product, scala.Serializable)
  • org.apache.spark.rdd.AsyncRDDActions<T> (implements org.apache.spark.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.UnresolvedAttribute
  • org.apache.spark.ml.attribute.AttributeGroup (implements scala.Serializable)
  • org.apache.spark.ml.attribute.AttributeType
  • org.apache.spark.sql.sources.BaseRelation
    • org.apache.spark.sql.sources.HadoopFsRelation
  • 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.Logging)
  • 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.mllib.linalg.distributed.BlockMatrix (implements org.apache.spark.mllib.linalg.distributed.DistributedMatrix, org.apache.spark.Logging)
  • org.apache.spark.storage.BlockStatus (implements scala.Product, scala.Serializable)
  • org.apache.spark.mllib.tree.configuration.BoostingStrategy (implements scala.Product, scala.Serializable)
  • org.apache.spark.partial.BoundedDouble
  • org.apache.spark.broadcast.Broadcast<T> (implements org.apache.spark.Logging, java.io.Serializable)
  • org.apache.spark.streaming.kafka.Broker (implements scala.Serializable)
  • org.apache.spark.ml.tree.CategoricalSplit (implements org.apache.spark.ml.tree.Split)
  • org.apache.spark.mllib.feature.ChiSqSelector (implements scala.Serializable)
  • org.apache.spark.mllib.feature.ChiSqSelectorModel (implements org.apache.spark.mllib.feature.VectorTransformer)
  • org.apache.spark.mllib.stat.test.ChiSqTestResult (implements org.apache.spark.mllib.stat.test.TestResult<DF>)
  • com.esotericsoftware.reflectasm.shaded.org.objectweb.asm.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.sql.Column (implements org.apache.spark.Logging)
    • org.apache.spark.sql.ColumnName
  • org.apache.spark.ComplexFutureAction<T> (implements org.apache.spark.FutureAction<T>)
  • org.apache.spark.graphx.lib.ConnectedComponents
  • org.apache.spark.ml.tree.ContinuousSplit (implements org.apache.spark.ml.tree.Split)
  • org.apache.spark.mllib.linalg.distributed.CoordinateMatrix (implements org.apache.spark.mllib.linalg.distributed.DistributedMatrix)
  • org.apache.spark.sql.DataFrame (implements scala.Serializable)
  • org.apache.spark.sql.DataFrameNaFunctions
  • org.apache.spark.sql.DataFrameReader
  • org.apache.spark.sql.DataFrameStatFunctions
  • org.apache.spark.sql.DataFrameWriter
  • 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.DateType
    • 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.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.UserDefinedType<UserType> (implements scala.Serializable)
  • org.apache.spark.sql.types.DataTypes
  • org.apache.spark.mllib.util.DataValidators (implements org.apache.spark.Logging)
  • org.apache.spark.sql.types.Decimal (implements scala.math.Ordered<A>, scala.Serializable)
  • org.apache.spark.mllib.tree.DecisionTree (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.mllib.tree.model.DecisionTreeModel (implements org.apache.spark.mllib.util.Saveable, scala.Serializable)
  • org.apache.spark.mllib.linalg.DenseMatrix (implements org.apache.spark.mllib.linalg.Matrix)
  • 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.serializer.DeserializationStream
  • org.apache.spark.rdd.DoubleRDDFunctions (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.streaming.dstream.DStream<T> (implements org.apache.spark.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.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.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.mllib.tree.impurity.Entropy (implements org.apache.spark.mllib.tree.impurity.Impurity)
  • scala.Enumeration (implements scala.Serializable)
    • org.apache.spark.mllib.tree.configuration.Algo
    • org.apache.spark.mllib.tree.configuration.FeatureType
    • org.apache.spark.mllib.tree.configuration.QuantileStrategy
    • org.apache.spark.scheduler.SchedulingMode
    • org.apache.spark.scheduler.TaskLocality
  • org.apache.spark.util.EnumUtil
  • org.apache.spark.ui.env.EnvironmentListener (implements org.apache.spark.scheduler.SparkListener)
  • org.apache.spark.ml.evaluation.Evaluator (implements org.apache.spark.ml.param.Params)
    • org.apache.spark.ml.evaluation.BinaryClassificationEvaluator
    • org.apache.spark.ml.evaluation.RegressionEvaluator
  • org.apache.spark.ExceptionFailure (implements scala.Product, scala.Serializable, org.apache.spark.TaskFailedReason)
  • org.apache.spark.scheduler.cluster.ExecutorInfo
  • org.apache.spark.ExecutorLostFailure (implements scala.Product, scala.Serializable, org.apache.spark.TaskFailedReason)
  • org.apache.spark.ui.exec.ExecutorsListener (implements org.apache.spark.scheduler.SparkListener)
  • org.apache.spark.status.api.v1.ExecutorStageSummary
  • org.apache.spark.status.api.v1.ExecutorSummary
  • org.apache.spark.mllib.clustering.ExpectationSum (implements scala.Serializable)
  • org.apache.spark.sql.ExperimentalMethods
  • org.apache.spark.mllib.random.ExponentialGenerator (implements org.apache.spark.mllib.random.RandomDataGenerator<T>)
  • org.apache.spark.FetchFailed (implements scala.Product, scala.Serializable, org.apache.spark.TaskFailedReason)
  • org.apache.spark.sql.sources.Filter
    • org.apache.spark.sql.sources.And (implements scala.Product, scala.Serializable)
    • org.apache.spark.sql.sources.EqualTo (implements scala.Product, scala.Serializable)
    • org.apache.spark.sql.sources.GreaterThan (implements scala.Product, scala.Serializable)
    • org.apache.spark.sql.sources.GreaterThanOrEqual (implements scala.Product, scala.Serializable)
    • org.apache.spark.sql.sources.In (implements scala.Product, scala.Serializable)
    • org.apache.spark.sql.sources.IsNotNull (implements scala.Product, scala.Serializable)
    • org.apache.spark.sql.sources.IsNull (implements scala.Product, scala.Serializable)
    • org.apache.spark.sql.sources.LessThan (implements scala.Product, scala.Serializable)
    • org.apache.spark.sql.sources.LessThanOrEqual (implements scala.Product, scala.Serializable)
    • org.apache.spark.sql.sources.Not (implements scala.Product, scala.Serializable)
    • org.apache.spark.sql.sources.Or (implements scala.Product, scala.Serializable)
    • org.apache.spark.sql.sources.StringContains (implements scala.Product, scala.Serializable)
    • org.apache.spark.sql.sources.StringEndsWith (implements scala.Product, scala.Serializable)
    • org.apache.spark.sql.sources.StringStartsWith (implements scala.Product, scala.Serializable)
  • org.apache.spark.streaming.flume.FlumeUtils
  • org.apache.spark.mllib.fpm.FPGrowth (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.mllib.fpm.FPGrowth.FreqItemset<Item> (implements scala.Serializable)
  • org.apache.spark.mllib.fpm.FPGrowthModel<Item> (implements scala.Serializable)
  • 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.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.mllib.tree.impurity.Gini (implements org.apache.spark.mllib.tree.impurity.Impurity)
  • 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.mllib.tree.GradientBoostedTrees (implements org.apache.spark.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.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.GraphKryoRegistrator (implements org.apache.spark.serializer.KryoRegistrator)
  • org.apache.spark.graphx.GraphLoader (implements org.apache.spark.Logging)
  • org.apache.spark.graphx.GraphOps<VD,ED> (implements scala.Serializable)
  • org.apache.spark.graphx.GraphXUtils
  • org.apache.spark.sql.GroupedData
  • org.apache.spark.mllib.feature.HashingTF (implements scala.Serializable)
  • org.apache.spark.broadcast.HttpBroadcastFactory (implements org.apache.spark.broadcast.BroadcastFactory)
  • org.apache.spark.mllib.feature.IDF
  • org.apache.spark.mllib.feature.IDF.DocumentFrequencyAggregator (implements scala.Serializable)
  • org.apache.spark.mllib.feature.IDFModel (implements scala.Serializable)
  • org.apache.spark.mllib.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.scheduler.InputFormatInfo (implements org.apache.spark.Logging)
  • org.apache.spark.status.api.v1.InputMetricDistributions
  • org.apache.spark.status.api.v1.InputMetrics
  • org.apache.spark.InterruptibleIterator<T> (implements scala.collection.Iterator<A>)
  • 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.sql.json.JacksonUtils
  • 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.examples.streaming.JavaKinesisWordCountASL
  • 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.JavaSparkListener (implements org.apache.spark.scheduler.SparkListener)
  • org.apache.spark.api.java.JavaSparkStatusTracker
  • org.apache.spark.streaming.api.java.JavaStreamingContext (implements java.io.Closeable)
  • org.apache.spark.sql.jdbc.JdbcDialect
    • org.apache.spark.sql.jdbc.AggregatedDialect
    • org.apache.spark.sql.jdbc.MySQLDialect (implements scala.Product, scala.Serializable)
    • org.apache.spark.sql.jdbc.NoopDialect (implements scala.Product, scala.Serializable)
    • org.apache.spark.sql.jdbc.PostgresDialect (implements scala.Product, scala.Serializable)
  • org.apache.spark.sql.jdbc.JdbcDialects
  • org.apache.spark.sql.jdbc.JdbcType (implements scala.Product, scala.Serializable)
  • org.apache.spark.status.api.v1.JobData
  • org.apache.spark.scheduler.JobLogger (implements org.apache.spark.Logging, org.apache.spark.scheduler.SparkListener)
  • org.apache.spark.ui.jobs.JobProgressListener (implements org.apache.spark.Logging, org.apache.spark.scheduler.SparkListener)
  • org.apache.spark.scheduler.JobSucceeded (implements org.apache.spark.scheduler.JobResult, scala.Product, scala.Serializable)
  • org.apache.spark.streaming.kafka.KafkaTestUtils (implements org.apache.spark.Logging)
  • org.apache.spark.streaming.kafka.KafkaUtils
  • org.apache.spark.streaming.kafka.KafkaUtilsPythonHelper
  • org.apache.spark.mllib.stat.KernelDensity (implements scala.Serializable)
  • org.apache.spark.scheduler.local.KillTask (implements scala.Product, scala.Serializable)
  • org.apache.spark.streaming.kinesis.KinesisUtils
  • org.apache.spark.examples.streaming.KinesisWordCountASL (implements org.apache.spark.Logging)
  • org.apache.spark.examples.streaming.KinesisWordProducerASL
  • org.apache.spark.mllib.clustering.KMeans (implements org.apache.spark.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.Logging)
  • 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.Logging, org.apache.spark.mllib.optimization.Optimizer)
  • org.apache.spark.mllib.clustering.LDA (implements org.apache.spark.Logging)
  • org.apache.spark.mllib.clustering.LDAModel
    • org.apache.spark.mllib.clustering.DistributedLDAModel
    • org.apache.spark.mllib.clustering.LocalLDAModel (implements scala.Serializable)
  • org.apache.spark.ml.regression.LeastSquaresAggregator (implements scala.Serializable)
  • org.apache.spark.ml.regression.LeastSquaresCostFun (implements breeze.optimize.DiffFunction<T>)
  • org.apache.spark.mllib.util.LinearDataGenerator
  • org.apache.spark.ml.classification.LogisticAggregator (implements scala.Serializable)
  • org.apache.spark.ml.classification.LogisticCostFun (implements breeze.optimize.DiffFunction<T>)
  • org.apache.spark.mllib.util.LogisticRegressionDataGenerator
  • org.apache.spark.mllib.tree.loss.LogLoss (implements org.apache.spark.mllib.tree.loss.Loss)
  • org.apache.spark.mllib.random.LogNormalGenerator (implements org.apache.spark.mllib.random.RandomDataGenerator<T>)
  • org.apache.spark.mllib.tree.loss.Losses
  • 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.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.Logging, org.apache.spark.mllib.util.Saveable, scala.Serializable)
  • org.apache.spark.storage.MemoryEntry (implements scala.Product, scala.Serializable)
  • org.apache.spark.sql.types.Metadata (implements scala.Serializable)
  • org.apache.spark.sql.types.MetadataBuilder
  • 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.mllib.util.MLUtils
  • org.apache.spark.streaming.mqtt.MQTTUtils
  • org.apache.spark.mllib.evaluation.MulticlassMetrics
  • org.apache.spark.mllib.evaluation.MultilabelMetrics
  • 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.util.MutablePair<T1,T2> (implements scala.Product, scala.Product2<T1,T2>, scala.Serializable)
  • org.apache.spark.mllib.classification.NaiveBayes (implements org.apache.spark.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.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.Logging, scala.Serializable)
  • org.apache.spark.mllib.feature.Normalizer (implements org.apache.spark.mllib.feature.VectorTransformer)
  • org.apache.spark.streaming.kafka.OffsetRange (implements scala.Serializable)
  • org.apache.spark.mllib.clustering.OnlineLDAOptimizer (implements org.apache.spark.mllib.clustering.LDAOptimizer)
  • org.apache.spark.rdd.OrderedRDDFunctions<K,V,P> (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.status.api.v1.OutputMetricDistributions
  • org.apache.spark.status.api.v1.OutputMetrics
  • java.io.OutputStream (implements java.io.Closeable, java.io.Flushable)
    • org.apache.spark.io.SnappyOutputStreamWrapper
    • org.apache.spark.storage.TimeTrackingOutputStream
  • org.apache.spark.sql.sources.OutputWriter
  • org.apache.spark.sql.sources.OutputWriterFactory (implements scala.Serializable)
  • org.apache.spark.graphx.lib.PageRank (implements org.apache.spark.Logging)
  • org.apache.spark.streaming.dstream.PairDStreamFunctions<K,V> (implements scala.Serializable)
  • org.apache.spark.rdd.PairRDDFunctions<K,V> (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.ml.param.Param<T> (implements scala.Serializable)
    • org.apache.spark.ml.param.BooleanParam
    • org.apache.spark.ml.param.DoubleArrayParam
    • org.apache.spark.ml.param.DoubleParam
    • org.apache.spark.ml.param.FloatParam
    • org.apache.spark.ml.param.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.rdd.PartitionCoalescer
  • org.apache.spark.rdd.PartitionCoalescer.LocationIterator (implements scala.collection.Iterator<A>)
  • org.apache.spark.Partitioner (implements scala.Serializable)
    • org.apache.spark.HashPartitioner
    • org.apache.spark.RangePartitioner<K,V>
  • org.apache.spark.rdd.PartitionGroup (implements scala.Product, scala.Serializable)
  • 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.ml.PipelineStage (implements org.apache.spark.Logging, org.apache.spark.ml.param.Params)
    • org.apache.spark.ml.Estimator<M>
      • org.apache.spark.ml.recommendation.ALS
      • org.apache.spark.ml.tuning.CrossValidator (implements org.apache.spark.Logging)
      • org.apache.spark.ml.feature.IDF
      • org.apache.spark.ml.classification.OneVsRest
      • org.apache.spark.ml.Pipeline
      • org.apache.spark.ml.Predictor<FeaturesType,Learner,M>
        • org.apache.spark.ml.classification.Classifier<FeaturesType,E,M>
          • org.apache.spark.ml.classification.LogisticRegression (implements org.apache.spark.Logging)
        • org.apache.spark.ml.classification.DecisionTreeClassifier
        • org.apache.spark.ml.regression.DecisionTreeRegressor
        • org.apache.spark.ml.classification.GBTClassifier (implements org.apache.spark.Logging)
        • org.apache.spark.ml.regression.GBTRegressor (implements org.apache.spark.Logging)
        • org.apache.spark.ml.regression.LinearRegression (implements org.apache.spark.Logging)
        • org.apache.spark.ml.classification.RandomForestClassifier
        • org.apache.spark.ml.regression.RandomForestRegressor
      • org.apache.spark.ml.feature.StandardScaler
      • org.apache.spark.ml.feature.StringIndexer
      • org.apache.spark.ml.feature.VectorIndexer
      • org.apache.spark.ml.feature.Word2Vec
    • org.apache.spark.ml.Transformer
      • org.apache.spark.ml.feature.Binarizer
      • org.apache.spark.ml.feature.HashingTF
      • org.apache.spark.ml.Model<M>
        • org.apache.spark.ml.recommendation.ALSModel
        • org.apache.spark.ml.feature.Bucketizer
        • org.apache.spark.ml.tuning.CrossValidatorModel
        • org.apache.spark.ml.feature.IDFModel
        • org.apache.spark.ml.classification.OneVsRestModel
        • org.apache.spark.ml.PipelineModel (implements org.apache.spark.Logging)
        • org.apache.spark.ml.PredictionModel<FeaturesType,M>
          • org.apache.spark.ml.classification.ClassificationModel<FeaturesType,M>
            • org.apache.spark.ml.classification.LogisticRegressionModel
          • org.apache.spark.ml.classification.DecisionTreeClassificationModel (implements scala.Serializable)
          • org.apache.spark.ml.regression.DecisionTreeRegressionModel (implements scala.Serializable)
          • org.apache.spark.ml.classification.GBTClassificationModel (implements scala.Serializable)
          • org.apache.spark.ml.regression.GBTRegressionModel (implements scala.Serializable)
          • org.apache.spark.ml.classification.RandomForestClassificationModel (implements scala.Serializable)
          • org.apache.spark.ml.regression.RandomForestRegressionModel (implements scala.Serializable)
          • org.apache.spark.ml.regression.RegressionModel<FeaturesType,M>
            • org.apache.spark.ml.regression.LinearRegressionModel
        • org.apache.spark.ml.feature.StandardScalerModel
        • org.apache.spark.ml.feature.StringIndexerModel
        • org.apache.spark.ml.feature.VectorIndexerModel
        • org.apache.spark.ml.feature.Word2VecModel
      • org.apache.spark.ml.feature.OneHotEncoder
      • org.apache.spark.ml.UnaryTransformer<IN,OUT,T> (implements org.apache.spark.Logging)
        • org.apache.spark.ml.feature.ElementwiseProduct
        • org.apache.spark.ml.feature.Normalizer
        • org.apache.spark.ml.feature.PolynomialExpansion
        • org.apache.spark.ml.feature.RegexTokenizer
        • org.apache.spark.ml.feature.Tokenizer
      • org.apache.spark.ml.feature.VectorAssembler
  • 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.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.sql.types.PrecisionInfo (implements scala.Product, scala.Serializable)
  • org.apache.spark.mllib.tree.model.Predict (implements scala.Serializable)
  • org.apache.spark.graphx.Pregel (implements org.apache.spark.Logging)
  • org.apache.spark.mllib.tree.RandomForest (implements org.apache.spark.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.Logging, scala.Serializable)
  • org.apache.spark.mllib.recommendation.Rating (implements scala.Product, scala.Serializable)
  • org.apache.spark.rdd.RDD<T> (implements org.apache.spark.Logging, scala.Serializable)
    • org.apache.spark.api.r.BaseRRDD<T,U> (implements org.apache.spark.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.Logging)
    • org.apache.spark.rdd.JdbcRDD<T> (implements org.apache.spark.Logging)
    • org.apache.spark.rdd.NewHadoopRDD<K,V> (implements org.apache.spark.Logging)
    • org.apache.spark.rdd.PartitionPruningRDD<T>
    • org.apache.spark.rdd.ShuffledRDD<K,V,C>
    • org.apache.spark.rdd.UnionRDD<T>
    • org.apache.spark.graphx.VertexRDD<VD>
      • org.apache.spark.graphx.impl.VertexRDDImpl<VD>
  • org.apache.spark.status.api.v1.RDDDataDistribution
  • org.apache.spark.mllib.rdd.RDDFunctions<T> (implements scala.Serializable)
  • org.apache.spark.storage.RDDInfo (implements scala.math.Ordered<A>)
  • org.apache.spark.status.api.v1.RDDPartitionInfo
  • org.apache.spark.status.api.v1.RDDStorageInfo
  • org.apache.spark.streaming.receiver.Receiver<T> (implements scala.Serializable)
  • org.apache.spark.streaming.scheduler.ReceiverInfo (implements scala.Product, scala.Serializable)
  • java.lang.ref.Reference<T>
    • java.lang.ref.WeakReference<T>
      • org.apache.spark.CleanupTaskWeakReference
  • org.apache.spark.mllib.evaluation.RegressionMetrics (implements org.apache.spark.Logging)
  • org.apache.spark.Resubmitted (implements scala.Product, scala.Serializable, org.apache.spark.TaskFailedReason)
  • org.apache.spark.scheduler.local.ReviveOffers (implements scala.Product, scala.Serializable)
  • org.apache.spark.sql.RowFactory
  • org.apache.spark.mllib.linalg.distributed.RowMatrix (implements org.apache.spark.mllib.linalg.distributed.DistributedMatrix, org.apache.spark.Logging)
  • org.apache.spark.util.RpcUtils
  • org.apache.spark.scheduler.RuntimePercentage (implements scala.Product, scala.Serializable)
  • org.apache.spark.streaming.Seconds
  • org.apache.spark.rdd.SequenceFileRDDFunctions<K,V> (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.SerializableWritable<T> (implements java.io.Serializable)
  • org.apache.spark.serializer.SerializationStream
  • 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.Logging, scala.Serializable)
  • org.apache.spark.serializer.SerializerInstance
  • org.apache.spark.graphx.lib.ShortestPaths
  • org.apache.spark.status.api.v1.ShuffleReadMetricDistributions
  • org.apache.spark.status.api.v1.ShuffleReadMetrics
  • org.apache.spark.status.api.v1.ShuffleWriteMetricDistributions
  • org.apache.spark.status.api.v1.ShuffleWriteMetrics
  • org.apache.spark.util.SignalLoggerHandler (implements sun.misc.SignalHandler)
  • 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.util.SizeEstimator (implements org.apache.spark.Logging)
  • org.apache.spark.io.SnappyCompressionCodec (implements org.apache.spark.io.CompressionCodec)
  • org.apache.spark.SparkConf (implements scala.Cloneable, org.apache.spark.Logging)
  • org.apache.spark.SparkContext (implements org.apache.spark.Logging)
  • org.apache.spark.SparkContext.DoubleAccumulatorParam$ (implements org.apache.spark.AccumulatorParam<T>)
  • org.apache.spark.SparkContext.FloatAccumulatorParam$ (implements org.apache.spark.AccumulatorParam<T>)
  • org.apache.spark.SparkContext.IntAccumulatorParam$ (implements org.apache.spark.AccumulatorParam<T>)
  • org.apache.spark.SparkContext.LongAccumulatorParam$ (implements org.apache.spark.AccumulatorParam<T>)
  • org.apache.spark.SparkEnv (implements org.apache.spark.Logging)
  • org.apache.spark.SparkFiles
  • org.apache.spark.SparkFirehoseListener (implements org.apache.spark.scheduler.SparkListener)
  • org.apache.spark.streaming.flume.SparkFlumeEvent (implements java.io.Externalizable)
  • org.apache.spark.streaming.ui.SparkJobIdWithUIData (implements scala.Product, scala.Serializable)
  • org.apache.spark.SparkJobInfoImpl (implements org.apache.spark.SparkJobInfo)
  • org.apache.spark.launcher.SparkLauncher
  • 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.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.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.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.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.util.SparkShutdownHook (implements Comparable<T>)
  • org.apache.spark.SparkStageInfoImpl (implements org.apache.spark.SparkStageInfo)
  • org.apache.spark.SparkStatusTracker
  • org.apache.spark.mllib.linalg.SparseMatrix (implements org.apache.spark.mllib.linalg.Matrix)
  • org.apache.spark.mllib.linalg.SparseVector (implements org.apache.spark.mllib.linalg.Vector)
  • 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.Logging, scala.Serializable)
    • org.apache.spark.sql.hive.HiveContext
    • org.apache.spark.sql.test.LocalSQLContext
      • org.apache.spark.sql.test.TestSQLContext
  • org.apache.spark.sql.SQLContext.implicits$ (implements scala.Serializable)
  • org.apache.spark.sql.SQLContext.implicits$.StringToColumn
  • org.apache.spark.mllib.tree.loss.SquaredError (implements org.apache.spark.mllib.tree.loss.Loss)
  • 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.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.mllib.stat.Statistics
  • org.apache.spark.streaming.receiver.Statistics (implements scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.StatsReportListener (implements org.apache.spark.Logging, org.apache.spark.scheduler.SparkListener)
  • 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.scheduler.StopCoordinator (implements org.apache.spark.scheduler.OutputCommitCoordinationMessage, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.local.StopExecutor (implements scala.Product, scala.Serializable)
  • org.apache.spark.storage.StorageLevel (implements java.io.Externalizable)
  • org.apache.spark.api.java.StorageLevels
  • org.apache.spark.ui.storage.StorageListener (implements org.apache.spark.scheduler.SparkListener)
  • org.apache.spark.storage.StorageStatus
  • org.apache.spark.storage.StorageStatusListener (implements org.apache.spark.scheduler.SparkListener)
  • org.apache.spark.mllib.tree.configuration.Strategy (implements scala.Serializable)
  • org.apache.spark.streaming.StreamingContext (implements org.apache.spark.Logging)
  • org.apache.spark.mllib.clustering.StreamingKMeans (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.mllib.regression.StreamingLinearAlgorithm<M,A> (implements org.apache.spark.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.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.graphx.lib.StronglyConnectedComponents
  • org.apache.spark.sql.types.StructField (implements scala.Product, scala.Serializable)
  • org.apache.spark.Success (implements scala.Product, scala.Serializable, org.apache.spark.TaskEndReason)
  • 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.TaskCommitDenied (implements scala.Product, scala.Serializable, org.apache.spark.TaskFailedReason)
  • org.apache.spark.TaskContext (implements java.io.Serializable)
  • org.apache.spark.status.api.v1.TaskData
  • org.apache.spark.scheduler.TaskInfo
  • org.apache.spark.TaskKilled (implements scala.Product, scala.Serializable, org.apache.spark.TaskFailedReason)
  • org.apache.spark.status.api.v1.TaskMetricDistributions
  • org.apache.spark.status.api.v1.TaskMetrics
  • org.apache.spark.TaskResultLost (implements scala.Product, scala.Serializable, org.apache.spark.TaskFailedReason)
  • Throwable (implements java.io.Serializable)
    • Exception
      • org.apache.spark.sql.AnalysisException (implements scala.Serializable)
      • org.apache.spark.storage.BlockNotFoundException
      • RuntimeException
        • org.apache.spark.TaskKilledException
      • org.apache.spark.SparkException
  • org.apache.spark.streaming.Time (implements scala.Product, scala.Serializable)
  • org.apache.spark.broadcast.TorrentBroadcastFactory (implements org.apache.spark.broadcast.BroadcastFactory)
  • org.apache.spark.graphx.lib.TriangleCount
  • org.apache.spark.graphx.TripletFields (implements java.io.Serializable)
  • org.apache.spark.streaming.twitter.TwitterUtils
  • org.apache.spark.sql.UDFRegistration (implements org.apache.spark.Logging)
  • org.apache.spark.mllib.random.UniformGenerator (implements org.apache.spark.mllib.random.RandomDataGenerator<T>)
  • org.apache.spark.UnknownReason (implements scala.Product, scala.Serializable, org.apache.spark.TaskFailedReason)
  • 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.UserDefinedFunction (implements scala.Product, scala.Serializable)
  • org.apache.spark.sql.types.UTF8String (implements scala.math.Ordered<A>, scala.Serializable)
  • org.apache.spark.mllib.tree.impurity.Variance (implements org.apache.spark.mllib.tree.impurity.Impurity)
  • org.apache.spark.util.Vector (implements scala.Serializable)
  • org.apache.spark.util.Vector.Multiplier
  • org.apache.spark.util.Vector.VectorAccumParam$ (implements org.apache.spark.AccumulatorParam<T>)
  • org.apache.spark.ml.feature.VectorIndexer.CategoryStats (implements scala.Serializable)
  • org.apache.spark.mllib.linalg.Vectors
  • org.apache.spark.mllib.feature.VocabWord (implements scala.Product, scala.Serializable)
  • org.apache.spark.sql.expressions.Window
  • org.apache.spark.sql.expressions.WindowSpec
  • org.apache.spark.mllib.feature.Word2Vec (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.mllib.feature.Word2VecModel (implements org.apache.spark.mllib.util.Saveable, scala.Serializable)
  • org.apache.spark.streaming.util.WriteAheadLog
  • org.apache.spark.streaming.util.WriteAheadLogRecordHandle (implements java.io.Serializable)
  • org.apache.spark.streaming.zeromq.ZeroMQUtils

Interface Hierarchy

• scala.concurrent.Awaitable<T>
  • scala.concurrent.Future<T>
    • org.apache.spark.FutureAction<T>
• org.apache.spark.broadcast.BroadcastFactory
• 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.io.CompressionCodec
• org.apache.spark.sql.sources.CreatableRelationProvider
• java.util.EventListener
  • org.apache.spark.util.TaskCompletionListener
• java.util.concurrent.Future<V>
  • org.apache.spark.api.java.JavaFutureAction<T>
• org.apache.spark.sql.sources.HadoopFsRelationProvider
• org.apache.spark.streaming.kafka.HasOffsetRanges
• org.apache.spark.sql.sources.InsertableRelation
• org.apache.spark.streaming.api.java.JavaStreamingContextFactory
• org.apache.spark.scheduler.JobResult
• org.apache.spark.serializer.KryoRegistrator
• org.apache.spark.mllib.clustering.LDAOptimizer
• org.apache.spark.mllib.util.Loader<M>
• org.apache.spark.Logging
  • org.apache.spark.streaming.receiver.ActorHelper
• org.apache.spark.mllib.stat.MultivariateStatisticalSummary
• 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.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.DoubleFlatMapFunction<T>
  • org.apache.spark.api.java.function.DoubleFunction<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.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.PairFlatMapFunction<T,K,V>
  • org.apache.spark.api.java.function.PairFunction<T,K,V>
  • scala.Serializable
    • org.apache.spark.mllib.classification.ClassificationModel
    • org.apache.spark.mllib.linalg.distributed.DistributedMatrix
    • 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.mllib.tree.loss.Loss
    • org.apache.spark.mllib.linalg.Matrix
    • org.apache.spark.mllib.optimization.Optimizer
    • org.apache.spark.scheduler.OutputCommitCoordinationMessage
    • org.apache.spark.ml.param.Params
    • 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.mllib.linalg.Vector
    • org.apache.spark.mllib.feature.VectorTransformer
  • org.apache.spark.SparkJobInfo
  • org.apache.spark.SparkStageInfo
  • org.apache.spark.sql.api.java.UDF1<T1,R>
  • org.apache.spark.sql.api.java.UDF10<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,R>
  • org.apache.spark.sql.api.java.UDF11<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,R>
  • org.apache.spark.sql.api.java.UDF12<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,R>
  • org.apache.spark.sql.api.java.UDF13<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,R>
  • org.apache.spark.sql.api.java.UDF14<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,R>
  • org.apache.spark.sql.api.java.UDF15<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,R>
  • org.apache.spark.sql.api.java.UDF16<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,R>
  • org.apache.spark.sql.api.java.UDF17<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,R>
  • org.apache.spark.sql.api.java.UDF18<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,R>
  • org.apache.spark.sql.api.java.UDF19<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,R>
  • org.apache.spark.sql.api.java.UDF2<T1,T2,R>
  • org.apache.spark.sql.api.java.UDF20<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,R>
  • org.apache.spark.sql.api.java.UDF21<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,R>
  • org.apache.spark.sql.api.java.UDF22<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,R>
  • org.apache.spark.sql.api.java.UDF3<T1,T2,T3,R>
  • org.apache.spark.sql.api.java.UDF4<T1,T2,T3,T4,R>
  • org.apache.spark.sql.api.java.UDF5<T1,T2,T3,T4,T5,R>
  • org.apache.spark.sql.api.java.UDF6<T1,T2,T3,T4,T5,T6,R>
  • org.apache.spark.sql.api.java.UDF7<T1,T2,T3,T4,T5,T6,T7,R>
  • org.apache.spark.sql.api.java.UDF8<T1,T2,T3,T4,T5,T6,T7,T8,R>
  • org.apache.spark.sql.api.java.UDF9<T1,T2,T3,T4,T5,T6,T7,T8,T9,R>
  • org.apache.spark.api.java.function.VoidFunction<T>
• org.apache.spark.scheduler.SparkListener
• org.apache.spark.scheduler.SparkListenerEvent
• org.apache.spark.streaming.scheduler.StreamingListener
• org.apache.spark.streaming.scheduler.StreamingListenerEvent
• org.apache.spark.sql.sources.TableScan
• org.apache.spark.TaskEndReason
  • org.apache.spark.TaskFailedReason
• org.apache.spark.mllib.stat.test.TestResult<DF>

Annotation Type Hierarchy

• org.apache.spark.annotation.AlphaComponent (implements java.lang.annotation.Annotation)
• org.apache.spark.annotation.DeveloperApi (implements java.lang.annotation.Annotation)
• org.apache.spark.annotation.Experimental (implements java.lang.annotation.Annotation)
• org.apache.spark.annotation.Private (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.JobExecutionStatus
    • org.apache.spark.status.api.v1.ApplicationStatus
    • org.apache.spark.status.api.v1.StageStatus
    • org.apache.spark.status.api.v1.TaskSorting
    • org.apache.spark.graphx.impl.EdgeActiveness
    • org.apache.spark.sql.SaveMode
    • org.apache.spark.streaming.StreamingContextState