Uses of Package
org.apache.flink.runtime.shuffle
-
Classes in org.apache.flink.runtime.shuffle used by org.apache.flink.runtime.deployment Class Description PartitionDescriptor Partition descriptor forShuffleMasterto obtainShuffleDescriptor.ShuffleDescriptor Interface for shuffle deployment descriptor of result partition resource. -
Classes in org.apache.flink.runtime.shuffle used by org.apache.flink.runtime.executiongraph Class Description ShuffleDescriptor Interface for shuffle deployment descriptor of result partition resource.ShuffleMaster Intermediate result partition registry to use inJobMaster. -
Classes in org.apache.flink.runtime.shuffle used by org.apache.flink.runtime.io.network Class Description NettyShuffleMaster DefaultShuffleMasterfor netty and local file based shuffle implementation.ShuffleEnvironment Interface for the implementation of shuffle service local environment.ShuffleEnvironmentContext Local context used to createShuffleEnvironment.ShuffleIOOwnerContext Context of shuffle input/output owner used to create partitions or gates belonging to the owner.ShuffleMasterContext Shuffle context used to createShuffleMaster.ShuffleServiceFactory Interface for shuffle service factory implementations. -
Classes in org.apache.flink.runtime.shuffle used by org.apache.flink.runtime.io.network.partition Class Description ShuffleDescriptor Interface for shuffle deployment descriptor of result partition resource.ShuffleEnvironment Interface for the implementation of shuffle service local environment.ShuffleMaster Intermediate result partition registry to use inJobMaster. -
Classes in org.apache.flink.runtime.shuffle used by org.apache.flink.runtime.io.network.partition.consumer Class Description NettyShuffleDescriptor Default implementation ofShuffleDescriptorforNettyShuffleMaster.ShuffleIOOwnerContext Context of shuffle input/output owner used to create partitions or gates belonging to the owner. -
Classes in org.apache.flink.runtime.shuffle used by org.apache.flink.runtime.jobmaster Class Description ShuffleMaster Intermediate result partition registry to use inJobMaster. -
Classes in org.apache.flink.runtime.shuffle used by org.apache.flink.runtime.resourcemanager Class Description ShuffleDescriptor Interface for shuffle deployment descriptor of result partition resource. -
Classes in org.apache.flink.runtime.shuffle used by org.apache.flink.runtime.scheduler Class Description ShuffleMaster Intermediate result partition registry to use inJobMaster. -
Classes in org.apache.flink.runtime.shuffle used by org.apache.flink.runtime.scheduler.adaptive Class Description ShuffleMaster Intermediate result partition registry to use inJobMaster. -
Classes in org.apache.flink.runtime.shuffle used by org.apache.flink.runtime.scheduler.adaptivebatch Class Description ShuffleMaster Intermediate result partition registry to use inJobMaster. -
Classes in org.apache.flink.runtime.shuffle used by org.apache.flink.runtime.shuffle Class 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 Default implementation ofShuffleDescriptorforNettyShuffleMaster.NettyShuffleDescriptor.LocalExecutionPartitionConnectionInfo Local partition connection information.NettyShuffleDescriptor.PartitionConnectionInfo Information for connection to partition producer for shuffle exchange.PartitionDescriptor Partition descriptor forShuffleMasterto obtainShuffleDescriptor.ProducerDescriptor Partition producer descriptor forShuffleMasterto obtainShuffleDescriptor.ShuffleDescriptor Interface for shuffle deployment descriptor of result partition resource.ShuffleEnvironment Interface for the implementation of shuffle service local environment.ShuffleEnvironmentContext Local context used to createShuffleEnvironment.ShuffleIOOwnerContext Context of shuffle input/output owner used to create partitions or gates belonging to the owner.ShuffleMaster Intermediate result partition registry to use inJobMaster.ShuffleMasterContext Shuffle context used to createShuffleMaster.ShuffleServiceFactory Interface for shuffle service factory implementations.ShuffleServiceLoader Utility to load the pluggableShuffleServiceFactoryimplementations.TaskInputsOutputsDescriptor Describes inputs and outputs information of a task.UnknownShuffleDescriptor UnknownShuffleDescriptorfor which the producer has not been deployed yet. -
Classes in org.apache.flink.runtime.shuffle used by org.apache.flink.runtime.taskexecutor Class Description ShuffleEnvironment Interface for the implementation of shuffle service local environment. -
Classes in org.apache.flink.runtime.shuffle used by org.apache.flink.runtime.taskexecutor.partition Class Description ShuffleDescriptor Interface for shuffle deployment descriptor of result partition resource. -
Classes in org.apache.flink.runtime.shuffle used by org.apache.flink.runtime.taskmanager Class Description ShuffleEnvironment Interface for the implementation of shuffle service local environment.