Hierarchy For Package org.apache.spark

Package Hierarchies:

• All Packages

Class Hierarchy

• Object
  • org.apache.spark.Accumulable<R,T> (implements java.io.Serializable)
    • org.apache.spark.Accumulator<T>
  • org.apache.spark.AccumulatorParam.DoubleAccumulatorParam$ (implements org.apache.spark.AccumulatorParam<T>)
  • org.apache.spark.AccumulatorParam.FloatAccumulatorParam$ (implements org.apache.spark.AccumulatorParam<T>)
  • org.apache.spark.AccumulatorParam.IntAccumulatorParam$ (implements org.apache.spark.AccumulatorParam<T>)
  • org.apache.spark.AccumulatorParam.LongAccumulatorParam$ (implements org.apache.spark.AccumulatorParam<T>)
  • org.apache.spark.AccumulatorParam.StringAccumulatorParam$ (implements org.apache.spark.AccumulatorParam<T>)
  • org.apache.spark.Aggregator<K,V,C> (implements scala.Product, scala.Serializable)
  • org.apache.spark.BarrierTaskInfo
  • org.apache.spark.CleanAccum (implements org.apache.spark.CleanupTask, scala.Product, scala.Serializable)
  • org.apache.spark.CleanBroadcast (implements org.apache.spark.CleanupTask, scala.Product, scala.Serializable)
  • org.apache.spark.CleanCheckpoint (implements org.apache.spark.CleanupTask, scala.Product, scala.Serializable)
  • org.apache.spark.CleanRDD (implements org.apache.spark.CleanupTask, scala.Product, scala.Serializable)
  • org.apache.spark.CleanShuffle (implements org.apache.spark.CleanupTask, scala.Product, scala.Serializable)
  • org.apache.spark.ComplexFutureAction<T> (implements org.apache.spark.FutureAction<T>)
  • org.apache.spark.ContextBarrierId (implements scala.Product, scala.Serializable)
  • org.apache.spark.Dependency<T> (implements scala.Serializable)
    • org.apache.spark.NarrowDependency<T>
      • org.apache.spark.OneToOneDependency<T>
      • org.apache.spark.RangeDependency<T>
    • org.apache.spark.ShuffleDependency<K,V,C>
  • org.apache.spark.ExceptionFailure (implements scala.Product, scala.Serializable, org.apache.spark.TaskFailedReason)
  • org.apache.spark.ExecutorLostFailure (implements scala.Product, scala.Serializable, org.apache.spark.TaskFailedReason)
  • org.apache.spark.ExecutorRegistered (implements scala.Product, scala.Serializable)
  • org.apache.spark.ExecutorRemoved (implements scala.Product, scala.Serializable)
  • org.apache.spark.ExpireDeadHosts
  • org.apache.spark.FetchFailed (implements scala.Product, scala.Serializable, org.apache.spark.TaskFailedReason)
  • org.apache.spark.InternalAccumulator
  • org.apache.spark.InternalAccumulator.input$
  • org.apache.spark.InternalAccumulator.output$
  • org.apache.spark.InternalAccumulator.shuffleRead$
  • org.apache.spark.InternalAccumulator.shuffleWrite$
  • org.apache.spark.InterruptibleIterator<T> (implements scala.collection.Iterator<A>)
  • org.apache.spark.Partitioner (implements scala.Serializable)
    • org.apache.spark.HashPartitioner
    • org.apache.spark.RangePartitioner<K,V>
  • java.lang.ref.Reference<T>
    • java.lang.ref.WeakReference<T>
      • org.apache.spark.CleanupTaskWeakReference
  • org.apache.spark.Resubmitted
  • org.apache.spark.SerializableWritable<T> (implements java.io.Serializable)
  • org.apache.spark.ShuffleStatus
  • org.apache.spark.SimpleFutureAction<T> (implements org.apache.spark.FutureAction<T>)
  • org.apache.spark.SparkConf (implements scala.Cloneable, org.apache.spark.internal.Logging, scala.Serializable)
  • org.apache.spark.SparkContext (implements org.apache.spark.internal.Logging)
  • org.apache.spark.SparkEnv (implements org.apache.spark.internal.Logging)
  • org.apache.spark.SparkExecutorInfoImpl (implements org.apache.spark.SparkExecutorInfo)
  • org.apache.spark.SparkFiles
  • org.apache.spark.SparkFirehoseListener (implements org.apache.spark.scheduler.SparkListenerInterface)
  • org.apache.spark.SparkJobInfoImpl (implements org.apache.spark.SparkJobInfo)
  • org.apache.spark.scheduler.SparkListener (implements org.apache.spark.scheduler.SparkListenerInterface)
    • org.apache.spark.SpillListener
  • org.apache.spark.SparkMasterRegex
  • org.apache.spark.SparkStageInfoImpl (implements org.apache.spark.SparkStageInfo)
  • org.apache.spark.SparkStatusTracker
  • org.apache.spark.StopMapOutputTracker
  • org.apache.spark.Success
  • org.apache.spark.TaskCommitDenied (implements scala.Product, scala.Serializable, org.apache.spark.TaskFailedReason)
  • org.apache.spark.TaskContext (implements java.io.Serializable)
    • org.apache.spark.BarrierTaskContext (implements org.apache.spark.internal.Logging)
  • org.apache.spark.TaskKilled (implements scala.Product, scala.Serializable, org.apache.spark.TaskFailedReason)
  • org.apache.spark.TaskResultLost
  • org.apache.spark.TaskSchedulerIsSet
  • org.apache.spark.TaskState
  • org.apache.spark.TestUtils
  • Throwable (implements java.io.Serializable)
    • Exception
      • RuntimeException
        • org.apache.spark.TaskKilledException
      • org.apache.spark.SparkException
  • org.apache.spark.UnknownReason

Interface Hierarchy

• scala.concurrent.Awaitable<T>
  • scala.concurrent.Future<T>
    • org.apache.spark.FutureAction<T>
• org.apache.spark.CleanerListener
• org.apache.spark.CleanupTask
• org.apache.spark.ExecutorAllocationClient
• org.apache.spark.ExecutorPlugin
• org.apache.spark.JobSubmitter
• org.apache.spark.MapOutputTrackerMessage
• java.io.Serializable
  • org.apache.spark.AccumulableParam<R,T>
    • org.apache.spark.AccumulatorParam<T>
  • scala.Serializable
    • org.apache.spark.BarrierCoordinatorMessage
    • org.apache.spark.Partition
  • org.apache.spark.SparkExecutorInfo
  • org.apache.spark.SparkJobInfo
  • org.apache.spark.SparkStageInfo
• org.apache.spark.TaskEndReason
  • org.apache.spark.TaskFailedReason

Enum Hierarchy

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