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.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.mapred,
• org.apache.spark.mapreduce,
• org.apache.spark.metrics,
• org.apache.spark.metrics.sink,
• org.apache.spark.metrics.source,
• org.apache.spark.ml,
• org.apache.spark.ml.classification,
• org.apache.spark.ml.evaluation,
• org.apache.spark.ml.feature,
• org.apache.spark.ml.param,
• org.apache.spark.ml.tuning,
• org.apache.spark.mllib.classification,
• 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.linalg,
• org.apache.spark.mllib.linalg.distributed,
• org.apache.spark.mllib.optimization,
• 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.correlation,
• org.apache.spark.mllib.stat.test,
• org.apache.spark.mllib.tree,
• org.apache.spark.mllib.tree.configuration,
• org.apache.spark.mllib.tree.impl,
• 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.cluster.mesos,
• org.apache.spark.scheduler.local,
• org.apache.spark.serializer,
• org.apache.spark.sql,
• org.apache.spark.sql.api.java,
• org.apache.spark.sql.columnar,
• org.apache.spark.sql.columnar.compression,
• org.apache.spark.sql.execution,
• org.apache.spark.sql.execution.joins,
• org.apache.spark.sql.hive,
• org.apache.spark.sql.hive.api.java,
• org.apache.spark.sql.hive.execution,
• org.apache.spark.sql.hive.parquet,
• org.apache.spark.sql.hive.test,
• org.apache.spark.sql.json,
• org.apache.spark.sql.parquet,
• org.apache.spark.sql.sources,
• org.apache.spark.sql.test,
• org.apache.spark.sql.types.util,
• 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.rdd,
• 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,
• 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.io,
• org.apache.spark.util.logging,
• 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.AbstractFunction1<T1,R> (implements scala.Function1<T1,R>)
    • org.apache.spark.storage.BlockManagerMessages.BlockManagerHeartbeat$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.GetActorSystemHostPortForExecutor$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.GetLocations$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.GetLocationsMultipleBlockIds$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.GetPeers$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.RemoveBlock$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.RemoveExecutor$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.RemoveRdd$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.RemoveShuffle$ (implements scala.Serializable)
    • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.KillExecutors$ (implements scala.Serializable)
    • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.LaunchTask$ (implements scala.Serializable)
    • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RegisterExecutorFailed$ (implements scala.Serializable)
    • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RequestExecutors$ (implements scala.Serializable)
  • scala.runtime.AbstractFunction2<T1,T2,R> (implements scala.Function2<T1,T2,R>)
    • org.apache.spark.storage.BlockManagerMessages.GetBlockStatus$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.GetMatchingBlockIds$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.RemoveBroadcast$ (implements scala.Serializable)
    • org.apache.spark.mllib.stat.test.ChiSqTest.Method$ (implements scala.Serializable)
    • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RemoveExecutor$ (implements scala.Serializable)
    • org.apache.spark.storage.ShuffleBlockFetcherIterator.FailureFetchResult$ (implements scala.Serializable)
    • org.apache.spark.storage.ShuffleBlockFetcherIterator.FetchRequest$ (implements scala.Serializable)
  • scala.runtime.AbstractFunction3<T1,T2,T3,R> (implements scala.Function3<T1,T2,T3,R>)
    • org.apache.spark.sql.execution.Aggregate.ComputedAggregate$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.RegisterBlockManager$ (implements scala.Serializable)
    • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.AddWebUIFilter$ (implements scala.Serializable)
    • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.KillTask$ (implements scala.Serializable)
    • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RegisterExecutor$ (implements scala.Serializable)
    • org.apache.spark.storage.ShuffleBlockFetcherIterator.SuccessFetchResult$ (implements scala.Serializable)
    • org.apache.spark.ui.jobs.UIData.TaskUIData$ (implements scala.Serializable)
    • org.apache.spark.streaming.util.WriteAheadLogManager.LogInfo$ (implements scala.Serializable)
  • scala.runtime.AbstractFunction6<T1,T2,T3,T4,T5,T6,R> (implements scala.Function6<T1,T2,T3,T4,T5,T6,R>)
    • org.apache.spark.mllib.recommendation.ALS.BlockStats$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.UpdateBlockInfo$ (implements scala.Serializable)
  • org.apache.spark.streaming.api.java.AbstractJavaDStreamLike<T,This,R> (implements org.apache.spark.streaming.api.java.JavaDStreamLike<T,This,R>)
    • 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.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.AbstractJavaRDDLike<T,This> (implements org.apache.spark.api.java.JavaRDDLike<T,This>)
    • org.apache.spark.api.java.JavaDoubleRDD
    • 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.api.java.JavaRDD<T>
  • java.util.AbstractMap<K,V> (implements java.util.Map<K,V>)
    • org.apache.spark.api.java.JavaUtils.SerializableMapWrapper<A,B> (implements java.io.Serializable)
  • org.apache.spark.util.random.AcceptanceResult (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.Accumulators
  • org.apache.spark.scheduler.ActiveJob
  • org.apache.spark.streaming.receiver.ActorReceiver.Supervisor (implements akka.actor.Actor)
  • org.apache.spark.streaming.receiver.ActorSupervisorStrategy
  • org.apache.spark.streaming.scheduler.AddBlock (implements scala.Product, org.apache.spark.streaming.scheduler.ReceiverTrackerMessage, scala.Serializable)
  • org.apache.spark.sql.execution.Aggregate.ComputedAggregate (implements scala.Product, scala.Serializable)
  • org.apache.spark.sql.execution.AggregateEvaluation (implements scala.Product, scala.Serializable)
  • org.apache.spark.Aggregator<K,V,C> (implements scala.Product, scala.Serializable)
  • org.apache.spark.util.AkkaUtils (implements org.apache.spark.Logging)
  • org.apache.spark.scheduler.AllJobsCancelled (implements org.apache.spark.scheduler.DAGSchedulerEvent, scala.Product, scala.Serializable)
  • org.apache.spark.streaming.scheduler.AllocatedBlocks (implements scala.Product, scala.Serializable)
  • org.apache.spark.mllib.recommendation.ALS (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.mllib.recommendation.ALS.BlockStats (implements scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.ApplicationEventListener (implements org.apache.spark.scheduler.SparkListener)
  • org.apache.spark.partial.ApproximateActionListener<T,U,R> (implements org.apache.spark.scheduler.JobListener)
  • org.apache.spark.mllib.evaluation.AreaUnderCurve
  • org.apache.spark.streaming.receiver.ArrayBufferBlock (implements scala.Product, org.apache.spark.streaming.receiver.ReceivedBlock, scala.Serializable)
  • org.apache.spark.storage.ArrayValues (implements org.apache.spark.storage.BlockValues, scala.Product, scala.Serializable)
  • org.apache.spark.rdd.AsyncRDDActions<T> (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.mllib.tree.impl.BaggedPoint<Datum> (implements scala.Serializable)
  • org.apache.spark.sql.sources.BaseRelation
    • org.apache.spark.sql.sources.CatalystScan
      • org.apache.spark.sql.parquet.ParquetRelation2 (implements org.apache.spark.Logging, scala.Product, scala.Serializable)
    • org.apache.spark.sql.sources.PrunedFilteredScan
    • org.apache.spark.sql.sources.PrunedScan
    • org.apache.spark.sql.sources.TableScan
      • org.apache.spark.sql.json.JSONRelation (implements scala.Product, scala.Serializable)
  • org.apache.spark.sql.columnar.BasicColumnAccessor<T,JvmType> (implements org.apache.spark.sql.columnar.ColumnAccessor)
    • org.apache.spark.sql.columnar.BinaryColumnAccessor (implements org.apache.spark.sql.columnar.NullableColumnAccessor)
    • org.apache.spark.sql.columnar.GenericColumnAccessor (implements org.apache.spark.sql.columnar.NullableColumnAccessor)
    • org.apache.spark.sql.columnar.NativeColumnAccessor<T> (implements org.apache.spark.sql.columnar.compression.CompressibleColumnAccessor<T>, org.apache.spark.sql.columnar.NullableColumnAccessor)
      • org.apache.spark.sql.columnar.BooleanColumnAccessor
      • org.apache.spark.sql.columnar.ByteColumnAccessor
      • org.apache.spark.sql.columnar.DateColumnAccessor
      • org.apache.spark.sql.columnar.DoubleColumnAccessor
      • org.apache.spark.sql.columnar.FloatColumnAccessor
      • org.apache.spark.sql.columnar.IntColumnAccessor
      • org.apache.spark.sql.columnar.LongColumnAccessor
      • org.apache.spark.sql.columnar.ShortColumnAccessor
      • org.apache.spark.sql.columnar.StringColumnAccessor
      • org.apache.spark.sql.columnar.TimestampColumnAccessor
  • org.apache.spark.sql.columnar.BasicColumnBuilder<T,JvmType> (implements org.apache.spark.sql.columnar.ColumnBuilder)
    • org.apache.spark.sql.columnar.ComplexColumnBuilder<T,JvmType> (implements org.apache.spark.sql.columnar.NullableColumnBuilder)
      • org.apache.spark.sql.columnar.BinaryColumnBuilder
      • org.apache.spark.sql.columnar.GenericColumnBuilder
    • org.apache.spark.sql.columnar.NativeColumnBuilder<T> (implements org.apache.spark.sql.columnar.compression.AllCompressionSchemes, org.apache.spark.sql.columnar.compression.CompressibleColumnBuilder<T>, org.apache.spark.sql.columnar.NullableColumnBuilder)
      • org.apache.spark.sql.columnar.BooleanColumnBuilder
      • org.apache.spark.sql.columnar.ByteColumnBuilder
      • org.apache.spark.sql.columnar.DateColumnBuilder
      • org.apache.spark.sql.columnar.DoubleColumnBuilder
      • org.apache.spark.sql.columnar.FloatColumnBuilder
      • org.apache.spark.sql.columnar.IntColumnBuilder
      • org.apache.spark.sql.columnar.LongColumnBuilder
      • org.apache.spark.sql.columnar.ShortColumnBuilder
      • org.apache.spark.sql.columnar.StringColumnBuilder
      • org.apache.spark.sql.columnar.TimestampColumnBuilder
  • org.apache.spark.streaming.scheduler.BatchAllocationEvent (implements scala.Product, org.apache.spark.streaming.scheduler.ReceivedBlockTrackerLogEvent, scala.Serializable)
  • org.apache.spark.streaming.scheduler.BatchCleanupEvent (implements scala.Product, org.apache.spark.streaming.scheduler.ReceivedBlockTrackerLogEvent, scala.Serializable)
  • org.apache.spark.streaming.scheduler.BatchInfo (implements scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.BeginEvent (implements org.apache.spark.scheduler.DAGSchedulerEvent, 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.tree.model.Bin (implements scala.Product, scala.Serializable)
  • org.apache.spark.mllib.evaluation.BinaryClassificationMetrics (implements org.apache.spark.Logging)
  • org.apache.spark.sql.columnar.BinaryColumnStats (implements org.apache.spark.sql.columnar.ColumnStats)
  • org.apache.spark.mllib.evaluation.binary.BinaryConfusionMatrixImpl (implements org.apache.spark.mllib.evaluation.binary.BinaryConfusionMatrix, scala.Product, scala.Serializable)
  • org.apache.spark.mllib.evaluation.binary.BinaryLabelCounter (implements scala.Serializable)
  • org.apache.spark.util.random.BinomialBounds
  • org.apache.spark.mllib.linalg.BLAS (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.streaming.scheduler.BlockAdditionEvent (implements scala.Product, org.apache.spark.streaming.scheduler.ReceivedBlockTrackerLogEvent, scala.Serializable)
  • 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.TempLocalBlockId (implements scala.Product, scala.Serializable)
    • org.apache.spark.storage.TempShuffleBlockId (implements scala.Product, scala.Serializable)
    • org.apache.spark.storage.TestBlockId (implements scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockInfo
  • org.apache.spark.storage.BlockManager (implements org.apache.spark.network.BlockDataManager, org.apache.spark.Logging)
  • org.apache.spark.streaming.receiver.BlockManagerBasedBlockHandler (implements org.apache.spark.Logging, org.apache.spark.streaming.receiver.ReceivedBlockHandler)
  • org.apache.spark.streaming.receiver.BlockManagerBasedStoreResult (implements scala.Product, org.apache.spark.streaming.receiver.ReceivedBlockStoreResult, scala.Serializable)
  • org.apache.spark.storage.BlockManagerId (implements java.io.Externalizable)
  • org.apache.spark.storage.BlockManagerInfo (implements org.apache.spark.Logging)
  • org.apache.spark.storage.BlockManagerMaster (implements org.apache.spark.Logging)
  • org.apache.spark.storage.BlockManagerMasterActor (implements akka.actor.Actor, org.apache.spark.util.ActorLogReceive, org.apache.spark.Logging)
  • org.apache.spark.storage.BlockManagerMessages
  • org.apache.spark.storage.BlockManagerMessages.BlockManagerHeartbeat (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.ExpireDeadHosts$ (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.GetActorSystemHostPortForExecutor (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.GetLocations (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.GetLocationsMultipleBlockIds (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.GetMatchingBlockIds (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.GetMemoryStatus$ (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.GetPeers (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.GetStorageStatus$ (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.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.StopBlockManagerMaster$ (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, 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.storage.BlockManagerSlaveActor (implements akka.actor.Actor, org.apache.spark.util.ActorLogReceive, org.apache.spark.Logging)
  • org.apache.spark.storage.BlockManagerSource (implements org.apache.spark.metrics.source.Source)
  • org.apache.spark.storage.BlockObjectWriter
    • org.apache.spark.storage.DiskBlockObjectWriter (implements org.apache.spark.Logging)
  • org.apache.spark.rdd.BlockRDDPartition (implements org.apache.spark.Partition)
  • org.apache.spark.storage.BlockResult
  • org.apache.spark.storage.BlockStatus (implements scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockStore (implements org.apache.spark.Logging)
    • org.apache.spark.storage.DiskStore (implements org.apache.spark.Logging)
    • org.apache.spark.storage.MemoryStore
    • org.apache.spark.storage.TachyonStore (implements org.apache.spark.Logging)
  • org.apache.spark.sql.columnar.compression.BooleanBitSet (implements org.apache.spark.sql.columnar.compression.CompressionScheme, scala.Product, scala.Serializable)
  • org.apache.spark.sql.columnar.compression.BooleanBitSet.Decoder (implements org.apache.spark.sql.columnar.compression.Decoder<T>)
  • org.apache.spark.sql.columnar.compression.BooleanBitSet.Encoder (implements org.apache.spark.sql.columnar.compression.Encoder<T>)
  • org.apache.spark.sql.columnar.BooleanColumnStats (implements org.apache.spark.sql.columnar.ColumnStats)
  • org.apache.spark.mllib.tree.configuration.BoostingStrategy (implements scala.Product, scala.Serializable)
  • org.apache.spark.partial.BoundedDouble
  • org.apache.spark.util.BoundedPriorityQueue<A> (implements scala.collection.generic.Growable<A>, scala.collection.Iterable<A>, java.io.Serializable)
  • org.apache.spark.broadcast.Broadcast<T> (implements org.apache.spark.Logging, java.io.Serializable)
    • org.apache.spark.broadcast.HttpBroadcast<T> (implements org.apache.spark.Logging, scala.Serializable)
    • org.apache.spark.broadcast.TorrentBroadcast<T> (implements org.apache.spark.Logging, java.io.Serializable)
  • org.apache.spark.broadcast.BroadcastManager (implements org.apache.spark.Logging)
  • org.apache.spark.streaming.receiver.ByteBufferBlock (implements scala.Product, org.apache.spark.streaming.receiver.ReceivedBlock, scala.Serializable)
  • org.apache.spark.streaming.receiver.ByteBufferData (implements org.apache.spark.streaming.receiver.ActorReceiverData, scala.Product, scala.Serializable)
  • org.apache.spark.storage.ByteBufferValues (implements org.apache.spark.storage.BlockValues, scala.Product, scala.Serializable)
  • org.apache.spark.graphx.util.BytecodeUtils
  • org.apache.spark.sql.columnar.ByteColumnStats (implements org.apache.spark.sql.columnar.ColumnStats)
  • org.apache.spark.sql.columnar.CachedBatch (implements scala.Product, scala.Serializable)
  • org.apache.spark.sql.CachedData (implements scala.Product, scala.Serializable)
  • org.apache.spark.CacheManager (implements org.apache.spark.Logging)
  • org.apache.spark.util.CallSite (implements scala.Product, scala.Serializable)
  • org.apache.spark.rdd.CartesianPartition (implements org.apache.spark.Partition)
  • org.apache.spark.streaming.Checkpoint (implements org.apache.spark.Logging, java.io.Serializable)
  • org.apache.spark.rdd.CheckpointRDDPartition (implements org.apache.spark.Partition)
  • org.apache.spark.streaming.CheckpointReader (implements org.apache.spark.Logging)
  • org.apache.spark.streaming.CheckpointWriter (implements org.apache.spark.Logging)
  • org.apache.spark.streaming.CheckpointWriter.CheckpointWriteHandler (implements Runnable)
  • org.apache.spark.mllib.stat.test.ChiSqTest (implements org.apache.spark.Logging)
  • 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>)
  • ClassLoader
    • org.apache.spark.util.ParentClassLoader
  • com.esotericsoftware.reflectasm.shaded.org.objectweb.asm.ClassVisitor
    • org.apache.spark.util.FieldAccessFinder
    • org.apache.spark.util.InnerClosureFinder
    • org.apache.spark.util.ReturnStatementFinder
  • org.apache.spark.CleanBroadcast (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.streaming.receiver.CleanupOldBlocks (implements scala.Product, org.apache.spark.streaming.receiver.ReceiverMessage, scala.Serializable)
  • org.apache.spark.streaming.scheduler.ClearCheckpointData (implements org.apache.spark.streaming.scheduler.JobGeneratorEvent, scala.Product, scala.Serializable)
  • org.apache.spark.streaming.scheduler.ClearMetadata (implements org.apache.spark.streaming.scheduler.JobGeneratorEvent, scala.Product, scala.Serializable)
  • org.apache.spark.util.ClosureCleaner (implements org.apache.spark.Logging)
  • org.apache.spark.rdd.CoalescedRDDPartition (implements org.apache.spark.Partition, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages
  • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.AddWebUIFilter (implements org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessage, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.KillExecutors (implements org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessage, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.KillTask (implements org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessage, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.LaunchTask (implements org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessage, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RegisterClusterManager$ (implements org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessage, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RegisteredExecutor$ (implements org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessage, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RegisterExecutor (implements org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessage, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RegisterExecutorFailed (implements org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessage, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RemoveExecutor (implements org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessage, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RequestExecutors (implements org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessage, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RetrieveSparkProps$ (implements org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessage, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.ReviveOffers$ (implements org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessage, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.StatusUpdate (implements org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessage, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.StatusUpdate$ (implements scala.Serializable)
  • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.StopDriver$ (implements org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessage, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.StopExecutor$ (implements org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessage, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.StopExecutors$ (implements org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessage, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.cluster.CoarseGrainedSchedulerBackend (implements org.apache.spark.ExecutorAllocationClient, org.apache.spark.Logging, org.apache.spark.scheduler.SchedulerBackend)
    • org.apache.spark.scheduler.cluster.mesos.CoarseMesosSchedulerBackend (implements org.apache.spark.Logging, org.apache.mesos.Scheduler)
    • org.apache.spark.scheduler.cluster.SimrSchedulerBackend (implements org.apache.spark.Logging)
    • org.apache.spark.scheduler.cluster.SparkDeploySchedulerBackend (implements org.apache.spark.deploy.client.AppClientListener, org.apache.spark.Logging)
    • org.apache.spark.scheduler.cluster.YarnSchedulerBackend
  • org.apache.spark.scheduler.cluster.CoarseGrainedSchedulerBackend.DriverActor (implements akka.actor.Actor, org.apache.spark.util.ActorLogReceive)
  • org.apache.spark.rdd.CoGroupPartition (implements org.apache.spark.Partition, scala.Serializable)
  • org.apache.spark.util.CollectionsUtils
  • org.apache.spark.sql.columnar.ColumnStatisticsSchema (implements scala.Serializable)
  • org.apache.spark.sql.columnar.ColumnType<T,JvmType>
    • org.apache.spark.sql.columnar.ByteArrayColumnType<T>
      • org.apache.spark.sql.columnar.BINARY
      • org.apache.spark.sql.columnar.GENERIC
    • org.apache.spark.sql.columnar.NativeColumnType<T>
      • org.apache.spark.sql.columnar.BOOLEAN
      • org.apache.spark.sql.columnar.BYTE
      • org.apache.spark.sql.columnar.DATE
      • org.apache.spark.sql.columnar.DOUBLE
      • org.apache.spark.sql.columnar.FLOAT
      • org.apache.spark.sql.columnar.INT
      • org.apache.spark.sql.columnar.LONG
      • org.apache.spark.sql.columnar.SHORT
      • org.apache.spark.sql.columnar.STRING
      • org.apache.spark.sql.columnar.TIMESTAMP
  • org.apache.spark.scheduler.CompletionEvent (implements org.apache.spark.scheduler.DAGSchedulerEvent, scala.Product, scala.Serializable)
  • org.apache.spark.util.CompletionIterator<A,I> (implements scala.collection.Iterator<A>)
  • org.apache.spark.ComplexFutureAction<T> (implements org.apache.spark.FutureAction<T>)
  • org.apache.spark.scheduler.CompressedMapStatus (implements java.io.Externalizable, org.apache.spark.scheduler.MapStatus)
  • org.apache.spark.graphx.lib.ConnectedComponents
  • org.apache.spark.ui.ConsoleProgressBar (implements org.apache.spark.Logging)
  • org.apache.spark.metrics.sink.ConsoleSink (implements org.apache.spark.metrics.sink.Sink)
  • org.apache.spark.ContextCleaner (implements org.apache.spark.Logging)
  • org.apache.spark.streaming.ContextWaiter
  • parquet.io.api.Converter
    • parquet.io.api.GroupConverter
      • org.apache.spark.sql.parquet.CatalystConverter
        • org.apache.spark.sql.parquet.CatalystArrayContainsNullConverter
        • org.apache.spark.sql.parquet.CatalystArrayConverter
        • org.apache.spark.sql.parquet.CatalystGroupConverter
          • org.apache.spark.sql.parquet.CatalystStructConverter
        • org.apache.spark.sql.parquet.CatalystMapConverter
        • org.apache.spark.sql.parquet.CatalystNativeArrayConverter
        • org.apache.spark.sql.parquet.CatalystPrimitiveRowConverter
    • parquet.io.api.PrimitiveConverter
      • org.apache.spark.sql.parquet.CatalystPrimitiveConverter
  • org.apache.spark.mllib.linalg.distributed.CoordinateMatrix (implements org.apache.spark.mllib.linalg.distributed.DistributedMatrix)
  • org.apache.spark.mllib.stat.correlation.CorrelationNames
  • org.apache.spark.mllib.stat.correlation.Correlations
  • org.apache.spark.partial.CountEvaluator (implements org.apache.spark.partial.ApproximateEvaluator<U,R>)
  • org.apache.spark.metrics.sink.CsvSink (implements org.apache.spark.metrics.sink.Sink)
  • org.apache.spark.scheduler.DAGScheduler (implements org.apache.spark.Logging)
  • org.apache.spark.scheduler.DAGSchedulerActorSupervisor (implements akka.actor.Actor, org.apache.spark.Logging)
  • org.apache.spark.scheduler.DAGSchedulerEventProcessActor (implements akka.actor.Actor, org.apache.spark.Logging)
  • org.apache.spark.scheduler.DAGSchedulerSource (implements org.apache.spark.metrics.source.Source)
  • org.apache.spark.sql.catalyst.types.DataType
    • org.apache.spark.sql.catalyst.types.UserDefinedType<UserType> (implements scala.Serializable)
      • org.apache.spark.sql.test.ExamplePointUDT
      • org.apache.spark.sql.api.java.JavaToScalaUDTWrapper<UserType> (implements scala.Serializable)
      • org.apache.spark.mllib.linalg.VectorUDT
  • org.apache.spark.sql.api.java.DataType
    • org.apache.spark.sql.api.java.ArrayType
    • org.apache.spark.sql.api.java.BinaryType
    • org.apache.spark.sql.api.java.BooleanType
    • org.apache.spark.sql.api.java.ByteType
    • org.apache.spark.sql.api.java.DateType
    • org.apache.spark.sql.api.java.DecimalType
    • org.apache.spark.sql.api.java.DoubleType
    • org.apache.spark.sql.api.java.FloatType
    • org.apache.spark.sql.api.java.IntegerType
    • org.apache.spark.sql.api.java.LongType
    • org.apache.spark.sql.api.java.MapType
    • org.apache.spark.sql.api.java.NullType
    • org.apache.spark.sql.api.java.ShortType
    • org.apache.spark.sql.api.java.StringType
    • org.apache.spark.sql.api.java.StructType
    • org.apache.spark.sql.api.java.TimestampType
    • org.apache.spark.sql.api.java.UserDefinedType<UserType> (implements java.io.Serializable)
      • org.apache.spark.sql.api.java.ScalaToJavaUDTWrapper<UserType> (implements scala.Serializable)
  • org.apache.spark.sql.types.util.DataTypeConversions
  • org.apache.spark.mllib.util.DataValidators (implements org.apache.spark.Logging)
  • org.apache.spark.sql.columnar.DateColumnStats (implements org.apache.spark.sql.columnar.ColumnStats)
  • org.apache.spark.mllib.tree.DecisionTree (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.mllib.tree.impl.DecisionTreeMetadata (implements scala.Serializable)
  • org.apache.spark.mllib.tree.model.DecisionTreeModel (implements scala.Serializable)
  • org.apache.spark.sql.json.DefaultSource (implements org.apache.spark.sql.sources.RelationProvider)
  • org.apache.spark.sql.parquet.DefaultSource (implements org.apache.spark.sql.sources.RelationProvider)
  • org.apache.spark.sql.hive.DeferredObjectAdapter (implements org.apache.hadoop.hive.ql.udf.generic.GenericUDF.DeferredObject, org.apache.spark.sql.hive.HiveInspectors)
  • 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.rdd.PruneDependency<T>
      • org.apache.spark.RangeDependency<T>
    • org.apache.spark.ShuffleDependency<K,V,C>
  • org.apache.spark.streaming.scheduler.DeregisterReceiver (implements scala.Product, org.apache.spark.streaming.scheduler.ReceiverTrackerMessage, scala.Serializable)
  • org.apache.spark.serializer.DeserializationStream
    • org.apache.spark.serializer.JavaDeserializationStream
    • org.apache.spark.serializer.KryoDeserializationStream
  • org.apache.spark.sql.columnar.compression.DictionaryEncoding (implements org.apache.spark.sql.columnar.compression.CompressionScheme, scala.Product, scala.Serializable)
  • org.apache.spark.sql.columnar.compression.DictionaryEncoding.Decoder<T> (implements org.apache.spark.sql.columnar.compression.Decoder<T>)
  • org.apache.spark.sql.columnar.compression.DictionaryEncoding.Encoder<T> (implements org.apache.spark.sql.columnar.compression.Encoder<T>)
  • org.apache.spark.scheduler.DirectTaskResult<T> (implements java.io.Externalizable, org.apache.spark.scheduler.TaskResult<T>)
  • org.apache.spark.storage.DiskBlockManager (implements org.apache.spark.Logging)
  • org.apache.spark.util.Distribution
  • org.apache.spark.streaming.scheduler.DoCheckpoint (implements org.apache.spark.streaming.scheduler.JobGeneratorEvent, scala.Product, scala.Serializable)
  • org.apache.spark.sql.columnar.DoubleColumnStats (implements org.apache.spark.sql.columnar.ColumnStats)
  • 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.FilteredDStream<T>
    • org.apache.spark.streaming.dstream.FlatMappedDStream<T,U>
    • org.apache.spark.streaming.dstream.FlatMapValuedDStream<K,V,U>
    • org.apache.spark.streaming.dstream.ForEachDStream<T>
    • org.apache.spark.streaming.dstream.GlommedDStream<T>
    • org.apache.spark.streaming.dstream.InputDStream<T>
      • org.apache.spark.streaming.dstream.ConstantInputDStream<T>
      • org.apache.spark.streaming.dstream.FileInputDStream<K,V,F>
      • org.apache.spark.streaming.dstream.QueueInputDStream<T>
      • org.apache.spark.streaming.dstream.ReceiverInputDStream<T>
        • org.apache.spark.streaming.flume.FlumeInputDStream<T>
        • org.apache.spark.streaming.flume.FlumePollingInputDStream<T>
        • org.apache.spark.streaming.kafka.KafkaInputDStream<K,V,U,T> (implements org.apache.spark.Logging)
        • org.apache.spark.streaming.mqtt.MQTTInputDStream
        • org.apache.spark.streaming.dstream.PluggableInputDStream<T>
        • org.apache.spark.streaming.dstream.RawInputDStream<T> (implements org.apache.spark.Logging)
        • org.apache.spark.streaming.dstream.SocketInputDStream<T>
        • org.apache.spark.streaming.twitter.TwitterInputDStream
    • org.apache.spark.streaming.dstream.MapPartitionedDStream<T,U>
    • org.apache.spark.streaming.dstream.MappedDStream<T,U>
    • org.apache.spark.streaming.dstream.MapValuedDStream<K,V,U>
    • org.apache.spark.streaming.dstream.ReducedWindowedDStream<K,V>
    • org.apache.spark.streaming.dstream.ShuffledDStream<K,V,C>
    • org.apache.spark.streaming.dstream.StateDStream<K,V,S>
    • org.apache.spark.streaming.dstream.TransformedDStream<U>
    • org.apache.spark.streaming.dstream.UnionDStream<T>
    • org.apache.spark.streaming.dstream.WindowedDStream<T>
  • org.apache.spark.streaming.dstream.DStreamCheckpointData<T> (implements org.apache.spark.Logging, scala.Serializable)
    • org.apache.spark.streaming.dstream.FileInputDStream.FileInputDStreamCheckpointData
  • org.apache.spark.streaming.DStreamGraph (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.mllib.tree.impl.DTStatsAggregator (implements scala.Serializable)
  • 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.graphx.impl.EdgePartition<ED,VD> (implements scala.Serializable)
  • org.apache.spark.graphx.impl.EdgePartitionBuilder<ED,VD>
  • org.apache.spark.graphx.impl.EdgeWithLocalIds<ED> (implements scala.Product, scala.Serializable)
  • org.apache.spark.mllib.linalg.EigenValueDecomposition
  • 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.rdd.CheckpointState
    • org.apache.spark.mllib.stat.test.ChiSqTest.NullHypothesis$
    • org.apache.spark.mllib.tree.configuration.EnsembleCombiningStrategy
    • org.apache.spark.mllib.tree.configuration.FeatureType
    • org.apache.spark.util.MetadataCleanerType
    • org.apache.spark.mllib.tree.configuration.QuantileStrategy
    • org.apache.spark.streaming.receiver.ReceiverSupervisor.ReceiverState
    • org.apache.spark.scheduler.SchedulingMode
    • org.apache.spark.streaming.StreamingContext.StreamingContextState$
    • org.apache.spark.scheduler.TaskLocality
    • org.apache.spark.TaskState
  • org.apache.spark.ui.env.EnvironmentListener (implements org.apache.spark.scheduler.SparkListener)
  • org.apache.spark.streaming.scheduler.ErrorReported (implements org.apache.spark.streaming.scheduler.JobSchedulerEvent, scala.Product, scala.Serializable)
  • org.apache.spark.ml.Evaluator (implements org.apache.spark.ml.Identifiable)
    • org.apache.spark.ml.evaluation.BinaryClassificationEvaluator (implements org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.Params)
  • org.apache.spark.scheduler.EventLoggingInfo (implements scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.EventLoggingListener (implements org.apache.spark.Logging, org.apache.spark.scheduler.SparkListener)
  • org.apache.spark.streaming.flume.EventTransformer (implements org.apache.spark.Logging)
  • org.apache.spark.sql.test.ExamplePoint
  • org.apache.spark.ExceptionFailure (implements scala.Product, scala.Serializable, org.apache.spark.TaskFailedReason)
  • org.apache.spark.scheduler.ExecutorAdded (implements org.apache.spark.scheduler.DAGSchedulerEvent, scala.Product, scala.Serializable)
  • org.apache.spark.ExecutorAllocationManager (implements org.apache.spark.Logging)
  • org.apache.spark.scheduler.ExecutorCacheTaskLocation (implements scala.Product, scala.Serializable, org.apache.spark.scheduler.TaskLocation)
  • org.apache.spark.scheduler.cluster.ExecutorData
  • org.apache.spark.scheduler.ExecutorLossReason
    • org.apache.spark.scheduler.ExecutorExited (implements scala.Product, scala.Serializable)
    • org.apache.spark.scheduler.SlaveLost (implements scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.ExecutorLost (implements org.apache.spark.scheduler.DAGSchedulerEvent, scala.Product, scala.Serializable)
  • 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.ui.exec.ExecutorSummaryInfo (implements scala.Product, scala.Serializable)
  • org.apache.spark.ui.jobs.ExecutorTable
  • org.apache.spark.graphx.impl.ExistingEdgePartitionBuilder<ED,VD>
  • org.apache.spark.scheduler.FairSchedulableBuilder (implements org.apache.spark.Logging, org.apache.spark.scheduler.SchedulableBuilder)
  • org.apache.spark.scheduler.FairSchedulingAlgorithm (implements org.apache.spark.scheduler.SchedulingAlgorithm)
  • org.apache.spark.sql.hive.parquet.FakeParquetSerDe (implements org.apache.hadoop.hive.serde2.SerDe)
  • org.apache.spark.mllib.evaluation.binary.FalsePositiveRate (implements org.apache.spark.mllib.evaluation.binary.BinaryClassificationMetricComputer)
  • org.apache.spark.FetchFailed (implements scala.Product, scala.Serializable, org.apache.spark.TaskFailedReason)
  • org.apache.spark.scheduler.FIFOSchedulableBuilder (implements org.apache.spark.Logging, org.apache.spark.scheduler.SchedulableBuilder)
  • org.apache.spark.scheduler.FIFOSchedulingAlgorithm (implements org.apache.spark.scheduler.SchedulingAlgorithm)
  • org.apache.spark.util.logging.FileAppender (implements org.apache.spark.Logging)
    • org.apache.spark.util.logging.RollingFileAppender
  • org.apache.spark.util.FileLogger (implements org.apache.spark.Logging)
  • org.apache.spark.storage.FileSegment
  • org.apache.spark.sql.parquet.FileSystemHelper
  • org.apache.spark.sql.sources.Filter
    • 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.LessThan (implements scala.Product, scala.Serializable)
    • org.apache.spark.sql.sources.LessThanOrEqual (implements scala.Product, scala.Serializable)
  • org.apache.spark.sql.columnar.FloatColumnStats (implements org.apache.spark.sql.columnar.ColumnStats)
  • org.apache.spark.streaming.flume.FlumeBatchFetcher (implements org.apache.spark.Logging, Runnable)
  • org.apache.spark.streaming.flume.FlumeConnection
  • org.apache.spark.streaming.flume.FlumeEventServer (implements org.apache.flume.source.avro.AvroSourceProtocol)
  • org.apache.spark.streaming.flume.FlumeReceiver.CompressionChannelPipelineFactory (implements org.jboss.netty.channel.ChannelPipelineFactory)
  • org.apache.spark.streaming.flume.FlumeUtils
  • org.apache.spark.mllib.evaluation.binary.FMeasure (implements org.apache.spark.mllib.evaluation.binary.BinaryClassificationMetricComputer, scala.Product, scala.Serializable)
  • org.apache.spark.util.random.GapSamplingIterator<T> (implements scala.collection.Iterator<A>)
  • org.apache.spark.util.random.GapSamplingReplacementIterator<T> (implements scala.collection.Iterator<A>)
  • org.apache.spark.sql.execution.joins.GeneralHashedRelation (implements org.apache.spark.sql.execution.joins.HashedRelation, 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.regression.RegressionModel, scala.Serializable)
    • org.apache.spark.mllib.regression.LinearRegressionModel (implements org.apache.spark.mllib.regression.RegressionModel, scala.Serializable)
    • org.apache.spark.mllib.classification.LogisticRegressionModel (implements org.apache.spark.mllib.classification.ClassificationModel, scala.Serializable)
    • org.apache.spark.mllib.regression.RidgeRegressionModel (implements org.apache.spark.mllib.regression.RegressionModel, scala.Serializable)
    • org.apache.spark.mllib.classification.SVMModel (implements org.apache.spark.mllib.classification.ClassificationModel, scala.Serializable)
  • org.apache.spark.streaming.scheduler.GenerateJobs (implements org.apache.spark.streaming.scheduler.JobGeneratorEvent, scala.Product, scala.Serializable)
  • org.apache.spark.sql.columnar.GenericColumnStats (implements org.apache.spark.sql.columnar.ColumnStats)
  • org.apache.spark.sql.catalyst.planning.GenericStrategy<PhysicalPlan> (implements org.apache.spark.Logging)
    • org.apache.spark.sql.sources.DataSourceStrategy
    • org.apache.spark.sql.hive.HiveStrategies.DataSinks
    • org.apache.spark.sql.hive.HiveStrategies.HiveCommandStrategy (implements scala.Product, scala.Serializable)
    • org.apache.spark.sql.hive.HiveStrategies.HiveTableScans
    • org.apache.spark.sql.hive.HiveStrategies.ParquetConversion
    • org.apache.spark.sql.hive.HiveStrategies.Scripts
    • org.apache.spark.sql.execution.SparkStrategies.BasicOperators
    • org.apache.spark.sql.execution.SparkStrategies.BroadcastNestedLoopJoin
    • org.apache.spark.sql.execution.SparkStrategies.CartesianProduct
    • org.apache.spark.sql.execution.SparkStrategies.CommandStrategy (implements scala.Product, scala.Serializable)
    • org.apache.spark.sql.execution.SparkStrategies.HashAggregation
    • org.apache.spark.sql.execution.SparkStrategies.HashJoin (implements org.apache.spark.sql.catalyst.expressions.PredicateHelper)
    • org.apache.spark.sql.execution.SparkStrategies.InMemoryScans
    • org.apache.spark.sql.execution.SparkStrategies.LeftSemiJoin (implements org.apache.spark.sql.catalyst.expressions.PredicateHelper)
    • org.apache.spark.sql.execution.SparkStrategies.ParquetOperations
    • org.apache.spark.sql.execution.SparkStrategies.TakeOrdered
  • org.apache.spark.GetMapOutputStatuses (implements org.apache.spark.MapOutputTrackerMessage, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.GettingResultEvent (implements org.apache.spark.scheduler.DAGSchedulerEvent, scala.Product, 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.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.metrics.sink.GraphiteSink (implements org.apache.spark.metrics.sink.Sink)
  • 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.partial.GroupedCountEvaluator<T> (implements org.apache.spark.partial.ApproximateEvaluator<U,R>)
  • org.apache.spark.partial.GroupedMeanEvaluator<T> (implements org.apache.spark.partial.ApproximateEvaluator<U,R>)
  • org.apache.spark.partial.GroupedSumEvaluator<T> (implements org.apache.spark.partial.ApproximateEvaluator<U,R>)
  • org.apache.spark.GrowableAccumulableParam<R,T> (implements org.apache.spark.AccumulableParam<R,T>)
  • org.apache.spark.rdd.HadoopPartition (implements org.apache.spark.Partition)
  • org.apache.spark.rdd.HadoopRDD.HadoopMapPartitionsWithSplitRDD$ (implements scala.Serializable)
  • org.apache.spark.rdd.HadoopRDD.SplitInfoReflections
  • org.apache.spark.sql.hive.HadoopTableReader (implements org.apache.spark.sql.hive.TableReader)
  • org.apache.spark.mllib.feature.HashingTF (implements scala.Serializable)
  • org.apache.spark.scheduler.HDFSCacheTaskLocation (implements scala.Product, scala.Serializable, org.apache.spark.scheduler.TaskLocation)
  • org.apache.spark.streaming.util.HdfsUtils
  • org.apache.spark.Heartbeat (implements scala.Product, scala.Serializable)
  • org.apache.spark.HeartbeatReceiver (implements akka.actor.Actor, org.apache.spark.util.ActorLogReceive, org.apache.spark.Logging)
  • org.apache.spark.HeartbeatResponse (implements scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.HighlyCompressedMapStatus (implements java.io.Externalizable, org.apache.spark.scheduler.MapStatus)
  • org.apache.spark.sql.hive.HiveFunctionRegistry (implements org.apache.spark.sql.catalyst.analysis.FunctionRegistry, org.apache.spark.sql.hive.HiveInspectors)
  • org.apache.spark.sql.hive.HiveFunctionWrapper (implements java.io.Externalizable, scala.Product, scala.Serializable)
  • org.apache.spark.sql.hive.HiveInspectors.typeInfoConversions
  • org.apache.spark.sql.hive.HiveMetastoreCatalog (implements org.apache.spark.sql.catalyst.analysis.Catalog, org.apache.spark.Logging)
  • org.apache.spark.sql.hive.HiveMetastoreTypes (implements scala.util.parsing.combinator.RegexParsers)
  • org.apache.spark.sql.hive.HiveQl
  • org.apache.spark.sql.hive.HiveQl.Token$
  • org.apache.spark.sql.hive.HiveQl.TransformableNode
  • org.apache.spark.sql.hive.HiveShim
  • org.apache.spark.sql.hive.HiveStrategies.ParquetConversion.LogicalPlanHacks
  • org.apache.spark.sql.hive.HiveStrategies.ParquetConversion.PhysicalPlanHacks
  • org.apache.spark.scheduler.HostTaskLocation (implements scala.Product, scala.Serializable, org.apache.spark.scheduler.TaskLocation)
  • org.apache.spark.broadcast.HttpBroadcastFactory (implements org.apache.spark.broadcast.BroadcastFactory)
  • org.apache.spark.HttpFileServer (implements org.apache.spark.Logging)
  • org.apache.spark.HttpServer (implements org.apache.spark.Logging)
  • 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.util.IdGenerator
  • org.apache.spark.mllib.tree.impurity.Impurities
  • org.apache.spark.mllib.tree.impurity.ImpurityAggregator (implements scala.Serializable)
    • org.apache.spark.mllib.tree.impurity.EntropyAggregator (implements scala.Serializable)
    • org.apache.spark.mllib.tree.impurity.GiniAggregator (implements scala.Serializable)
    • org.apache.spark.mllib.tree.impurity.VarianceAggregator (implements scala.Serializable)
  • org.apache.spark.mllib.tree.impurity.ImpurityCalculator
    • org.apache.spark.mllib.tree.impurity.EntropyCalculator
    • org.apache.spark.mllib.tree.impurity.GiniCalculator
    • org.apache.spark.mllib.tree.impurity.VarianceCalculator
  • 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.scheduler.IndirectTaskResult<T> (implements scala.Product, java.io.Serializable, scala.Serializable, org.apache.spark.scheduler.TaskResult<T>)
  • org.apache.spark.mllib.tree.model.InformationGainStats (implements scala.Serializable)
  • org.apache.spark.mllib.recommendation.InLinkBlock (implements scala.Product, scala.Serializable)
  • org.apache.hadoop.mapreduce.InputFormat<K,V>
    • org.apache.hadoop.mapreduce.lib.input.FileInputFormat<K,V>
      • org.apache.hadoop.mapreduce.lib.input.CombineFileInputFormat<K,V>
        • org.apache.spark.input.StreamFileInputFormat<T>
          • org.apache.spark.input.StreamInputFormat
        • org.apache.spark.input.WholeTextFileInputFormat (implements org.apache.hadoop.conf.Configurable)
      • org.apache.spark.input.FixedLengthBinaryInputFormat
      • parquet.hadoop.ParquetInputFormat<T>
        • org.apache.spark.sql.parquet.FilteringParquetRowInputFormat (implements org.apache.spark.Logging)
  • org.apache.spark.scheduler.InputFormatInfo (implements org.apache.spark.Logging)
  • java.io.InputStream (implements java.io.Closeable)
    • org.apache.spark.util.ByteBufferInputStream
    • java.io.ObjectInputStream (implements java.io.ObjectInput, java.io.ObjectStreamConstants)
      • org.apache.spark.streaming.ObjectInputStreamWithLoader
  • org.apache.spark.sql.columnar.IntColumnStats (implements org.apache.spark.sql.columnar.ColumnStats)
  • org.apache.spark.sql.columnar.compression.IntDelta (implements org.apache.spark.sql.columnar.compression.CompressionScheme, scala.Product, scala.Serializable)
  • org.apache.spark.sql.columnar.compression.IntDelta.Decoder (implements org.apache.spark.sql.columnar.compression.Decoder<T>)
  • org.apache.spark.sql.columnar.compression.IntDelta.Encoder (implements org.apache.spark.sql.columnar.compression.Encoder<T>)
  • org.apache.spark.InterruptibleIterator<T> (implements scala.collection.Iterator<A>)
  • org.apache.spark.streaming.Interval
  • org.apache.spark.util.IntParam
  • org.apache.spark.streaming.receiver.IteratorBlock (implements scala.Product, org.apache.spark.streaming.receiver.ReceivedBlock, scala.Serializable)
  • org.apache.spark.streaming.receiver.IteratorData<T> (implements org.apache.spark.streaming.receiver.ActorReceiverData, scala.Product, scala.Serializable)
  • org.apache.spark.storage.IteratorValues (implements org.apache.spark.storage.BlockValues, scala.Product, scala.Serializable)
  • org.apache.spark.JavaFutureActionWrapper<S,T> (implements org.apache.spark.api.java.JavaFutureAction<T>)
  • org.apache.spark.examples.streaming.JavaKinesisWordCountASL
  • org.apache.spark.sql.api.java.JavaSchemaRDD (implements org.apache.spark.api.java.JavaRDDLike<T,This>, org.apache.spark.sql.SchemaRDDLike)
  • org.apache.spark.api.java.JavaSparkContext (implements java.io.Closeable)
  • org.apache.spark.api.java.JavaSparkStatusTracker
  • org.apache.spark.sql.api.java.JavaSQLContext (implements org.apache.spark.sql.api.java.UDFRegistration)
    • org.apache.spark.sql.hive.api.java.JavaHiveContext
  • org.apache.spark.streaming.api.java.JavaStreamingContext (implements java.io.Closeable)
  • org.apache.spark.api.java.JavaUtils
  • org.apache.spark.rdd.JdbcPartition (implements org.apache.spark.Partition)
  • org.apache.spark.ui.JettyUtils (implements org.apache.spark.Logging)
  • org.apache.spark.ui.JettyUtils.ServletParams<T>
  • org.apache.spark.ui.JettyUtils.ServletParams$
  • org.apache.spark.metrics.sink.JmxSink (implements org.apache.spark.metrics.sink.Sink)
  • org.apache.spark.streaming.scheduler.Job
  • org.apache.spark.scheduler.JobCancelled (implements org.apache.spark.scheduler.DAGSchedulerEvent, scala.Product, scala.Serializable)
  • org.apache.spark.streaming.scheduler.JobCompleted (implements org.apache.spark.streaming.scheduler.JobSchedulerEvent, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.JobFailed (implements org.apache.spark.scheduler.JobResult, scala.Product, scala.Serializable)
  • org.apache.spark.streaming.scheduler.JobGenerator (implements org.apache.spark.Logging)
  • org.apache.spark.scheduler.JobGroupCancelled (implements org.apache.spark.scheduler.DAGSchedulerEvent, scala.Product, scala.Serializable)
  • 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.streaming.scheduler.JobScheduler (implements org.apache.spark.Logging)
  • org.apache.spark.streaming.scheduler.JobSet (implements scala.Product, scala.Serializable)
  • org.apache.spark.streaming.scheduler.JobStarted (implements org.apache.spark.streaming.scheduler.JobSchedulerEvent, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.JobSubmitted (implements org.apache.spark.scheduler.DAGSchedulerEvent, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.JobSucceeded (implements org.apache.spark.scheduler.JobResult, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.JobWaiter<T> (implements org.apache.spark.scheduler.JobListener)
  • org.apache.spark.util.JsonProtocol
  • org.apache.spark.sql.json.JsonRDD (implements org.apache.spark.Logging)
  • org.apache.spark.metrics.source.JvmSource (implements org.apache.spark.metrics.source.Source)
  • org.apache.spark.streaming.kafka.KafkaUtils
  • org.apache.spark.scheduler.local.KillTask (implements scala.Product, scala.Serializable)
  • org.apache.spark.streaming.kinesis.KinesisCheckpointState (implements org.apache.spark.Logging)
  • org.apache.spark.streaming.kinesis.KinesisRecordProcessor (implements com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor, org.apache.spark.Logging)
  • org.apache.spark.streaming.kinesis.KinesisUtils
  • org.apache.spark.examples.streaming.KinesisWordCountASL (implements org.apache.spark.Logging)
  • org.apache.spark.examples.streaming.KinesisWordCountProducerASL
  • 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 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.util.LinearDataGenerator
  • org.apache.spark.scheduler.LiveListenerBus (implements org.apache.spark.Logging, org.apache.spark.scheduler.SparkListenerBus)
  • org.apache.spark.scheduler.local.LocalActor (implements akka.actor.Actor, org.apache.spark.util.ActorLogReceive, org.apache.spark.Logging)
  • org.apache.spark.scheduler.local.LocalBackend (implements org.apache.spark.executor.ExecutorBackend, org.apache.spark.scheduler.SchedulerBackend)
  • org.apache.spark.mllib.clustering.LocalKMeans (implements org.apache.spark.Logging)
  • org.apache.spark.mllib.util.LogisticRegressionDataGenerator
  • org.apache.spark.mllib.tree.loss.LogLoss (implements org.apache.spark.mllib.tree.loss.Loss)
  • org.apache.spark.sql.columnar.LongColumnStats (implements org.apache.spark.sql.columnar.ColumnStats)
  • org.apache.spark.sql.columnar.compression.LongDelta (implements org.apache.spark.sql.columnar.compression.CompressionScheme, scala.Product, scala.Serializable)
  • org.apache.spark.sql.columnar.compression.LongDelta.Decoder (implements org.apache.spark.sql.columnar.compression.Decoder<T>)
  • org.apache.spark.sql.columnar.compression.LongDelta.Encoder (implements org.apache.spark.sql.columnar.compression.Encoder<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.streaming.util.ManualClock (implements org.apache.spark.streaming.util.Clock)
  • org.apache.spark.MapOutputTracker (implements org.apache.spark.Logging)
    • org.apache.spark.MapOutputTrackerMaster
    • org.apache.spark.MapOutputTrackerWorker
  • org.apache.spark.MapOutputTrackerMasterActor (implements akka.actor.Actor, org.apache.spark.util.ActorLogReceive, org.apache.spark.Logging)
  • 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, scala.Serializable)
  • org.apache.spark.partial.MeanEvaluator (implements org.apache.spark.partial.ApproximateEvaluator<U,R>)
  • org.apache.spark.storage.MemoryEntry (implements scala.Product, scala.Serializable)
  • org.apache.spark.util.MemoryParam
  • org.apache.spark.scheduler.cluster.mesos.MemoryUtils
  • org.apache.spark.scheduler.cluster.mesos.MesosSchedulerBackend (implements org.apache.spark.Logging, org.apache.mesos.Scheduler, org.apache.spark.scheduler.SchedulerBackend)
  • org.apache.spark.sql.catalyst.util.MetadataBuilder
    • org.apache.spark.sql.api.java.MetadataBuilder
  • org.apache.spark.util.MetadataCleaner (implements org.apache.spark.Logging)
  • org.apache.spark.sql.hive.MetastoreRelation.SchemaAttribute
  • org.apache.spark.metrics.MetricsConfig (implements org.apache.spark.Logging)
  • org.apache.spark.metrics.sink.MetricsServlet (implements org.apache.spark.metrics.sink.Sink)
  • org.apache.spark.metrics.MetricsSystem (implements org.apache.spark.Logging)
  • org.apache.spark.mllib.util.MFDataGenerator
  • org.apache.spark.streaming.Milliseconds
  • org.apache.spark.streaming.Minutes
  • 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.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, scala.Serializable)
  • org.apache.spark.rdd.NarrowCoGroupSplitDep (implements org.apache.spark.rdd.CoGroupSplitDep, scala.Product, scala.Serializable)
  • org.apache.spark.rdd.NewHadoopPartition (implements org.apache.spark.Partition)
  • org.apache.spark.rdd.NewHadoopRDD.NewHadoopMapPartitionsWithSplitRDD$ (implements scala.Serializable)
  • org.apache.spark.util.NextIterator<U> (implements scala.collection.Iterator<A>)
  • org.apache.spark.mllib.optimization.NNLS
  • org.apache.spark.mllib.optimization.NNLS.Workspace
  • org.apache.spark.mllib.tree.model.Node (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.mllib.tree.impl.NodeIdCache
  • org.apache.spark.mllib.tree.impl.NodeIndexUpdater (implements scala.Product, scala.Serializable)
  • org.apache.spark.sql.columnar.NoopColumnStats (implements org.apache.spark.sql.columnar.ColumnStats)
  • org.apache.spark.mllib.feature.Normalizer (implements org.apache.spark.mllib.feature.VectorTransformer)
  • org.apache.spark.mllib.util.NumericParser
  • org.apache.spark.rdd.OrderedRDDFunctions<K,V,P> (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.mllib.recommendation.OutLinkBlock (implements scala.Product, scala.Serializable)
  • org.apache.hadoop.mapreduce.OutputFormat<K,V>
    • org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<K,V>
      • parquet.hadoop.ParquetOutputFormat<T>
        • org.apache.spark.sql.parquet.AppendingParquetOutputFormat
  • java.io.OutputStream (implements java.io.Closeable, java.io.Flushable)
    • org.apache.spark.util.io.ByteArrayChunkOutputStream
    • org.apache.spark.streaming.util.RateLimitedOutputStream (implements org.apache.spark.Logging)
  • 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.mapreduce.SparkHadoopMapReduceUtil)
  • org.apache.spark.rdd.ParallelCollectionPartition<T> (implements org.apache.spark.Partition, scala.Serializable)
  • org.apache.spark.ml.param.Param<T> (implements scala.Serializable)
    • org.apache.spark.ml.param.BooleanParam
    • 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.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.sql.parquet.ParquetFilters
  • org.apache.spark.sql.parquet.ParquetTestData
  • org.apache.spark.sql.parquet.ParquetTypeInfo (implements scala.Product, scala.Serializable)
  • org.apache.spark.sql.parquet.ParquetTypesConverter (implements org.apache.spark.Logging)
  • org.apache.spark.partial.PartialResult<R>
  • org.apache.spark.sql.parquet.Partition (implements scala.Product, scala.Serializable)
  • 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.mllib.recommendation.ALSPartitioner
    • org.apache.spark.HashPartitioner
    • org.apache.spark.RangePartitioner<K,V>
  • org.apache.spark.rdd.PartitionerAwareUnionRDDPartition (implements org.apache.spark.Partition)
  • org.apache.spark.rdd.PartitionGroup (implements scala.Product, scala.Serializable)
  • org.apache.spark.rdd.PartitionPruningRDDPartition (implements org.apache.spark.Partition)
  • org.apache.spark.sql.columnar.PartitionStatistics (implements 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.rdd.PartitionwiseSampledRDDPartition (implements org.apache.spark.Partition, scala.Serializable)
  • org.apache.spark.sql.columnar.compression.PassThrough (implements org.apache.spark.sql.columnar.compression.CompressionScheme, scala.Product, scala.Serializable)
  • org.apache.spark.sql.columnar.compression.PassThrough.Decoder<T> (implements org.apache.spark.sql.columnar.compression.Decoder<T>)
  • org.apache.spark.sql.columnar.compression.PassThrough.Encoder<T> (implements org.apache.spark.sql.columnar.compression.Encoder<T>)
  • org.apache.spark.mllib.stat.correlation.PearsonCorrelation (implements org.apache.spark.mllib.stat.correlation.Correlation, org.apache.spark.Logging)
  • org.apache.spark.rdd.PipedRDD.NotEqualsFileNameFilter (implements java.io.FilenameFilter)
  • org.apache.spark.ml.PipelineStage (implements org.apache.spark.Logging, scala.Serializable)
    • org.apache.spark.ml.Estimator<M> (implements org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.tuning.CrossValidator (implements org.apache.spark.ml.tuning.CrossValidatorParams, org.apache.spark.Logging)
      • org.apache.spark.ml.classification.LogisticRegression (implements org.apache.spark.ml.classification.LogisticRegressionParams)
      • org.apache.spark.ml.Pipeline
      • org.apache.spark.ml.feature.StandardScaler (implements org.apache.spark.ml.feature.StandardScalerParams)
    • org.apache.spark.ml.Transformer (implements org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.Model<M>
        • org.apache.spark.ml.tuning.CrossValidatorModel (implements org.apache.spark.ml.tuning.CrossValidatorParams)
        • org.apache.spark.ml.classification.LogisticRegressionModel (implements org.apache.spark.ml.classification.LogisticRegressionParams)
        • org.apache.spark.ml.PipelineModel (implements org.apache.spark.Logging)
        • org.apache.spark.ml.feature.StandardScalerModel (implements org.apache.spark.ml.feature.StandardScalerParams)
      • org.apache.spark.ml.UnaryTransformer<IN,OUT,T> (implements org.apache.spark.ml.param.HasInputCol, org.apache.spark.ml.param.HasOutputCol, org.apache.spark.Logging)
        • org.apache.spark.ml.feature.HashingTF
        • org.apache.spark.ml.feature.Tokenizer
  • 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.scheduler.Pool (implements org.apache.spark.Logging, org.apache.spark.scheduler.Schedulable)
  • org.apache.spark.ui.jobs.PoolTable
  • org.apache.spark.input.PortableDataStream (implements scala.Serializable)
  • org.apache.spark.mllib.evaluation.binary.Precision (implements org.apache.spark.mllib.evaluation.binary.BinaryClassificationMetricComputer)
  • org.apache.spark.mllib.tree.model.Predict (implements scala.Serializable)
  • org.apache.spark.graphx.Pregel (implements org.apache.spark.Logging)
  • org.apache.spark.storage.PutResult (implements scala.Product, scala.Serializable)
  • org.apache.spark.sql.catalyst.planning.QueryPlanner<PhysicalPlan>
    • org.apache.spark.sql.execution.SparkStrategies
  • java.util.Random (implements java.io.Serializable)
    • org.apache.spark.util.random.XORShiftRandom
  • org.apache.spark.mllib.tree.RandomForest (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.mllib.tree.RandomForest.NodeIndexInfo (implements scala.Serializable)
  • org.apache.spark.mllib.rdd.RandomRDDPartition<T> (implements org.apache.spark.Partition)
  • org.apache.spark.mllib.random.RandomRDDs
  • org.apache.spark.mllib.evaluation.RankingMetrics<T> (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.streaming.receiver.RateLimiter (implements org.apache.spark.Logging)
    • org.apache.spark.streaming.receiver.BlockGenerator (implements org.apache.spark.Logging)
  • org.apache.spark.mllib.recommendation.Rating (implements scala.Product, scala.Serializable)
  • org.apache.spark.streaming.util.RawTextHelper
  • org.apache.spark.streaming.util.RawTextSender (implements org.apache.spark.Logging)
  • org.apache.spark.rdd.RDD<T> (implements org.apache.spark.Logging, scala.Serializable)
    • org.apache.spark.rdd.BlockRDD<T>
      • org.apache.spark.streaming.rdd.WriteAheadLogBackedBlockRDD<T>
    • org.apache.spark.rdd.CartesianRDD<T,U> (implements scala.Serializable)
    • org.apache.spark.rdd.CheckpointRDD<T>
    • org.apache.spark.rdd.CoalescedRDD<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.EmptyRDD<T>
    • org.apache.spark.rdd.FilteredRDD<T>
    • org.apache.spark.rdd.FlatMappedRDD<U,T>
    • org.apache.spark.rdd.FlatMappedValuesRDD<K,V,U>
    • org.apache.spark.rdd.GlommedRDD<T>
    • org.apache.spark.rdd.HadoopRDD<K,V> (implements org.apache.spark.Logging)
    • org.apache.spark.rdd.HadoopRDD.HadoopMapPartitionsWithSplitRDD<U,T>
    • org.apache.spark.rdd.JdbcRDD<T> (implements org.apache.spark.Logging)
    • org.apache.spark.rdd.MapPartitionsRDD<U,T>
    • org.apache.spark.rdd.MappedRDD<U,T>
    • org.apache.spark.rdd.MappedValuesRDD<K,V,U>
    • org.apache.spark.rdd.NewHadoopRDD<K,V> (implements org.apache.spark.Logging, org.apache.spark.mapreduce.SparkHadoopMapReduceUtil)
      • org.apache.spark.rdd.BinaryFileRDD<T>
      • org.apache.spark.rdd.WholeTextFileRDD
    • org.apache.spark.rdd.NewHadoopRDD.NewHadoopMapPartitionsWithSplitRDD<U,T>
    • org.apache.spark.rdd.ParallelCollectionRDD<T>
    • org.apache.spark.rdd.PartitionerAwareUnionRDD<T>
    • org.apache.spark.rdd.PartitionPruningRDD<T>
    • org.apache.spark.rdd.PartitionwiseSampledRDD<T,U>
    • org.apache.spark.rdd.PipedRDD<T>
    • org.apache.spark.mllib.rdd.RandomRDD<T>
    • org.apache.spark.mllib.rdd.RandomVectorRDD
    • org.apache.spark.rdd.SampledRDD<T>
    • org.apache.spark.sql.SchemaRDD (implements org.apache.spark.sql.SchemaRDDLike)
    • org.apache.spark.rdd.ShuffledRDD<K,V,C>
    • org.apache.spark.mllib.rdd.SlidingRDD<T>
    • org.apache.spark.rdd.SubtractedRDD<K,V,W>
    • org.apache.spark.rdd.UnionRDD<T>
    • org.apache.spark.graphx.VertexRDD<VD>
      • org.apache.spark.graphx.impl.VertexRDDImpl<VD>
    • org.apache.spark.rdd.ZippedPartitionsBaseRDD<V>
      • org.apache.spark.rdd.ZippedPartitionsRDD2<A,B,V>
      • org.apache.spark.rdd.ZippedPartitionsRDD3<A,B,C,V>
      • org.apache.spark.rdd.ZippedPartitionsRDD4<A,B,C,D,V>
    • org.apache.spark.rdd.ZippedWithIndexRDD<T>
  • org.apache.spark.rdd.RDDCheckpointData<T> (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.sql.execution.RDDConversions
  • org.apache.spark.mllib.rdd.RDDFunctions<T> (implements scala.Serializable)
  • org.apache.spark.storage.RDDInfo (implements scala.math.Ordered<A>)
  • parquet.hadoop.api.ReadSupport<T>
    • org.apache.spark.sql.parquet.RowReadSupport (implements org.apache.spark.Logging)
  • org.apache.spark.RealClock (implements org.apache.spark.Clock)
  • org.apache.spark.mllib.evaluation.binary.Recall (implements org.apache.spark.mllib.evaluation.binary.BinaryClassificationMetricComputer)
  • org.apache.spark.streaming.scheduler.ReceivedBlockInfo (implements scala.Product, scala.Serializable)
  • org.apache.spark.streaming.scheduler.ReceivedBlockTracker (implements org.apache.spark.Logging)
  • org.apache.spark.streaming.receiver.Receiver<T> (implements scala.Serializable)
    • org.apache.spark.streaming.receiver.ActorReceiver<T> (implements org.apache.spark.Logging)
    • org.apache.spark.streaming.flume.FlumePollingReceiver (implements org.apache.spark.Logging)
    • org.apache.spark.streaming.flume.FlumeReceiver (implements org.apache.spark.Logging)
    • org.apache.spark.streaming.kafka.KafkaReceiver<K,V,U,T> (implements org.apache.spark.Logging)
    • org.apache.spark.streaming.kinesis.KinesisReceiver (implements org.apache.spark.Logging)
    • org.apache.spark.streaming.mqtt.MQTTReceiver
    • org.apache.spark.streaming.dstream.RawNetworkReceiver (implements org.apache.spark.Logging)
    • org.apache.spark.streaming.kafka.ReliableKafkaReceiver<K,V,U,T> (implements org.apache.spark.Logging)
    • org.apache.spark.streaming.dstream.SocketReceiver<T> (implements org.apache.spark.Logging)
    • org.apache.spark.streaming.twitter.TwitterReceiver (implements org.apache.spark.Logging)
  • org.apache.spark.streaming.scheduler.ReceiverInfo (implements scala.Product, scala.Serializable)
  • org.apache.spark.streaming.receiver.ReceiverSupervisor (implements org.apache.spark.Logging)
    • org.apache.spark.streaming.receiver.ReceiverSupervisorImpl (implements org.apache.spark.Logging)
  • org.apache.spark.streaming.scheduler.ReceiverTracker (implements org.apache.spark.Logging)
  • org.apache.spark.streaming.scheduler.ReceiverTracker.ReceiverLauncher
  • parquet.io.api.RecordMaterializer<T>
    • org.apache.spark.sql.parquet.RowRecordMaterializer
  • org.apache.hadoop.mapreduce.RecordReader<KEYIN,VALUEIN> (implements java.io.Closeable)
    • org.apache.hadoop.mapreduce.lib.input.CombineFileRecordReader<K,V>
      • org.apache.spark.input.WholeCombineFileRecordReader (implements org.apache.hadoop.conf.Configurable)
    • org.apache.spark.input.FixedLengthBinaryRecordReader
    • org.apache.spark.input.StreamBasedRecordReader<T>
      • org.apache.spark.input.StreamRecordReader
    • org.apache.spark.input.WholeTextFileRecordReader (implements org.apache.hadoop.conf.Configurable)
  • org.apache.spark.streaming.util.RecurringTimer (implements org.apache.spark.Logging)
  • java.lang.ref.Reference<T>
    • java.lang.ref.WeakReference<T>
      • org.apache.spark.CleanupTaskWeakReference
  • org.apache.spark.streaming.scheduler.RegisterReceiver (implements scala.Product, org.apache.spark.streaming.scheduler.ReceiverTrackerMessage, scala.Serializable)
  • org.apache.spark.mllib.evaluation.RegressionMetrics (implements org.apache.spark.Logging)
  • org.apache.spark.scheduler.ReplayListenerBus (implements org.apache.spark.Logging, org.apache.spark.scheduler.SparkListenerBus)
  • org.apache.spark.graphx.impl.ReplicatedVertexView<VD,ED>
  • org.apache.spark.streaming.scheduler.ReportError (implements scala.Product, scala.Serializable)
  • com.twitter.chill.ResourcePool<T>
    • org.apache.spark.sql.execution.KryoResourcePool
  • org.apache.spark.scheduler.ResubmitFailedStages (implements org.apache.spark.scheduler.DAGSchedulerEvent, scala.Product, scala.Serializable)
  • org.apache.spark.Resubmitted (implements scala.Product, scala.Serializable, org.apache.spark.TaskFailedReason)
  • org.apache.spark.storage.ResultWithDroppedBlocks (implements scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.local.ReviveOffers (implements scala.Product, scala.Serializable)
  • org.apache.spark.graphx.impl.RoutingTablePartition (implements scala.Serializable)
  • org.apache.spark.sql.api.java.Row (implements scala.Serializable)
  • org.apache.spark.mllib.linalg.distributed.RowMatrix (implements org.apache.spark.mllib.linalg.distributed.DistributedMatrix, org.apache.spark.Logging)
  • org.apache.spark.sql.catalyst.rules.Rule<TreeType> (implements org.apache.spark.Logging)
    • org.apache.spark.sql.execution.AddExchange (implements scala.Product, scala.Serializable)
    • org.apache.spark.sql.execution.ExtractPythonUdfs
    • org.apache.spark.sql.hive.HiveMetastoreCatalog.CreateTables
    • org.apache.spark.sql.hive.HiveMetastoreCatalog.PreInsertionCasts
  • org.apache.spark.sql.columnar.compression.RunLengthEncoding (implements org.apache.spark.sql.columnar.compression.CompressionScheme, scala.Product, scala.Serializable)
  • org.apache.spark.sql.columnar.compression.RunLengthEncoding.Decoder<T> (implements org.apache.spark.sql.columnar.compression.Decoder<T>)
  • org.apache.spark.sql.columnar.compression.RunLengthEncoding.Encoder<T> (implements org.apache.spark.sql.columnar.compression.Encoder<T>)
  • org.apache.spark.scheduler.RuntimePercentage (implements scala.Product, scala.Serializable)
  • org.apache.spark.rdd.SampledRDDPartition (implements org.apache.spark.Partition, scala.Serializable)
  • org.apache.spark.util.random.SamplingUtils
  • org.apache.spark.streaming.Seconds
  • org.apache.spark.SecurityManager (implements org.apache.spark.Logging, org.apache.spark.network.sasl.SecretKeyHolder)
  • org.apache.spark.rdd.SequenceFileRDDFunctions<K,V> (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.util.SerializableBuffer (implements scala.Serializable)
  • org.apache.spark.SerializableWritable<T> (implements java.io.Serializable)
  • org.apache.spark.serializer.SerializationStream
    • org.apache.spark.serializer.JavaSerializationStream
    • org.apache.spark.serializer.KryoSerializationStream
  • com.esotericsoftware.kryo.Serializer<T>
    • org.apache.spark.sql.execution.BigDecimalSerializer
    • org.apache.spark.sql.execution.HyperLogLogSerializer
    • org.apache.spark.sql.execution.IntegerHashSetSerializer
    • org.apache.spark.serializer.JavaIterableWrapperSerializer
    • org.apache.spark.sql.execution.LongHashSetSerializer
    • org.apache.spark.sql.execution.OpenHashSetSerializer
  • 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.sql.execution.SparkSqlSerializer
  • org.apache.spark.serializer.SerializerInstance
    • org.apache.spark.serializer.JavaSerializerInstance
    • org.apache.spark.serializer.KryoSerializerInstance
  • org.apache.spark.ui.ServerInfo (implements scala.Product, scala.Serializable)
  • org.apache.spark.sql.hive.ShimFileSinkDesc (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.graphx.impl.ShippableVertexPartition.ShippableVertexPartitionOpsConstructor$ (implements org.apache.spark.graphx.impl.VertexPartitionBaseOpsConstructor<T>)
  • org.apache.spark.sql.columnar.ShortColumnStats (implements org.apache.spark.sql.columnar.ColumnStats)
  • org.apache.spark.graphx.lib.ShortestPaths
  • org.apache.spark.storage.ShuffleBlockFetcherIterator (implements scala.collection.Iterator<A>, org.apache.spark.Logging)
  • org.apache.spark.storage.ShuffleBlockFetcherIterator.FailureFetchResult (implements scala.Product, scala.Serializable, org.apache.spark.storage.ShuffleBlockFetcherIterator.FetchResult)
  • org.apache.spark.storage.ShuffleBlockFetcherIterator.FetchRequest (implements scala.Product, scala.Serializable)
  • org.apache.spark.storage.ShuffleBlockFetcherIterator.SuccessFetchResult (implements scala.Product, scala.Serializable, org.apache.spark.storage.ShuffleBlockFetcherIterator.FetchResult)
  • org.apache.spark.rdd.ShuffleCoGroupSplitDep (implements org.apache.spark.rdd.CoGroupSplitDep, scala.Product, scala.Serializable)
  • org.apache.spark.rdd.ShuffledRDDPartition (implements org.apache.spark.Partition)
  • org.apache.spark.util.SignalLogger
  • org.apache.spark.util.SignalLoggerHandler (implements sun.misc.SignalHandler)
  • org.apache.spark.SimpleFutureAction<T> (implements org.apache.spark.FutureAction<T>)
  • org.apache.spark.streaming.receiver.SingleItemData<T> (implements org.apache.spark.streaming.receiver.ActorReceiverData, scala.Product, scala.Serializable)
  • org.apache.spark.mllib.linalg.SingularValueDecomposition<UType,VType> (implements scala.Product, scala.Serializable)
  • org.apache.spark.util.logging.SizeBasedRollingPolicy (implements org.apache.spark.Logging, org.apache.spark.util.logging.RollingPolicy)
  • org.apache.spark.util.SizeEstimator (implements org.apache.spark.Logging)
  • org.apache.spark.mllib.rdd.SlidingRDDPartition<T> (implements org.apache.spark.Partition, scala.Serializable)
  • 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.ExecutorAllocationClient, 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.util.SparkExitCode
  • org.apache.spark.SparkFiles
  • org.apache.spark.streaming.flume.SparkFlumeEvent (implements java.io.Externalizable)
  • org.apache.spark.SparkHadoopWriter (implements org.apache.spark.Logging, scala.Serializable, org.apache.spark.mapred.SparkHadoopMapRedUtil)
  • org.apache.spark.sql.hive.SparkHiveWriterContainer (implements org.apache.spark.Logging, scala.Serializable, org.apache.spark.mapred.SparkHadoopMapRedUtil)
    • org.apache.spark.sql.hive.SparkHiveDynamicPartitionWriterContainer
  • org.apache.spark.SparkJobInfoImpl (implements org.apache.spark.SparkJobInfo)
  • 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.SparkListenerExecutorMetricsUpdate (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.SparkListenerShutdown (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.SparkStageInfoImpl (implements org.apache.spark.SparkStageInfo)
  • org.apache.spark.SparkStatusTracker
  • org.apache.spark.util.SparkUncaughtExceptionHandler (implements org.apache.spark.Logging, Thread.UncaughtExceptionHandler)
  • 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.mllib.stat.correlation.SpearmanCorrelation (implements org.apache.spark.mllib.stat.correlation.Correlation, org.apache.spark.Logging)
  • org.apache.spark.mllib.tree.model.Split (implements scala.Product, scala.Serializable)
    • org.apache.spark.mllib.tree.model.DummyCategoricalSplit
    • org.apache.spark.mllib.tree.model.DummyHighSplit
    • org.apache.spark.mllib.tree.model.DummyLowSplit
  • org.apache.spark.scheduler.SplitInfo
  • org.apache.spark.sql.SQLConf.Deprecated$
  • org.apache.spark.sql.SQLContext (implements org.apache.spark.sql.CacheManager, org.apache.spark.Logging, scala.Serializable, org.apache.spark.sql.SQLConf, org.apache.spark.sql.UDFRegistration)
    • org.apache.spark.sql.hive.HiveContext
      • org.apache.spark.sql.hive.LocalHiveContext
      • org.apache.spark.sql.hive.test.TestHiveContext
        • org.apache.spark.sql.hive.test.TestHive
    • org.apache.spark.sql.test.TestSQLContext
  • org.apache.spark.mllib.tree.loss.SquaredError (implements org.apache.spark.mllib.tree.loss.Loss)
  • org.apache.spark.scheduler.Stage (implements org.apache.spark.Logging)
  • org.apache.spark.scheduler.StageCancelled (implements org.apache.spark.scheduler.DAGSchedulerEvent, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.StageInfo
  • org.apache.spark.ui.jobs.StageTableBase
    • org.apache.spark.ui.jobs.FailedStageTable
  • 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)
  • scala.util.parsing.combinator.syntactical.StandardTokenParsers (implements scala.util.parsing.combinator.syntactical.StdTokenParsers)
    • org.apache.spark.sql.catalyst.AbstractSparkSQLParser (implements scala.util.parsing.combinator.PackratParsers)
      • org.apache.spark.sql.hive.ExtendedHiveQlParser
    • org.apache.spark.sql.sources.DDLParser (implements org.apache.spark.Logging, scala.util.parsing.combinator.PackratParsers)
  • 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.local.StopExecutor (implements scala.Product, scala.Serializable)
  • org.apache.spark.StopMapOutputTracker (implements org.apache.spark.MapOutputTrackerMessage, scala.Product, scala.Serializable)
  • org.apache.spark.streaming.receiver.StopReceiver (implements org.apache.spark.streaming.receiver.ReceiverMessage)
  • 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.storage.StorageUtils
  • org.apache.spark.mllib.tree.configuration.Strategy (implements scala.Serializable)
  • org.apache.spark.util.random.StratifiedSamplingUtils (implements org.apache.spark.Logging)
  • org.apache.spark.streaming.StreamingContext (implements org.apache.spark.Logging)
  • org.apache.spark.examples.streaming.StreamingExamples (implements org.apache.spark.Logging)
  • org.apache.spark.streaming.ui.StreamingJobProgressListener (implements org.apache.spark.streaming.scheduler.StreamingListener)
  • org.apache.spark.mllib.clustering.StreamingKMeans (implements org.apache.spark.Logging)
  • 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.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.StreamingListenerBus (implements org.apache.spark.Logging)
  • 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.StreamingListenerShutdown (implements scala.Product, scala.Serializable, org.apache.spark.streaming.scheduler.StreamingListenerEvent)
  • org.apache.spark.streaming.StreamingSource (implements org.apache.spark.metrics.source.Source)
  • org.apache.spark.sql.columnar.StringColumnStats (implements org.apache.spark.sql.columnar.ColumnStats)
  • org.apache.spark.graphx.lib.StronglyConnectedComponents
  • org.apache.spark.sql.api.java.StructField
  • org.apache.spark.partial.StudentTCacher
  • org.apache.spark.Success (implements scala.Product, scala.Serializable, org.apache.spark.TaskEndReason)
  • org.apache.spark.partial.SumEvaluator (implements org.apache.spark.partial.ApproximateEvaluator<U,R>)
  • 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.util.SystemClock (implements org.apache.spark.util.Clock)
  • org.apache.spark.streaming.util.SystemClock (implements org.apache.spark.streaming.util.Clock)
  • org.apache.spark.storage.TachyonBlockManager (implements org.apache.spark.Logging)
  • org.apache.spark.storage.TachyonFileSegment
  • org.apache.spark.scheduler.Task<T> (implements scala.Serializable)
    • org.apache.spark.scheduler.ResultTask<T,U> (implements java.io.Serializable)
    • org.apache.spark.scheduler.ShuffleMapTask (implements org.apache.spark.Logging)
  • org.apache.spark.TaskContext (implements java.io.Serializable)
    • org.apache.spark.TaskContextImpl (implements org.apache.spark.Logging)
  • org.apache.spark.TaskContextHelper
  • org.apache.spark.scheduler.TaskDescription (implements scala.Serializable)
  • org.apache.spark.ui.jobs.TaskDetailsClassNames
  • org.apache.spark.scheduler.TaskInfo
  • org.apache.spark.TaskKilled (implements scala.Product, scala.Serializable, org.apache.spark.TaskFailedReason)
  • org.apache.spark.scheduler.TaskResultGetter (implements org.apache.spark.Logging)
  • org.apache.spark.TaskResultLost (implements scala.Product, scala.Serializable, org.apache.spark.TaskFailedReason)
  • org.apache.spark.scheduler.TaskSchedulerImpl (implements org.apache.spark.Logging, org.apache.spark.scheduler.TaskScheduler)
  • org.apache.spark.scheduler.TaskSet
  • org.apache.spark.scheduler.TaskSetFailed (implements org.apache.spark.scheduler.DAGSchedulerEvent, scala.Product, scala.Serializable)
  • org.apache.spark.scheduler.TaskSetManager (implements org.apache.spark.Logging, org.apache.spark.scheduler.Schedulable)
  • org.apache.spark.TestClock (implements org.apache.spark.Clock)
  • org.apache.spark.sql.hive.test.TestHiveContext.QueryExecution
  • org.apache.spark.sql.hive.test.TestHiveContext.TestTable (implements scala.Product, scala.Serializable)
  • org.apache.spark.TestUtils
  • Thread (implements Runnable)
    • org.apache.spark.util.RedirectThread
  • org.apache.spark.util.ThreadStackTrace (implements scala.Product, scala.Serializable)
  • Throwable (implements java.io.Serializable)
    • Exception
      • org.apache.spark.storage.BlockException (implements scala.Product, scala.Serializable)
      • org.apache.spark.storage.BlockNotFoundException
      • org.apache.spark.sql.hive.HiveQl.ParseException
      • org.apache.spark.sql.hive.HiveQl.SemanticException
      • org.apache.spark.sql.execution.QueryExecutionException
      • RuntimeException
        • org.apache.spark.TaskKilledException
      • org.apache.spark.ServerStateException
      • org.apache.spark.SparkException
        • org.apache.spark.SparkDriverExecutionException
      • org.apache.spark.util.TaskCompletionListenerException
  • org.apache.spark.streaming.Time (implements scala.Product, scala.Serializable)
  • org.apache.spark.util.logging.TimeBasedRollingPolicy (implements org.apache.spark.Logging, org.apache.spark.util.logging.RollingPolicy)
  • org.apache.spark.sql.columnar.TimestampColumnStats (implements org.apache.spark.sql.columnar.ColumnStats)
  • org.apache.spark.util.TimeStampedHashMap<A,B> (implements org.apache.spark.Logging, scala.collection.mutable.Map<A,B>)
  • org.apache.spark.util.TimeStampedHashSet<A> (implements scala.collection.mutable.Set<A>)
  • org.apache.spark.util.TimeStampedValue<V> (implements scala.Product, scala.Serializable)
  • org.apache.spark.util.TimeStampedWeakValueHashMap<A,B> (implements org.apache.spark.Logging, scala.collection.mutable.Map<A,B>)
  • org.apache.spark.mllib.tree.impl.TimeTracker (implements scala.Serializable)
  • org.apache.spark.ui.ToolTips
  • org.apache.spark.broadcast.TorrentBroadcastFactory (implements org.apache.spark.broadcast.BroadcastFactory)
  • org.apache.spark.mllib.tree.model.TreeEnsembleModel (implements scala.Serializable)
    • org.apache.spark.mllib.tree.model.GradientBoostedTreesModel
    • org.apache.spark.mllib.tree.model.RandomForestModel
  • org.apache.spark.sql.catalyst.trees.TreeNode<BaseType>
    • org.apache.spark.sql.catalyst.expressions.Expression
      • org.apache.spark.sql.catalyst.expressions.AggregateExpression
        • org.apache.spark.sql.catalyst.expressions.AggregateFunction (implements org.apache.spark.sql.catalyst.trees.LeafNode<BaseType>, scala.Serializable)
          • org.apache.spark.sql.hive.HiveUdafFunction (implements org.apache.spark.sql.hive.HiveInspectors, scala.Product, scala.Serializable)
        • org.apache.spark.sql.hive.HiveGenericUdaf (implements org.apache.spark.sql.hive.HiveInspectors, scala.Product, scala.Serializable)
        • org.apache.spark.sql.hive.HiveUdaf (implements org.apache.spark.sql.hive.HiveInspectors, scala.Product, scala.Serializable)
      • org.apache.spark.sql.catalyst.expressions.Generator
        • org.apache.spark.sql.hive.HiveGenericUdtf (implements org.apache.spark.sql.hive.HiveInspectors, scala.Product, scala.Serializable)
      • org.apache.spark.sql.hive.HiveGenericUdf (implements org.apache.spark.sql.hive.HiveInspectors, org.apache.spark.Logging, scala.Product, scala.Serializable)
      • org.apache.spark.sql.hive.HiveSimpleUdf (implements org.apache.spark.sql.hive.HiveInspectors, org.apache.spark.Logging, scala.Product, scala.Serializable)
      • org.apache.spark.sql.execution.PythonUDF (implements org.apache.spark.Logging, scala.Product, scala.Serializable)
    • org.apache.spark.sql.catalyst.plans.QueryPlan<PlanType>
      • org.apache.spark.sql.catalyst.plans.logical.LogicalPlan (implements org.apache.spark.Logging)
        • org.apache.spark.sql.columnar.InMemoryRelation (implements org.apache.spark.sql.catalyst.analysis.MultiInstanceRelation, scala.Product, scala.Serializable)
        • org.apache.spark.sql.hive.InsertIntoHiveTable (implements scala.Product, scala.Serializable)
        • org.apache.spark.sql.catalyst.plans.logical.LeafNode (implements org.apache.spark.sql.catalyst.trees.LeafNode<BaseType>)
          • org.apache.spark.sql.catalyst.plans.logical.Command
            • org.apache.spark.sql.hive.AddFile (implements scala.Product, scala.Serializable)
            • org.apache.spark.sql.hive.AddJar (implements scala.Product, scala.Serializable)
            • org.apache.spark.sql.hive.AnalyzeTable (implements scala.Product, scala.Serializable)
            • org.apache.spark.sql.sources.CreateTableUsing (implements scala.Product, org.apache.spark.sql.execution.RunnableCommand, scala.Serializable)
            • org.apache.spark.sql.hive.DropTable (implements scala.Product, scala.Serializable)
            • org.apache.spark.sql.hive.NativePlaceholder (implements scala.Product, scala.Serializable)
          • org.apache.spark.sql.sources.LogicalRelation (implements org.apache.spark.sql.catalyst.analysis.MultiInstanceRelation, scala.Product, scala.Serializable)
          • org.apache.spark.sql.hive.MetastoreRelation (implements scala.Product, scala.Serializable)
          • org.apache.spark.sql.parquet.ParquetRelation (implements org.apache.spark.sql.catalyst.analysis.MultiInstanceRelation, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.LogicalRDD (implements org.apache.spark.sql.catalyst.analysis.MultiInstanceRelation, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.SparkLogicalPlan (implements org.apache.spark.sql.catalyst.analysis.MultiInstanceRelation, scala.Product, scala.Serializable)
        • org.apache.spark.sql.catalyst.plans.logical.UnaryNode (implements org.apache.spark.sql.catalyst.trees.UnaryNode<BaseType>)
          • org.apache.spark.sql.execution.EvaluatePython (implements scala.Product, scala.Serializable)
      • org.apache.spark.sql.execution.SparkPlan (implements org.apache.spark.Logging, scala.Serializable)
        • org.apache.spark.sql.hive.execution.AddFile (implements org.apache.spark.sql.execution.Command, org.apache.spark.sql.execution.LeafNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.hive.execution.AddJar (implements org.apache.spark.sql.execution.Command, org.apache.spark.sql.execution.LeafNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.Aggregate (implements scala.Product, scala.Serializable, org.apache.spark.sql.execution.UnaryNode)
        • org.apache.spark.sql.hive.execution.AnalyzeTable (implements org.apache.spark.sql.execution.Command, org.apache.spark.sql.execution.LeafNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.BatchPythonEvaluation (implements scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.joins.BroadcastHashJoin (implements org.apache.spark.sql.execution.BinaryNode, org.apache.spark.sql.execution.joins.HashJoin, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.joins.BroadcastNestedLoopJoin (implements org.apache.spark.sql.execution.BinaryNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.CacheTableCommand (implements org.apache.spark.sql.execution.Command, org.apache.spark.sql.execution.LeafNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.joins.CartesianProduct (implements org.apache.spark.sql.execution.BinaryNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.hive.execution.CreateTableAsSelect (implements org.apache.spark.sql.execution.Command, org.apache.spark.sql.execution.LeafNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.DescribeCommand (implements org.apache.spark.sql.execution.Command, org.apache.spark.sql.execution.LeafNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.hive.execution.DescribeHiveTableCommand (implements org.apache.spark.sql.execution.Command, org.apache.spark.sql.execution.LeafNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.Distinct (implements scala.Product, scala.Serializable, org.apache.spark.sql.execution.UnaryNode)
        • org.apache.spark.sql.hive.execution.DropTable (implements org.apache.spark.sql.execution.Command, org.apache.spark.sql.execution.LeafNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.Except (implements org.apache.spark.sql.execution.BinaryNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.Exchange (implements scala.Product, scala.Serializable, org.apache.spark.sql.execution.UnaryNode)
        • org.apache.spark.sql.execution.ExecutedCommand (implements scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.ExistingRdd (implements org.apache.spark.sql.execution.LeafNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.ExplainCommand (implements org.apache.spark.sql.execution.Command, org.apache.spark.sql.execution.LeafNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.ExternalSort (implements scala.Product, scala.Serializable, org.apache.spark.sql.execution.UnaryNode)
        • org.apache.spark.sql.execution.Filter (implements scala.Product, scala.Serializable, org.apache.spark.sql.execution.UnaryNode)
        • org.apache.spark.sql.execution.Generate (implements scala.Product, scala.Serializable, org.apache.spark.sql.execution.UnaryNode)
        • org.apache.spark.sql.execution.GeneratedAggregate (implements scala.Product, scala.Serializable, org.apache.spark.sql.execution.UnaryNode)
        • org.apache.spark.sql.execution.joins.HashOuterJoin (implements org.apache.spark.sql.execution.BinaryNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.hive.execution.HiveTableScan (implements org.apache.spark.sql.execution.LeafNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.columnar.InMemoryColumnarTableScan (implements org.apache.spark.sql.execution.LeafNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.hive.execution.InsertIntoHiveTable (implements org.apache.spark.sql.execution.Command, org.apache.spark.sql.hive.HiveInspectors, scala.Product, scala.Serializable, org.apache.spark.sql.execution.UnaryNode)
        • org.apache.spark.sql.parquet.InsertIntoParquetTable (implements scala.Product, scala.Serializable, org.apache.spark.mapreduce.SparkHadoopMapReduceUtil, org.apache.spark.sql.execution.UnaryNode)
        • org.apache.spark.sql.execution.Intersect (implements org.apache.spark.sql.execution.BinaryNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.joins.LeftSemiJoinBNL (implements org.apache.spark.sql.execution.BinaryNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.joins.LeftSemiJoinHash (implements org.apache.spark.sql.execution.BinaryNode, org.apache.spark.sql.execution.joins.HashJoin, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.Limit (implements scala.Product, scala.Serializable, org.apache.spark.sql.execution.UnaryNode)
        • org.apache.spark.sql.hive.execution.NativeCommand (implements org.apache.spark.sql.execution.Command, org.apache.spark.sql.execution.LeafNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.OutputFaker (implements scala.Product, scala.Serializable)
        • org.apache.spark.sql.parquet.ParquetTableScan (implements org.apache.spark.sql.execution.LeafNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.PhysicalRDD (implements org.apache.spark.sql.execution.LeafNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.Project (implements scala.Product, scala.Serializable, org.apache.spark.sql.execution.UnaryNode)
        • org.apache.spark.sql.execution.Sample (implements scala.Product, scala.Serializable, org.apache.spark.sql.execution.UnaryNode)
        • org.apache.spark.sql.hive.execution.ScriptTransformation (implements scala.Product, scala.Serializable, org.apache.spark.sql.execution.UnaryNode)
        • org.apache.spark.sql.execution.SetCommand (implements org.apache.spark.sql.execution.Command, org.apache.spark.sql.execution.LeafNode, org.apache.spark.Logging, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.joins.ShuffledHashJoin (implements org.apache.spark.sql.execution.BinaryNode, org.apache.spark.sql.execution.joins.HashJoin, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.Sort (implements scala.Product, scala.Serializable, org.apache.spark.sql.execution.UnaryNode)
        • org.apache.spark.sql.execution.TakeOrdered (implements scala.Product, scala.Serializable, org.apache.spark.sql.execution.UnaryNode)
        • org.apache.spark.sql.execution.UncacheTableCommand (implements org.apache.spark.sql.execution.Command, org.apache.spark.sql.execution.LeafNode, scala.Product, scala.Serializable)
        • org.apache.spark.sql.execution.Union (implements scala.Product, scala.Serializable)
  • org.apache.spark.mllib.tree.impl.TreePoint (implements scala.Serializable)
  • 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.api.java.UDTWrappers
  • org.apache.spark.ui.jobs.UIData
  • org.apache.spark.ui.jobs.UIData.ExecutorSummary
  • org.apache.spark.ui.jobs.UIData.JobUIData
  • org.apache.spark.ui.jobs.UIData.JobUIData$
  • org.apache.spark.ui.jobs.UIData.StageUIData
  • org.apache.spark.ui.jobs.UIData.TaskUIData (implements scala.Product, scala.Serializable)
  • org.apache.spark.ui.UIUtils (implements org.apache.spark.Logging)
  • org.apache.spark.ui.UIWorkloadGenerator
  • org.apache.spark.mllib.random.UniformGenerator (implements org.apache.spark.mllib.random.RandomDataGenerator<T>)
  • org.apache.spark.rdd.UnionPartition<T> (implements org.apache.spark.Partition)
  • org.apache.spark.sql.execution.joins.UniqueKeyHashedRelation (implements org.apache.spark.sql.execution.joins.HashedRelation, scala.Serializable)
  • 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.util.Utils (implements org.apache.spark.Logging)
  • 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.mllib.linalg.Vectors
  • org.apache.spark.mllib.clustering.VectorWithNorm (implements scala.Serializable)
  • org.apache.spark.graphx.impl.VertexAttributeBlock<VD> (implements scala.Serializable)
  • org.apache.spark.graphx.impl.VertexPartition.VertexPartitionOpsConstructor$ (implements org.apache.spark.graphx.impl.VertexPartitionBaseOpsConstructor<T>)
  • org.apache.spark.graphx.impl.VertexPartitionBase<VD> (implements scala.Serializable)
    • org.apache.spark.graphx.impl.ShippableVertexPartition<VD>
    • org.apache.spark.graphx.impl.VertexPartition<VD>
  • org.apache.spark.graphx.impl.VertexPartitionBaseOps<VD,Self> (implements org.apache.spark.Logging, scala.Serializable)
    • org.apache.spark.graphx.impl.ShippableVertexPartitionOps<VD>
    • org.apache.spark.graphx.impl.VertexPartitionOps<VD>
  • org.apache.spark.mllib.feature.VocabWord (implements scala.Product, scala.Serializable)
  • org.apache.spark.ui.WebUI (implements org.apache.spark.Logging)
    • org.apache.spark.ui.SparkUI (implements org.apache.spark.Logging)
  • org.apache.spark.ui.WebUIPage
    • org.apache.spark.ui.jobs.AllJobsPage
    • org.apache.spark.ui.jobs.AllStagesPage
    • org.apache.spark.ui.env.EnvironmentPage
    • org.apache.spark.ui.exec.ExecutorsPage
    • org.apache.spark.ui.exec.ExecutorThreadDumpPage
    • org.apache.spark.ui.jobs.JobPage
    • org.apache.spark.ui.jobs.PoolPage
    • org.apache.spark.ui.storage.RDDPage
    • org.apache.spark.ui.jobs.StagePage
    • org.apache.spark.ui.storage.StoragePage
    • org.apache.spark.streaming.ui.StreamingPage (implements org.apache.spark.Logging)
  • org.apache.spark.ui.WebUITab
    • org.apache.spark.ui.SparkUITab
      • org.apache.spark.ui.env.EnvironmentTab
      • org.apache.spark.ui.exec.ExecutorsTab
      • org.apache.spark.ui.jobs.JobsTab
      • org.apache.spark.ui.jobs.StagesTab
      • org.apache.spark.ui.storage.StorageTab
      • org.apache.spark.streaming.ui.StreamingTab (implements org.apache.spark.Logging)
  • org.apache.spark.mllib.feature.Word2Vec (implements org.apache.spark.Logging, scala.Serializable)
  • org.apache.spark.mllib.feature.Word2VecModel (implements scala.Serializable)
  • org.apache.spark.scheduler.WorkerOffer (implements scala.Product, scala.Serializable)
  • org.apache.spark.WritableConverter<T> (implements java.io.Serializable)
  • org.apache.spark.streaming.rdd.WriteAheadLogBackedBlockRDDPartition (implements org.apache.spark.Partition)
  • org.apache.spark.streaming.receiver.WriteAheadLogBasedBlockHandler (implements org.apache.spark.Logging, org.apache.spark.streaming.receiver.ReceivedBlockHandler)
  • org.apache.spark.streaming.receiver.WriteAheadLogBasedStoreResult (implements scala.Product, org.apache.spark.streaming.receiver.ReceivedBlockStoreResult, scala.Serializable)
  • org.apache.spark.streaming.util.WriteAheadLogFileSegment (implements scala.Product, scala.Serializable)
  • org.apache.spark.streaming.util.WriteAheadLogManager (implements org.apache.spark.Logging)
  • org.apache.spark.streaming.util.WriteAheadLogManager.LogInfo (implements scala.Product, scala.Serializable)
  • org.apache.spark.streaming.util.WriteAheadLogRandomReader (implements java.io.Closeable)
  • org.apache.spark.streaming.util.WriteAheadLogReader (implements java.io.Closeable, scala.collection.Iterator<A>, org.apache.spark.Logging)
  • org.apache.spark.streaming.util.WriteAheadLogWriter (implements java.io.Closeable)
  • parquet.hadoop.api.WriteSupport<T>
    • org.apache.spark.sql.parquet.RowWriteSupport (implements org.apache.spark.Logging)
      • org.apache.spark.sql.parquet.MutableRowWriteSupport
    • org.apache.spark.sql.parquet.TestGroupWriteSupport
  • org.apache.spark.streaming.zeromq.ZeroMQReceiver<T> (implements akka.actor.Actor, org.apache.spark.streaming.receiver.ActorHelper, org.apache.spark.Logging)
  • org.apache.spark.streaming.zeromq.ZeroMQUtils
  • org.apache.spark.rdd.ZippedPartitionsPartition (implements org.apache.spark.Partition)
  • org.apache.spark.rdd.ZippedWithIndexRDDPartition (implements org.apache.spark.Partition, scala.Serializable)

Interface Hierarchy

• org.apache.spark.util.ActorLogReceive
• org.apache.spark.streaming.receiver.ActorReceiverData
• org.apache.spark.partial.ApproximateEvaluator<U,R>
• scala.concurrent.Awaitable<T>
  • scala.concurrent.Future<T>
    • org.apache.spark.FutureAction<T>
• org.apache.spark.mllib.evaluation.binary.BinaryConfusionMatrix
• org.apache.spark.sql.catalyst.trees.BinaryNode<BaseType>
  • org.apache.spark.sql.execution.BinaryNode
• org.apache.spark.streaming.receiver.BlockGeneratorListener
• org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster
• org.apache.spark.storage.BlockManagerMessages.ToBlockManagerSlave
• org.apache.spark.storage.BlockValues
• org.apache.spark.broadcast.BroadcastFactory
• org.apache.spark.sql.CacheManager
• org.apache.spark.CleanerListener
• org.apache.spark.CleanupTask
• org.apache.spark.Clock
• org.apache.spark.util.Clock
• org.apache.spark.streaming.util.Clock
• Cloneable
  • scala.Cloneable
    • org.apache.spark.util.random.RandomSampler<T,U> (also extends org.apache.spark.util.random.Pseudorandom, scala.Serializable)
• org.apache.spark.sql.columnar.ColumnAccessor
  • org.apache.spark.sql.columnar.compression.CompressibleColumnAccessor<T>
  • org.apache.spark.sql.columnar.NullableColumnAccessor
• org.apache.spark.sql.columnar.ColumnBuilder
  • org.apache.spark.sql.columnar.compression.CompressibleColumnBuilder<T> (also extends org.apache.spark.Logging)
  • org.apache.spark.sql.columnar.NullableColumnBuilder
• org.apache.spark.sql.execution.Command
• org.apache.spark.io.CompressionCodec
• org.apache.spark.sql.columnar.compression.CompressionScheme
• org.apache.spark.mllib.stat.correlation.Correlation
• org.apache.spark.scheduler.DAGSchedulerEvent
• org.apache.spark.sql.columnar.compression.Decoder<T>
• org.apache.spark.sql.columnar.compression.Encoder<T>
• java.util.EventListener
  • org.apache.spark.util.TaskCompletionListener
• org.apache.spark.ExecutorAllocationClient
• java.util.concurrent.Future<V>
  • org.apache.spark.api.java.JavaFutureAction<T>
• org.apache.spark.sql.execution.joins.HashedRelation
• org.apache.spark.sql.execution.joins.HashJoin
• org.apache.spark.sql.hive.HiveInspectors
• org.apache.spark.sql.hive.HiveStrategies
• org.apache.spark.streaming.api.java.JavaStreamingContextFactory
• org.apache.spark.streaming.scheduler.JobGeneratorEvent
• org.apache.spark.scheduler.JobListener
• org.apache.spark.scheduler.JobResult
• org.apache.spark.streaming.scheduler.JobSchedulerEvent
• org.apache.spark.serializer.KryoRegistrator
• org.apache.spark.sql.catalyst.trees.LeafNode<BaseType>
  • org.apache.spark.sql.execution.LeafNode
• org.apache.spark.Logging
  • org.apache.spark.streaming.receiver.ActorHelper
  • org.apache.spark.sql.columnar.compression.CompressibleColumnBuilder<T> (also extends org.apache.spark.sql.columnar.ColumnBuilder)
  • org.apache.spark.scheduler.SparkListenerBus
• org.apache.spark.MapOutputTrackerMessage
• org.apache.spark.scheduler.MapStatus
• org.apache.spark.mllib.stat.MultivariateStatisticalSummary
• 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.streaming.receiver.ReceivedBlock
• org.apache.spark.streaming.receiver.ReceivedBlockHandler
• org.apache.spark.streaming.receiver.ReceivedBlockStoreResult
• org.apache.spark.streaming.scheduler.ReceivedBlockTrackerLogEvent
• org.apache.spark.streaming.scheduler.ReceiverTrackerMessage
• org.apache.spark.sql.sources.RelationProvider
• org.apache.spark.util.logging.RollingPolicy
• org.apache.spark.sql.execution.RunnableCommand
• org.apache.spark.scheduler.Schedulable
• org.apache.spark.scheduler.SchedulableBuilder
• org.apache.spark.scheduler.SchedulerBackend
• org.apache.spark.scheduler.SchedulingAlgorithm
• org.apache.spark.sql.SchemaRDDLike
• 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.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.evaluation.binary.BinaryClassificationMetricComputer
    • org.apache.spark.mllib.classification.ClassificationModel
    • org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessage
    • org.apache.spark.rdd.CoGroupSplitDep
    • org.apache.spark.sql.columnar.ColumnStats
    • org.apache.spark.mllib.linalg.distributed.DistributedMatrix
    • org.apache.spark.ml.Identifiable
      • org.apache.spark.ml.tuning.CrossValidatorParams
      • org.apache.spark.ml.param.HasFeaturesCol
        • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.HasThreshold, org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.param.HasInputCol
        • org.apache.spark.ml.feature.StandardScalerParams (also extends org.apache.spark.ml.param.HasOutputCol, org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.param.HasLabelCol
        • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.HasThreshold, org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.param.HasMaxIter
        • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.HasThreshold, org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.param.HasOutputCol
        • org.apache.spark.ml.feature.StandardScalerParams (also extends org.apache.spark.ml.param.HasInputCol, org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.param.HasPredictionCol
        • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.HasThreshold, org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.param.HasRegParam
        • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.HasThreshold, org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.param.HasScoreCol
        • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasThreshold, org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.param.HasThreshold
        • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.HasThreshold, org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.param.Params (also extends scala.Serializable)
        • org.apache.spark.ml.tuning.CrossValidatorParams
        • org.apache.spark.ml.param.HasFeaturesCol
          • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.HasThreshold, org.apache.spark.ml.param.Params)
        • org.apache.spark.ml.param.HasInputCol
          • org.apache.spark.ml.feature.StandardScalerParams (also extends org.apache.spark.ml.param.HasOutputCol, org.apache.spark.ml.param.Params)
        • org.apache.spark.ml.param.HasLabelCol
          • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.HasThreshold, org.apache.spark.ml.param.Params)
        • org.apache.spark.ml.param.HasMaxIter
          • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.HasThreshold, org.apache.spark.ml.param.Params)
        • org.apache.spark.ml.param.HasOutputCol
          • org.apache.spark.ml.feature.StandardScalerParams (also extends org.apache.spark.ml.param.HasInputCol, org.apache.spark.ml.param.Params)
        • org.apache.spark.ml.param.HasPredictionCol
          • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.HasThreshold, org.apache.spark.ml.param.Params)
        • org.apache.spark.ml.param.HasRegParam
          • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.HasThreshold, org.apache.spark.ml.param.Params)
        • org.apache.spark.ml.param.HasScoreCol
          • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasThreshold, org.apache.spark.ml.param.Params)
        • org.apache.spark.ml.param.HasThreshold
          • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.Params)
        • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.HasThreshold)
        • org.apache.spark.ml.feature.StandardScalerParams (also extends org.apache.spark.ml.param.HasInputCol, org.apache.spark.ml.param.HasOutputCol)
      • org.apache.spark.ml.feature.StandardScalerParams (also extends org.apache.spark.ml.param.HasInputCol, org.apache.spark.ml.param.HasOutputCol, org.apache.spark.ml.param.Params)
    • 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.ml.param.Params (also extends org.apache.spark.ml.Identifiable)
      • org.apache.spark.ml.tuning.CrossValidatorParams
      • org.apache.spark.ml.param.HasFeaturesCol
        • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.HasThreshold, org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.param.HasInputCol
        • org.apache.spark.ml.feature.StandardScalerParams (also extends org.apache.spark.ml.param.HasOutputCol, org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.param.HasLabelCol
        • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.HasThreshold, org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.param.HasMaxIter
        • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.HasThreshold, org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.param.HasOutputCol
        • org.apache.spark.ml.feature.StandardScalerParams (also extends org.apache.spark.ml.param.HasInputCol, org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.param.HasPredictionCol
        • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.HasThreshold, org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.param.HasRegParam
        • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.HasThreshold, org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.param.HasScoreCol
        • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasThreshold, org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.param.HasThreshold
        • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.Params)
      • org.apache.spark.ml.classification.LogisticRegressionParams (also extends org.apache.spark.ml.param.HasFeaturesCol, org.apache.spark.ml.param.HasLabelCol, org.apache.spark.ml.param.HasMaxIter, org.apache.spark.ml.param.HasPredictionCol, org.apache.spark.ml.param.HasRegParam, org.apache.spark.ml.param.HasScoreCol, org.apache.spark.ml.param.HasThreshold)
      • org.apache.spark.ml.feature.StandardScalerParams (also extends org.apache.spark.ml.param.HasInputCol, org.apache.spark.ml.param.HasOutputCol)
    • 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.streaming.receiver.ReceiverMessage
    • org.apache.spark.mllib.regression.RegressionModel
    • 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.storage.ShuffleBlockFetcherIterator.FetchResult
• org.apache.spark.metrics.sink.Sink
• org.apache.spark.metrics.source.Source
• org.apache.spark.mapreduce.SparkHadoopMapReduceUtil
• org.apache.spark.mapred.SparkHadoopMapRedUtil
• org.apache.spark.scheduler.SparkListener
• org.apache.spark.scheduler.SparkListenerEvent
• org.apache.spark.sql.SQLConf
• org.apache.spark.streaming.scheduler.StreamingListener
• org.apache.spark.streaming.scheduler.StreamingListenerEvent
• org.apache.spark.sql.hive.TableReader
• org.apache.spark.TaskEndReason
  • org.apache.spark.TaskFailedReason
• org.apache.spark.scheduler.TaskLocation
• org.apache.spark.scheduler.TaskResult<T>
• org.apache.spark.scheduler.TaskScheduler
• org.apache.spark.mllib.stat.test.TestResult<DF>
• org.apache.spark.sql.UDFRegistration
• org.apache.spark.sql.api.java.UDFRegistration
• org.apache.spark.sql.catalyst.trees.UnaryNode<BaseType>
  • org.apache.spark.sql.execution.UnaryNode
• org.apache.spark.graphx.impl.VertexPartitionBaseOpsConstructor<T>
• org.apache.spark.sql.columnar.compression.WithCompressionSchemes
  • org.apache.spark.sql.columnar.compression.AllCompressionSchemes

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)

Enum Hierarchy

• Object
  • Enum<E> (implements Comparable<T>, java.io.Serializable)
    • org.apache.spark.JobExecutionStatus
    • org.apache.spark.graphx.impl.EdgeActiveness