Uses of Interface
org.apache.flink.runtime.util.GroupCache

Packages that use GroupCache

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

Uses of GroupCache in org.apache.flink.runtime.deployment

Methods in org.apache.flink.runtime.deployment with parameters of type GroupCache

Modifier and Type	Method and Description
void	TaskDeploymentDescriptor.loadBigData(PermanentBlobService blobService, GroupCache<JobID,PermanentBlobKey,JobInformation> jobInformationCache, GroupCache<JobID,PermanentBlobKey,TaskInformation> taskInformationCache, GroupCache<JobID,PermanentBlobKey,TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup> shuffleDescriptorsCache) Loads externalized data from the BLOB store back to the object.
void	TaskDeploymentDescriptor.loadBigData(PermanentBlobService blobService, GroupCache<JobID,PermanentBlobKey,JobInformation> jobInformationCache, GroupCache<JobID,PermanentBlobKey,TaskInformation> taskInformationCache, GroupCache<JobID,PermanentBlobKey,TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup> shuffleDescriptorsCache) Loads externalized data from the BLOB store back to the object.
void	TaskDeploymentDescriptor.loadBigData(PermanentBlobService blobService, GroupCache<JobID,PermanentBlobKey,JobInformation> jobInformationCache, GroupCache<JobID,PermanentBlobKey,TaskInformation> taskInformationCache, GroupCache<JobID,PermanentBlobKey,TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup> shuffleDescriptorsCache) Loads externalized data from the BLOB store back to the object.
void	InputGateDeploymentDescriptor.tryLoadAndDeserializeShuffleDescriptors(PermanentBlobService blobService, JobID jobId, GroupCache<JobID,PermanentBlobKey,TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup> shuffleDescriptorsCache)

Uses of GroupCache in org.apache.flink.runtime.taskexecutor

Methods in org.apache.flink.runtime.taskexecutor that return GroupCache

Modifier and Type	Method and Description
GroupCache<JobID,PermanentBlobKey,JobInformation>	TaskManagerServices.getJobInformationCache()
GroupCache<JobID,PermanentBlobKey,TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup>	TaskManagerServices.getShuffleDescriptorCache()
GroupCache<JobID,PermanentBlobKey,TaskInformation>	TaskManagerServices.getTaskInformationCache()

Uses of GroupCache in org.apache.flink.runtime.util

Classes in org.apache.flink.runtime.util that implement GroupCache

Modifier and Type	Class and Description
class	DefaultGroupCache<G,K,V> Default implement of GroupCache.