|
Change Parameter Type cpTasks : Map<String,FutureTask<Path>> to cpTasks : Map<String,Future<Path>> in method public RuntimeUDFContext(name String, numParallelSubtasks int, subtaskIndex int, userCodeClassLoader ClassLoader, executionConfig ExecutionConfig, cpTasks Map<String,Future<Path>>) in class org.apache.flink.api.common.functions.util.RuntimeUDFContext |
From |
To |
|
Change Parameter Type cpTasks : Map<String,FutureTask<Path>> to cpTasks : Map<String,Future<Path>> in method public DistributedRuntimeUDFContext(name String, numParallelSubtasks int, subtaskIndex int, userCodeClassLoader ClassLoader, executionConfig ExecutionConfig, cpTasks Map<String,Future<Path>>) in class org.apache.flink.runtime.operators.util.DistributedRuntimeUDFContext |
From |
To |
|
Change Parameter Type jobID : JobID to cachedPath : Path in method public CopyProcess(e DistributedCacheEntry, cachedPath Path) in class org.apache.flink.runtime.filecache.FileCache.CopyProcess |
From |
To |
|
Rename Variable count : Map<String,Integer> to jobEntries : Map<String,Tuple4<Integer,File,Path,Future<Path>>> in method public createTmpFile(name String, entry DistributedCacheEntry, jobID JobID) : Future<Path> in class org.apache.flink.runtime.filecache.FileCache |
From |
To |
|
Rename Variable count : Map<String,Integer> to jobEntries : Map<String,Tuple4<Integer,File,Path,Future<Path>>> in method public run() : void in class org.apache.flink.runtime.filecache.FileCache.DeleteProcess |
From |
To |
|
Change Variable Type count : Map<String,Integer> to jobEntries : Map<String,Tuple4<Integer,File,Path,Future<Path>>> in method public createTmpFile(name String, entry DistributedCacheEntry, jobID JobID) : Future<Path> in class org.apache.flink.runtime.filecache.FileCache |
From |
To |
|
Change Variable Type count : Map<String,Integer> to jobEntries : Map<String,Tuple4<Integer,File,Path,Future<Path>>> in method public run() : void in class org.apache.flink.runtime.filecache.FileCache.DeleteProcess |
From |
To |