71bf2f570861daae53b24bfcf1d06aedb85311b9
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 60
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move Attribute | 1 | ||
| Move Attribute private userCodeClassLoader : ClassLoader from class org.apache.flink.client.program.Client to private userCodeClassLoader : ClassLoader from class org.apache.flink.streaming.api.environment.StreamContextEnvironment | From | To | |
| Move Class | 3 | ||
| Move Class org.apache.flink.client.program.PackagedProgram.PreviewPlanEnvironment moved to org.apache.flink.client.program.PreviewPlanEnvironment | From | To | |
| Move Class org.apache.flink.client.program.Client.ProgramAbortException moved to org.apache.flink.client.program.OptimizerPlanEnvironment.ProgramAbortException | From | To | |
| Move Class org.apache.flink.client.program.Client.OptimizerPlanEnvironment moved to org.apache.flink.client.program.OptimizerPlanEnvironment | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type address : Tuple2<String,Object> to address : scala.Tuple2<String,Object> in method public setUp() : void in class org.apache.flink.client.program.ClientTest | From | To | |
| Extract Variable | 3 | ||
| Extract Variable factory : ContextEnvironmentFactory in method package setAsContext(client Client, jarFilesToAttach List<File>, userCodeClassLoader ClassLoader, defaultParallelism int, wait boolean) : void from class org.apache.flink.client.program.ContextEnvironment | From | To | |
| Extract Variable result : JobExecutionResult in method public execute(jobName String) : JobExecutionResult from class org.apache.flink.api.java.RemoteEnvironment | From | To | |
| Extract Variable result : JobExecutionResult in method public execute(jobName String) : JobExecutionResult from class org.apache.flink.api.java.LocalEnvironment | From | To | |
| Extract Method | 1 | ||
| Extract Method public compileJobGraph(program OptimizedPlan, jobId JobID) : JobGraph extracted from public compileJobGraph(program OptimizedPlan) : JobGraph in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator | From | To | |
| Rename Method | 5 | ||
| Rename Method public getOriginalPactPlan() : Plan renamed to public getOriginalPlan() : Plan in class org.apache.flink.optimizer.plan.OptimizedPlan | From | To | |
| Rename Method public run(compiledPlan OptimizedPlan, libraries List<File>, wait boolean) : JobSubmissionResult renamed to public runBlocking(jobGraph JobGraph, classLoader ClassLoader) : JobExecutionResult in class org.apache.flink.client.program.Client | From | To | |
| Rename Method protected executeProgram(program PackagedProgram, client Client, parallelism int, wait boolean) : int renamed to protected executeProgramBlocking(program PackagedProgram, client Client, parallelism int) : int in class org.apache.flink.client.CliFrontend | From | To | |
| Rename Method public run(prog PackagedProgram, parallelism int, wait boolean) : JobSubmissionResult renamed to public runDetached(prog PackagedProgram, parallelism int) : JobSubmissionResult in class org.apache.flink.client.program.Client | From | To | |
| Rename Method protected executeProgram(program PackagedProgram, client Client, parallelism int, wait boolean) : int renamed to protected executeProgramDetached(program PackagedProgram, client Client, parallelism int) : int in class org.apache.flink.client.CliFrontendRunTest.RunTestingCliFrontend | From | To | |
| Rename Variable | 3 | ||
| Rename Variable planWithJarsMock : JobWithJars to jobWithJars : JobWithJars in method public setUp() : void in class org.apache.flink.client.program.ClientTest | From | To | |
| Rename Variable c : Client to client : Client in method public testExternalProgram() : void in class org.apache.flink.api.avro.AvroExternalJarProgramITCase | From | To | |
| Rename Variable p : Plan to plan : Plan in method public getExecutionPlan() : String in class org.apache.flink.client.program.ContextEnvironment | From | To | |
| Change Return Type | 4 | ||
| Change Return Type UUID to JobID in method public getId() : JobID in class org.apache.flink.api.java.ExecutionEnvironment | From | To | |
| Change Return Type JobSubmissionResult to JobExecutionResult in method public runBlocking(jobGraph JobGraph, classLoader ClassLoader) : JobExecutionResult in class org.apache.flink.client.program.Client | From | To | |
| Change Return Type FlinkPlan to OptimizedPlan in method private getOptimizedPlan(compiler Optimizer, prog JobWithJars, parallelism int) : OptimizedPlan in class org.apache.flink.client.program.Client | From | To | |
| Change Return Type JobExecutionResult to JobSubmissionResult in method public abstract execute(jobName String) : JobSubmissionResult in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To | |
| Parameterize Variable | 1 | ||
| Parameterize Variable job : JobGraph to jobGraph : JobGraph in method public runBlocking(jobGraph JobGraph, classLoader ClassLoader) : JobExecutionResult in class org.apache.flink.client.program.Client | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute executionId : UUID to jobID : JobID in class org.apache.flink.api.java.ExecutionEnvironment | From | To | |
| Rename Attribute lastJobId : JobID to lastJobID : JobID in class org.apache.flink.client.program.Client | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type executionId : UUID to jobID : JobID in class org.apache.flink.api.java.ExecutionEnvironment | From | To | |
| Extract And Move Method | 7 | ||
| Extract And Move Method public fromJobSubmissionResult(result JobSubmissionResult) : JobExecutionResult extracted from public execute(jobName String) : JobExecutionResult in class org.apache.flink.streaming.api.environment.StreamContextEnvironment & moved to class org.apache.flink.api.common.JobExecutionResult | From | To | |
| Extract And Move Method public setJobId(jobId JobID) : void extracted from public execute(jobName String) : JobExecutionResult in class org.apache.flink.api.java.LocalEnvironment & moved to class org.apache.flink.api.common.Plan | From | To | |
| Extract And Move Method public setSessionTimeout(sessionTimeout long) : void extracted from public execute(jobName String) : JobExecutionResult in class org.apache.flink.api.java.LocalEnvironment & moved to class org.apache.flink.api.common.Plan | From | To | |
| Extract And Move Method public setSessionTimeout(sessionTimeout long) : void extracted from public execute(jobName String) : JobExecutionResult in class org.apache.flink.api.java.RemoteEnvironment & moved to class org.apache.flink.api.common.Plan | From | To | |
| Extract And Move Method public fromJobSubmissionResult(result JobSubmissionResult) : JobExecutionResult extracted from public execute(jobName String) : JobExecutionResult in class org.apache.flink.client.program.ContextEnvironment & moved to class org.apache.flink.api.common.JobExecutionResult | From | To | |
| Extract And Move Method public stop() : void extracted from public stop() : void in class org.apache.flink.client.LocalExecutor & moved to class org.apache.flink.tez.client.TezExecutor | From | To | |
| Extract And Move Method public setJobId(jobId JobID) : void extracted from public execute(jobName String) : JobExecutionResult in class org.apache.flink.api.java.RemoteEnvironment & moved to class org.apache.flink.api.common.Plan | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter p : JobWithJars to program : JobWithJars in method public executePlanWithJars(program JobWithJars) : JobExecutionResult in class org.apache.flink.client.RemoteExecutor | From | To | |
| Rename Parameter userCodeClassloader : ClassLoader to classLoader : ClassLoader in method public submitJobAndWait(actorSystem ActorSystem, jobManagerGateway ActorGateway, jobGraph JobGraph, timeout FiniteDuration, sysoutLogUpdates boolean, classLoader ClassLoader) : JobExecutionResult in class org.apache.flink.runtime.client.JobClient | From | To | |
| Rename Parameter userCodeClassloader : ClassLoader to classLoader : ClassLoader in method public submitJobDetached(jobManagerGateway ActorGateway, jobGraph JobGraph, timeout FiniteDuration, classLoader ClassLoader) : void in class org.apache.flink.runtime.client.JobClient | From | To |