Uses of Class
org.apache.flink.api.common.cache.DistributedCache.DistributedCacheEntry

Packages that use DistributedCache.DistributedCacheEntry

Package	Description
org.apache.flink.api.common
org.apache.flink.api.common.cache
org.apache.flink.optimizer.plantranslate
org.apache.flink.runtime.filecache
org.apache.flink.runtime.jobgraph
org.apache.flink.streaming.api.environment

Uses of DistributedCache.DistributedCacheEntry in org.apache.flink.api.common

Fields in org.apache.flink.api.common with type parameters of type DistributedCache.DistributedCacheEntry

Modifier and Type	Field and Description
protected HashMap<String,DistributedCache.DistributedCacheEntry>	Plan.cacheFile Hash map for files in the distributed cache: registered name to cache entry.

Methods in org.apache.flink.api.common that return types with arguments of type DistributedCache.DistributedCacheEntry

Modifier and Type	Method and Description
Set<Map.Entry<String,DistributedCache.DistributedCacheEntry>>	Plan.getCachedFiles() return the registered caches files

Methods in org.apache.flink.api.common with parameters of type DistributedCache.DistributedCacheEntry

Modifier and Type	Method and Description
void	Plan.registerCachedFile(String name, DistributedCache.DistributedCacheEntry entry) register cache files in program level

Uses of DistributedCache.DistributedCacheEntry in org.apache.flink.api.common.cache

Methods in org.apache.flink.api.common.cache that return types with arguments of type DistributedCache.DistributedCacheEntry

Modifier and Type	Method and Description
static Set<Map.Entry<String,DistributedCache.DistributedCacheEntry>>	DistributedCache.readFileInfoFromConfig(Configuration conf)

Methods in org.apache.flink.api.common.cache with parameters of type DistributedCache.DistributedCacheEntry

Modifier and Type	Method and Description
static void	DistributedCache.writeFileInfoToConfig(String name, DistributedCache.DistributedCacheEntry e, Configuration conf)

Uses of DistributedCache.DistributedCacheEntry in org.apache.flink.optimizer.plantranslate

Method parameters in org.apache.flink.optimizer.plantranslate with type arguments of type DistributedCache.DistributedCacheEntry

Modifier and Type	Method and Description
static void	JobGraphGenerator.addUserArtifactEntries(Collection<Tuple2<String,DistributedCache.DistributedCacheEntry>> userArtifacts, JobGraph jobGraph)

Uses of DistributedCache.DistributedCacheEntry in org.apache.flink.runtime.filecache

Methods in org.apache.flink.runtime.filecache with parameters of type DistributedCache.DistributedCacheEntry

Modifier and Type	Method and Description
Future<Path>	FileCache.createTmpFile(String name, DistributedCache.DistributedCacheEntry entry, JobID jobID, ExecutionAttemptID executionId) If the file doesn't exists locally, retrieve the file from the blob-service.

Uses of DistributedCache.DistributedCacheEntry in org.apache.flink.runtime.jobgraph

Methods in org.apache.flink.runtime.jobgraph that return types with arguments of type DistributedCache.DistributedCacheEntry

Modifier and Type	Method and Description
Map<String,DistributedCache.DistributedCacheEntry>	JobGraph.getUserArtifacts() Gets the list of assigned user jar paths.

Methods in org.apache.flink.runtime.jobgraph with parameters of type DistributedCache.DistributedCacheEntry

Modifier and Type	Method and Description
void	JobGraph.addUserArtifact(String name, DistributedCache.DistributedCacheEntry file) Adds the path of a custom file required to run the job on a task manager.

Uses of DistributedCache.DistributedCacheEntry in org.apache.flink.streaming.api.environment

Fields in org.apache.flink.streaming.api.environment with type parameters of type DistributedCache.DistributedCacheEntry

Modifier and Type	Field and Description
protected List<Tuple2<String,DistributedCache.DistributedCacheEntry>>	StreamExecutionEnvironment.cacheFile

Methods in org.apache.flink.streaming.api.environment that return types with arguments of type DistributedCache.DistributedCacheEntry

Modifier and Type	Method and Description
List<Tuple2<String,DistributedCache.DistributedCacheEntry>>	StreamExecutionEnvironment.getCachedFiles() Get the list of cached files that were registered for distribution among the task managers.