Class Hierarchy
- java.lang.Object
- org.apache.flink.runtime.shuffle.DefaultPartitionWithMetrics (implements org.apache.flink.runtime.shuffle.PartitionWithMetrics)
- org.apache.flink.runtime.shuffle.DefaultShuffleMasterSnapshotContext (implements org.apache.flink.runtime.shuffle.ShuffleMasterSnapshotContext)
- org.apache.flink.runtime.shuffle.DefaultShuffleMetrics (implements org.apache.flink.runtime.shuffle.ShuffleMetrics)
- org.apache.flink.runtime.shuffle.EmptyShuffleMasterSnapshot (implements org.apache.flink.runtime.shuffle.ShuffleMasterSnapshot)
- org.apache.flink.runtime.shuffle.JobShuffleContextImpl (implements org.apache.flink.runtime.shuffle.JobShuffleContext)
- org.apache.flink.runtime.shuffle.NettyShuffleDescriptor (implements org.apache.flink.runtime.shuffle.ShuffleDescriptor)
- org.apache.flink.runtime.shuffle.NettyShuffleDescriptor.NetworkPartitionConnectionInfo (implements org.apache.flink.runtime.shuffle.NettyShuffleDescriptor.PartitionConnectionInfo)
- org.apache.flink.runtime.shuffle.NettyShuffleMaster (implements org.apache.flink.runtime.shuffle.ShuffleMaster<T>)
- org.apache.flink.runtime.shuffle.NettyShuffleUtils
- org.apache.flink.runtime.shuffle.PartitionDescriptor (implements java.io.Serializable)
- org.apache.flink.runtime.shuffle.ProducerDescriptor
- org.apache.flink.runtime.shuffle.ShuffleEnvironmentContext
- org.apache.flink.runtime.shuffle.ShuffleIOOwnerContext
- org.apache.flink.runtime.shuffle.ShuffleMasterContextImpl (implements org.apache.flink.runtime.shuffle.ShuffleMasterContext)
- org.apache.flink.runtime.shuffle.ShuffleServiceOptions
- org.apache.flink.runtime.shuffle.ShuffleUtils
- org.apache.flink.runtime.shuffle.TaskInputsOutputsDescriptor
- org.apache.flink.runtime.shuffle.UnknownShuffleDescriptor (implements org.apache.flink.runtime.shuffle.ShuffleDescriptor)
Interface Hierarchy
- java.lang.AutoCloseable
- org.apache.flink.runtime.shuffle.ShuffleEnvironment<P,G>
- org.apache.flink.runtime.shuffle.ShuffleMaster<T>
- org.apache.flink.runtime.shuffle.JobShuffleContext
- java.io.Serializable
- org.apache.flink.runtime.shuffle.NettyShuffleDescriptor.PartitionConnectionInfo
- org.apache.flink.runtime.shuffle.PartitionWithMetrics
- org.apache.flink.runtime.shuffle.ShuffleDescriptor
- org.apache.flink.runtime.shuffle.ShuffleMasterSnapshot
- org.apache.flink.runtime.shuffle.ShuffleMetrics
- org.apache.flink.runtime.shuffle.ShuffleMasterContext
- org.apache.flink.runtime.shuffle.ShuffleMasterSnapshotContext
- org.apache.flink.runtime.shuffle.ShuffleServiceFactory<SD,P,G>
Enum Hierarchy
- java.lang.Object
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
- org.apache.flink.runtime.shuffle.NettyShuffleDescriptor.LocalExecutionPartitionConnectionInfo (implements org.apache.flink.runtime.shuffle.NettyShuffleDescriptor.PartitionConnectionInfo)
- org.apache.flink.runtime.shuffle.ShuffleServiceLoader
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)