|
Change Parameter Type miniCluster : LocalFlinkMiniCluster to jobExecutor : JobExecutor in method public setAsContext(jobExecutor JobExecutor, parallelism int, jarFiles Collection<Path>, classPaths Collection<URL>) : void in class org.apache.flink.test.util.TestEnvironment |
From |
To |
|
Change Parameter Type cluster : LocalFlinkMiniCluster to jobExecutor : JobExecutor in method public setAsContext(jobExecutor JobExecutor, parallelism int, jarFiles Collection<Path>, classpaths Collection<URL>) : void in class org.apache.flink.streaming.util.TestStreamEnvironment |
From |
To |
|
Change Parameter Type executor : LocalFlinkMiniCluster to executor : JobExecutor in method public TestEnvironment(executor JobExecutor, parallelism int, isObjectReuseEnabled boolean) in class org.apache.flink.test.util.TestEnvironment |
From |
To |
|
Change Parameter Type miniCluster : LocalFlinkMiniCluster to jobExecutor : JobExecutor in method public setAsContext(jobExecutor JobExecutor, parallelism int) : void in class org.apache.flink.test.util.TestEnvironment |
From |
To |
|
Change Parameter Type cluster : LocalFlinkMiniCluster to jobExecutor : JobExecutor in method public setAsContext(jobExecutor JobExecutor, parallelism int) : void in class org.apache.flink.streaming.util.TestStreamEnvironment |
From |
To |
|
Change Parameter Type miniCluster : LocalFlinkMiniCluster to jobExecutor : JobExecutor in method public TestStreamEnvironment(jobExecutor JobExecutor, parallelism int, jarFiles Collection<Path>, classPaths Collection<URL>) in class org.apache.flink.streaming.util.TestStreamEnvironment |
From |
To |
|
Change Parameter Type miniCluster : LocalFlinkMiniCluster to jobExecutor : JobExecutor in method public TestStreamEnvironment(jobExecutor JobExecutor, parallelism int) in class org.apache.flink.streaming.util.TestStreamEnvironment |
From |
To |
|
Change Parameter Type miniCluster : LocalFlinkMiniCluster to jobExecutor : JobExecutor in method public TestEnvironment(jobExecutor JobExecutor, parallelism int, isObjectReuseEnabled boolean, jarFiles Collection<Path>, classPaths Collection<URL>) in class org.apache.flink.test.util.TestEnvironment |
From |
To |
|
Rename Parameter miniCluster : LocalFlinkMiniCluster to jobExecutor : JobExecutor in method public TestEnvironment(jobExecutor JobExecutor, parallelism int, isObjectReuseEnabled boolean, jarFiles Collection<Path>, classPaths Collection<URL>) in class org.apache.flink.test.util.TestEnvironment |
From |
To |
|
Rename Parameter miniCluster : LocalFlinkMiniCluster to jobExecutor : JobExecutor in method public setAsContext(jobExecutor JobExecutor, parallelism int, jarFiles Collection<Path>, classPaths Collection<URL>) : void in class org.apache.flink.test.util.TestEnvironment |
From |
To |
|
Rename Parameter cluster : LocalFlinkMiniCluster to jobExecutor : JobExecutor in method public setAsContext(jobExecutor JobExecutor, parallelism int, jarFiles Collection<Path>, classpaths Collection<URL>) : void in class org.apache.flink.streaming.util.TestStreamEnvironment |
From |
To |
|
Rename Parameter miniCluster : LocalFlinkMiniCluster to jobExecutor : JobExecutor in method public setAsContext(jobExecutor JobExecutor, parallelism int) : void in class org.apache.flink.test.util.TestEnvironment |
From |
To |
|
Rename Parameter cluster : LocalFlinkMiniCluster to jobExecutor : JobExecutor in method public setAsContext(jobExecutor JobExecutor, parallelism int) : void in class org.apache.flink.streaming.util.TestStreamEnvironment |
From |
To |
|
Rename Parameter miniCluster : LocalFlinkMiniCluster to jobExecutor : JobExecutor in method public TestStreamEnvironment(jobExecutor JobExecutor, parallelism int, jarFiles Collection<Path>, classPaths Collection<URL>) in class org.apache.flink.streaming.util.TestStreamEnvironment |
From |
To |
|
Rename Parameter miniCluster : LocalFlinkMiniCluster to jobExecutor : JobExecutor in method public TestStreamEnvironment(jobExecutor JobExecutor, parallelism int) in class org.apache.flink.streaming.util.TestStreamEnvironment |
From |
To |