Package org.apache.flink.runtime.shuffle
-
Interface Summary Interface Description JobShuffleContext Job level shuffle context which can offer some job information like job ID and through it, the shuffle plugin notify the job to stop tracking the lost result partitions.NettyShuffleDescriptor.PartitionConnectionInfo Information for connection to partition producer for shuffle exchange.PartitionWithMetrics Interface representing the description and metrics of a result partition.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 inJobMaster
.ShuffleMasterContext Shuffle context used to createShuffleMaster
.ShuffleMasterSnapshot This class represents a snapshot of shuffle master, which can be used to restore the internal state of the shuffle master.ShuffleMasterSnapshotContext Snapshot context used to createShuffleMasterSnapshot
.ShuffleMetrics Interface provides access to the shuffle metrics which includes the meta information of partition(partition bytes, etc).ShuffleServiceFactory<SD extends ShuffleDescriptor,P extends ResultPartitionWriter,G extends IndexedInputGate> Interface for shuffle service factory implementations. -
Class Summary Class Description DefaultPartitionWithMetrics DefaultPartitionWithMetrics
implementation.DefaultShuffleMasterSnapshotContext DefaultShuffleMasterSnapshotContext
implementation.DefaultShuffleMetrics DefaultShuffleMetrics
implementation.EmptyShuffleMasterSnapshot A singleton implementation ofShuffleMasterSnapshot
that represents an empty snapshot of shuffle master.JobShuffleContextImpl The default implementation ofJobShuffleContext
.NettyShuffleDescriptor Default implementation ofShuffleDescriptor
forNettyShuffleMaster
.NettyShuffleDescriptor.NetworkPartitionConnectionInfo Remote partition connection information with index to query partition.NettyShuffleMaster DefaultShuffleMaster
for netty and local file based shuffle implementation.NettyShuffleUtils Utils to calculate network memory requirement of a vertex from network configuration and details of input and output.PartitionDescriptor Partition descriptor forShuffleMaster
to obtainShuffleDescriptor
.ProducerDescriptor Partition producer descriptor forShuffleMaster
to obtainShuffleDescriptor
.ShuffleEnvironmentContext Local context used to createShuffleEnvironment
.ShuffleIOOwnerContext Context of shuffle input/output owner used to create partitions or gates belonging to the owner.ShuffleMasterContextImpl The default implementation ofShuffleMasterContext
.ShuffleServiceOptions Options to configure shuffle service.ShuffleUtils Common utility methods for shuffle service.TaskInputsOutputsDescriptor Describes inputs and outputs information of a task.UnknownShuffleDescriptor UnknownShuffleDescriptor
for which the producer has not been deployed yet. -
Enum Summary Enum Description NettyShuffleDescriptor.LocalExecutionPartitionConnectionInfo Local partition connection information.ShuffleServiceLoader Utility to load the pluggableShuffleServiceFactory
implementations.