5ff07e63d1e9a98959e5edf66872222b847d23d5
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 16
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public getSerializedJobInformation() : SerializedValue<JobInformation> renamed to public getJobInformationOrBlobKey() : Either<SerializedValue<JobInformation>,PermanentBlobKey> in class org.apache.flink.runtime.executiongraph.ExecutionGraph | From | To | |
| Rename Variable | 3 | ||
| Rename Variable jobInfoBlobKey : PermanentBlobKey to jobInformationOrBlobKey : Either<SerializedValue<JobInformation>,PermanentBlobKey> in method package createDeploymentDescriptor(executionId ExecutionAttemptID, targetSlot SimpleSlot, taskStateHandles TaskStateSnapshot, attemptNumber int) : TaskDeploymentDescriptor in class org.apache.flink.runtime.executiongraph.ExecutionVertex | From | To | |
| Rename Variable taskInformationBlobKey : PermanentBlobKey to taskInformationOrBlobKey : Either<SerializedValue<TaskInformation>,PermanentBlobKey> in method protected checkTaskOffloaded(eg ExecutionGraph, jobVertexId JobVertexID) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentWithBlobServerTest | From | To | |
| Rename Variable jobInformationBlobKey : PermanentBlobKey to jobInformationOrBlobKey : Either<SerializedValue<JobInformation>,PermanentBlobKey> in method protected checkJobOffloaded(eg ExecutionGraph) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentWithBlobServerTest | From | To | |
| Change Return Type | 1 | ||
| Change Return Type SerializedValue<JobInformation> to Either<SerializedValue<JobInformation>,PermanentBlobKey> in method public getJobInformationOrBlobKey() : Either<SerializedValue<JobInformation>,PermanentBlobKey> in class org.apache.flink.runtime.executiongraph.ExecutionGraph | From | To | |
| Change Variable Type | 3 | ||
| Change Variable Type jobInfoBlobKey : PermanentBlobKey to jobInformationOrBlobKey : Either<SerializedValue<JobInformation>,PermanentBlobKey> in method package createDeploymentDescriptor(executionId ExecutionAttemptID, targetSlot SimpleSlot, taskStateHandles TaskStateSnapshot, attemptNumber int) : TaskDeploymentDescriptor in class org.apache.flink.runtime.executiongraph.ExecutionVertex | From | To | |
| Change Variable Type taskInformationBlobKey : PermanentBlobKey to taskInformationOrBlobKey : Either<SerializedValue<TaskInformation>,PermanentBlobKey> in method protected checkTaskOffloaded(eg ExecutionGraph, jobVertexId JobVertexID) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentWithBlobServerTest | From | To | |
| Change Variable Type jobInformationBlobKey : PermanentBlobKey to jobInformationOrBlobKey : Either<SerializedValue<JobInformation>,PermanentBlobKey> in method protected checkJobOffloaded(eg ExecutionGraph) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentWithBlobServerTest | From | To | |
| Extract Variable | 7 | ||
| Extract Variable jobInformation : JobInformation in method public testSimpleFailoverRegion() : void from class org.apache.flink.runtime.executiongraph.RestartPipelinedRegionStrategyTest | From | To | |
| Extract Variable jobInformation : JobInformation in method public buildGraph(prior ExecutionGraph, jobGraph JobGraph, jobManagerConfig Configuration, futureExecutor ScheduledExecutorService, ioExecutor Executor, slotProvider SlotProvider, classLoader ClassLoader, recoveryFactory CheckpointRecoveryFactory, timeout Time, restartStrategy RestartStrategy, metrics MetricGroup, parallelismForAutoMax int, blobServer BlobServer, log Logger) : ExecutionGraph from class org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder | From | To | |
| Extract Variable jobInformation : JobInformation in method public testMultiRegionNotAllToAll() : void from class org.apache.flink.runtime.executiongraph.RestartPipelinedRegionStrategyTest | From | To | |
| Extract Variable jobInformation : JobInformation in method public testExecutionGraphGeneration() : void from class org.apache.flink.streaming.runtime.partitioner.RescalePartitionerTest | From | To | |
| Extract Variable jobInformation : JobInformation in method public testMultipleFailoverRegions() : void from class org.apache.flink.runtime.executiongraph.RestartPipelinedRegionStrategyTest | From | To | |
| Extract Variable jobInformation : JobInformation in method public testSingleRegionWithMixedInput() : void from class org.apache.flink.runtime.executiongraph.RestartPipelinedRegionStrategyTest | From | To | |
| Extract Variable jobInformation : JobInformation in method private createSampleGraph(jid JobID, failoverStrategy Factory, restartStrategy RestartStrategy, slotProvider SlotProvider, parallelism int) : ExecutionGraph from class org.apache.flink.runtime.executiongraph.PipelinedRegionFailoverConcurrencyTest | From | To |