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.api.java.utils
org.apache.flink.runtime.filecache
org.apache.flink.runtime.jobgraph
org.apache.flink.streaming.api.environment
org.apache.flink.streaming.api.graph
org.apache.flink.table.planner.utils

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 cached 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 at 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 List<Tuple2<String,DistributedCache.DistributedCacheEntry>>	DistributedCache.parseCachedFilesFromString(List<String> files) Parses a list of distributed cache entries encoded in a string.
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)

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

Modifier and Type	Method and Description
static List<String>	DistributedCache.parseStringFromCachedFiles(List<Tuple2<String,DistributedCache.DistributedCacheEntry>> files)

Uses of DistributedCache.DistributedCacheEntry in org.apache.flink.api.java.utils

Constructor parameters in org.apache.flink.api.java.utils with type arguments of type DistributedCache.DistributedCacheEntry

Constructor and Description
PlanGenerator(List<DataSink<?>> sinks, ExecutionConfig config, int defaultParallelism, List<Tuple2<String,DistributedCache.DistributedCacheEntry>> cacheFile, String jobName)

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.
static Map<String,DistributedCache.DistributedCacheEntry>	JobGraphUtils.prepareUserArtifactEntries(Map<String,DistributedCache.DistributedCacheEntry> userArtifacts, JobID jobId)

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.

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

Modifier and Type	Method and Description
JobGraphBuilder	JobGraphBuilder.addUserArtifacts(Map<String,DistributedCache.DistributedCacheEntry> newUserArtifacts)
static Map<String,DistributedCache.DistributedCacheEntry>	JobGraphUtils.prepareUserArtifactEntries(Map<String,DistributedCache.DistributedCacheEntry> userArtifacts, JobID jobId)

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 Now we could not migrate this field to configuration.

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.

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

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

Modifier and Type	Method and Description
Collection<Tuple2<String,DistributedCache.DistributedCacheEntry>>	StreamGraph.getUserArtifacts()

Uses of DistributedCache.DistributedCacheEntry in org.apache.flink.table.planner.utils

Methods in org.apache.flink.table.planner.utils that return types with arguments of type DistributedCache.DistributedCacheEntry

Modifier and Type	Method and Description
List<Tuple2<String,DistributedCache.DistributedCacheEntry>>	DummyStreamExecutionEnvironment.getCachedFiles()