5ebe3fb55f2ce9299660989d40aa6d96d45a6d8c
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 16
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public getBlobServer() : BlobServer renamed to public getBlobWriter() : BlobWriter in class org.apache.flink.runtime.executiongraph.ExecutionGraph | From | To | |
| Pull Up Method | 1 | ||
| Pull Up Method public tryOffload(value T, jobId JobID, blobServer BlobServer) : Either<SerializedValue<T>,PermanentBlobKey> from class org.apache.flink.runtime.blob.BlobServer to public serializeAndTryOffload(value T, jobId JobID, blobWriter BlobWriter) : Either<SerializedValue<T>,PermanentBlobKey> from class org.apache.flink.runtime.blob.BlobWriter | From | To | |
| Change Parameter Type | 3 | ||
| Change Parameter Type blobServer : BlobServer to blobWriter : BlobWriter in method public ExecutionGraph(jobInformation JobInformation, futureExecutor ScheduledExecutorService, ioExecutor Executor, timeout Time, restartStrategy RestartStrategy, failoverStrategyFactory FailoverStrategy.Factory, slotProvider SlotProvider, userClassLoader ClassLoader, blobWriter BlobWriter) in class org.apache.flink.runtime.executiongraph.ExecutionGraph | From | To | |
| Change Parameter Type blobServer : BlobServer to blobWriter : BlobWriter in method public serializeAndTryOffload(value T, jobId JobID, blobWriter BlobWriter) : Either<SerializedValue<T>,PermanentBlobKey> in class org.apache.flink.runtime.blob.BlobWriter | From | To | |
| Change Parameter Type blobServer : BlobServer to blobWriter : BlobWriter 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, blobWriter BlobWriter, log Logger) : ExecutionGraph in class org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder | From | To | |
| Rename Variable | 1 | ||
| Rename Variable blobServer : BlobServer to blobWriter : BlobWriter in method public getTaskInformationOrBlobKey() : Either<SerializedValue<TaskInformation>,PermanentBlobKey> in class org.apache.flink.runtime.executiongraph.ExecutionJobVertex | From | To | |
| Change Return Type | 1 | ||
| Change Return Type BlobServer to BlobWriter in method public getBlobWriter() : BlobWriter in class org.apache.flink.runtime.executiongraph.ExecutionGraph | From | To | |
| Push Down Attribute | 1 | ||
| Push Down Attribute protected blobServer : BlobServer from class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest to protected blobServer : BlobServer from class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentWithBlobServerTest | From | To | |
| Move Attribute | 1 | ||
| Move Attribute private blobServer : BlobServer from class org.apache.flink.runtime.executiongraph.ExecutionGraph to protected blobServer : BlobServer from class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentWithBlobServerTest | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute blobServer : BlobServer to blobWriter : BlobWriter in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest | From | To | |
| Rename Attribute blobServer : BlobServer to blobWriter : BlobWriter in class org.apache.flink.runtime.executiongraph.ExecutionGraph | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type blobServer : BlobServer to blobWriter : BlobWriter in method public getTaskInformationOrBlobKey() : Either<SerializedValue<TaskInformation>,PermanentBlobKey> in class org.apache.flink.runtime.executiongraph.ExecutionJobVertex | From | To | |
| Extract Interface | 1 | ||
| Extract Interface org.apache.flink.runtime.blob.BlobWriter from classes [org.apache.flink.runtime.blob.BlobServer] | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type blobServer : BlobServer to blobWriter : BlobWriter in class org.apache.flink.runtime.executiongraph.ExecutionGraph | From | To | |
| Change Attribute Type blobServer : BlobServer to blobWriter : BlobWriter in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter blobServer : BlobServer to blobWriter : BlobWriter in method public serializeAndTryOffload(value T, jobId JobID, blobWriter BlobWriter) : Either<SerializedValue<T>,PermanentBlobKey> in class org.apache.flink.runtime.blob.BlobWriter | From | To | |
| Rename Parameter blobServer : BlobServer to blobWriter : BlobWriter 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, blobWriter BlobWriter, log Logger) : ExecutionGraph in class org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder | From | To | |
| Rename Parameter blobServer : BlobServer to blobWriter : BlobWriter in method public ExecutionGraph(jobInformation JobInformation, futureExecutor ScheduledExecutorService, ioExecutor Executor, timeout Time, restartStrategy RestartStrategy, failoverStrategyFactory FailoverStrategy.Factory, slotProvider SlotProvider, userClassLoader ClassLoader, blobWriter BlobWriter) in class org.apache.flink.runtime.executiongraph.ExecutionGraph | From | To |