Uses of Class
org.apache.flink.runtime.deployment.TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup

Packages that use TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup

Package	Description
org.apache.flink.runtime.deployment
org.apache.flink.runtime.taskexecutor

Uses of TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup in org.apache.flink.runtime.deployment

Methods in org.apache.flink.runtime.deployment that return types with arguments of type TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup

Modifier and Type	Method	Description
List<TaskDeploymentDescriptor.MaybeOffloaded<TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup>>	CachedShuffleDescriptors.getAllSerializedShuffleDescriptorGroups()

Constructor parameters in org.apache.flink.runtime.deployment with type arguments of type TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup

Constructor	Description
InputGateDeploymentDescriptor(IntermediateDataSetID consumedResultId, ResultPartitionType consumedPartitionType, IndexRange consumedSubpartitionIndexRange, int numberOfInputChannels, List<TaskDeploymentDescriptor.MaybeOffloaded<TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup>> serializedInputChannels)

Uses of TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup in org.apache.flink.runtime.taskexecutor

Methods in org.apache.flink.runtime.taskexecutor that return TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup

Modifier and Type	Method	Description
TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup	DefaultShuffleDescriptorsCache.get(PermanentBlobKey blobKey)
TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup	ShuffleDescriptorsCache.get(PermanentBlobKey blobKey)	Get shuffle descriptor group in cache.

Methods in org.apache.flink.runtime.taskexecutor with parameters of type TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup

Modifier and Type	Method	Description
void	DefaultShuffleDescriptorsCache.put(org.apache.flink.api.common.JobID jobId, PermanentBlobKey blobKey, TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup shuffleDescriptorGroup)
void	ShuffleDescriptorsCache.put(org.apache.flink.api.common.JobID jobId, PermanentBlobKey blobKey, TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup shuffleDescriptorGroup)	Put shuffle descriptor group to cache.