Class DefaultShuffleDescriptorsCache
- java.lang.Object
-
- org.apache.flink.runtime.taskexecutor.DefaultShuffleDescriptorsCache
-
- All Implemented Interfaces:
ShuffleDescriptorsCache
public class DefaultShuffleDescriptorsCache extends Object implements ShuffleDescriptorsCache
Default implement ofShuffleDescriptorsCache. Entries will be expired after timeout.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classDefaultShuffleDescriptorsCache.FactoryThe Factory ofDefaultShuffleDescriptorsCache.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclear()clear all cache.voidclearCacheForJob(org.apache.flink.api.common.JobID jobId)Clear all cache for the Job.TaskDeploymentDescriptorFactory.ShuffleDescriptorGroupget(PermanentBlobKey blobKey)Get shuffle descriptor group in cache.voidput(org.apache.flink.api.common.JobID jobId, PermanentBlobKey blobKey, TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup shuffleDescriptorGroup)Put shuffle descriptor group to cache.
-
-
-
Method Detail
-
clear
public void clear()
Description copied from interface:ShuffleDescriptorsCacheclear all cache.- Specified by:
clearin interfaceShuffleDescriptorsCache
-
get
public TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup get(PermanentBlobKey blobKey)
Description copied from interface:ShuffleDescriptorsCacheGet shuffle descriptor group in cache.- Specified by:
getin interfaceShuffleDescriptorsCache- Parameters:
blobKey- identify the shuffle descriptor group- Returns:
- shuffle descriptor group in cache if exists, otherwise null
-
put
public void put(org.apache.flink.api.common.JobID jobId, PermanentBlobKey blobKey, TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup shuffleDescriptorGroup)Description copied from interface:ShuffleDescriptorsCachePut shuffle descriptor group to cache.- Specified by:
putin interfaceShuffleDescriptorsCache- Parameters:
jobId- of jobblobKey- identify the shuffle descriptor groupshuffleDescriptorGroup- shuffle descriptor group to cache
-
clearCacheForJob
public void clearCacheForJob(org.apache.flink.api.common.JobID jobId)
Description copied from interface:ShuffleDescriptorsCacheClear all cache for the Job.- Specified by:
clearCacheForJobin interfaceShuffleDescriptorsCache- Parameters:
jobId- of job
-
-