b6b4baf588fae0494e32492ac16df8977d8cfc1b
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 12
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method private createCheckpointStorageLocation() : CheckpointStorageLocation renamed to private createCheckpointStreamFactory() : CheckpointStreamFactory in class org.apache.flink.runtime.state.ttl.StateBackendTestContext | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type checkpointStorage : CheckpointStorage to checkpointStorage : CheckpointStorageWorkerView in method public MockStreamTask(environment Environment, name String, checkpointLock Object, config StreamConfig, executionConfig ExecutionConfig, streamTaskStateInitializer StreamTaskStateInitializer, closableRegistry CloseableRegistry, streamStatusMaintainer StreamStatusMaintainer, checkpointStorage CheckpointStorageWorkerView, processingTimeService ProcessingTimeService, handleAsyncException BiConsumer<String,Throwable>, accumulatorMap Map<String,Accumulator<?,?>>) in class org.apache.flink.streaming.util.MockStreamTask | From | To | |
| Change Return Type | 4 | ||
| Change Return Type CheckpointStorage to CheckpointStorageCoordinatorView in method public getCheckpointStorage() : CheckpointStorageCoordinatorView in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Change Return Type CheckpointStorage to CheckpointStorageWorkerView in method public getCheckpointStorage() : CheckpointStorageWorkerView in class org.apache.flink.streaming.util.MockStreamTask | From | To | |
| Change Return Type CheckpointStorageLocation to CheckpointStreamFactory in method private createCheckpointStreamFactory() : CheckpointStreamFactory in class org.apache.flink.runtime.state.ttl.StateBackendTestContext | From | To | |
| Change Return Type CheckpointStorage to CheckpointStorageWorkerView in method public getCheckpointStorage() : CheckpointStorageWorkerView in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute checkpointStorageLocation : CheckpointStorageLocation to checkpointStreamFactory : CheckpointStreamFactory in class org.apache.flink.runtime.state.StateBackendTestBase | From | To | |
| Rename Attribute checkpointStorageLocation : CheckpointStorageLocation to checkpointStreamFactory : CheckpointStreamFactory in class org.apache.flink.runtime.state.ttl.StateBackendTestContext | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type checkpointStorage : CheckpointStorage to checkpointStorage : CheckpointStorageCoordinatorView in method private createTestingSavepoint() : URI in class org.apache.flink.runtime.dispatcher.DispatcherTest | From | To | |
| Extract Interface | 2 | ||
| Extract Interface org.apache.flink.runtime.state.CheckpointStorageCoordinatorView from classes [org.apache.flink.runtime.state.CheckpointStorage] | From | To | |
| Extract Interface org.apache.flink.runtime.state.CheckpointStorageWorkerView from classes [org.apache.flink.runtime.state.CheckpointStorage] | From | To | |
| Change Attribute Type | 7 | ||
| Change Attribute Type checkpointStorage : CheckpointStorage to checkpointStorage : CheckpointStorageCoordinatorView in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Change Attribute Type checkpointStorage : CheckpointStorage to checkpointStorage : CheckpointStorageWorkerView in class org.apache.flink.streaming.runtime.operators.GenericWriteAheadSink | From | To | |
| Change Attribute Type checkpointStorageLocation : CheckpointStorageLocation to checkpointStreamFactory : CheckpointStreamFactory in class org.apache.flink.runtime.state.ttl.StateBackendTestContext | From | To | |
| Change Attribute Type checkpointStorage : CheckpointStorage to checkpointStorage : CheckpointStorageWorkerView in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Change Attribute Type checkpointStorageLocation : CheckpointStorageLocation to checkpointStreamFactory : CheckpointStreamFactory in class org.apache.flink.runtime.state.StateBackendTestBase | From | To | |
| Change Attribute Type checkpointStorage : CheckpointStorage to checkpointStorage : CheckpointStorageWorkerView in class org.apache.flink.streaming.util.MockStreamTask | From | To | |
| Change Attribute Type checkpointStorage : CheckpointStorage to checkpointStorage : CheckpointStorageWorkerView in class org.apache.flink.streaming.util.MockStreamTaskBuilder | From | To |