Package org.apache.flink.runtime.shuffle

Interface Summary

Interface	Description
NettyShuffleDescriptor.PartitionConnectionInfo	Information for connection to partition producer for shuffle exchange.
ShuffleDescriptor	Interface for shuffle deployment descriptor of result partition resource.
ShuffleEnvironment<P extends ResultPartitionWriter,G extends IndexedInputGate>	Interface for the implementation of shuffle service local environment.
ShuffleMaster<T extends ShuffleDescriptor>	Intermediate result partition registry to use in JobMaster.
ShuffleServiceFactory<SD extends ShuffleDescriptor,P extends ResultPartitionWriter,G extends IndexedInputGate>	Interface for shuffle service factory implementations.

Class Summary

Class	Description
NettyShuffleDescriptor	Default implementation of ShuffleDescriptor for NettyShuffleMaster.
NettyShuffleDescriptor.NetworkPartitionConnectionInfo	Remote partition connection information with index to query partition.
PartitionDescriptor	Partition descriptor for ShuffleMaster to obtain ShuffleDescriptor.
ProducerDescriptor	Partition producer descriptor for ShuffleMaster to obtain ShuffleDescriptor.
ShuffleEnvironmentContext	Local context used to create ShuffleEnvironment.
ShuffleIOOwnerContext	Context of shuffle input/output owner used to create partitions or gates belonging to the owner.
ShuffleServiceOptions	Options to configure shuffle service.
ShuffleUtils	Common utility methods for shuffle service.
UnknownShuffleDescriptor	Unknown ShuffleDescriptor for which the producer has not been deployed yet.

Enum Summary

Enum	Description
NettyShuffleDescriptor.LocalExecutionPartitionConnectionInfo	Local partition connection information.
NettyShuffleMaster	Default ShuffleMaster for netty and local file based shuffle implementation.
ShuffleServiceLoader	Utility to load the pluggable ShuffleServiceFactory implementations.