Class Hierarchy
- java.lang.Object
- 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.ShuffleDescriptor
- org.apache.flink.runtime.shuffle.ShuffleMasterContext
- 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)