0f8d76c6f71e0b4a07ed11a112c3bd21c300e966
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 73
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Move And Inline Method | 3 | ||
Move And Inline Method public getRestartStrategyConfiguration() : RestartStrategies.RestartStrategyConfiguration moved from class org.apache.flink.api.common.Plan to class org.apache.flink.streaming.api.RestartStrategyTest & inlined to public testFixedRestartingWhenCheckpointingAndExplicitExecutionRetriesNonZero() : void | From | To | |
Move And Inline Method public getRestartStrategyConfiguration() : RestartStrategies.RestartStrategyConfiguration moved from class org.apache.flink.api.common.Plan to class org.apache.flink.streaming.api.RestartStrategyTest & inlined to public testAutomaticRestartingWhenCheckpointing() : void | From | To | |
Move And Inline Method public getRestartStrategyConfiguration() : RestartStrategies.RestartStrategyConfiguration moved from class org.apache.flink.api.common.Plan to class org.apache.flink.streaming.api.RestartStrategyTest & inlined to public testNoRestartingWhenCheckpointingAndExplicitExecutionRetriesZero() : void | From | To | |
Change Parameter Type | 1 | ||
Change Parameter Type jobName : String to config : ExecutionConfig in method public JobGraph(config ExecutionConfig, vertices JobVertex...) in class org.apache.flink.runtime.jobgraph.JobGraph | From | To | |
Move Attribute | 2 | ||
Move Attribute private executionConfig : ExecutionConfig from class org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable to private executionConfig : ExecutionConfig from class org.apache.flink.runtime.taskmanager.Task | From | To | |
Move Attribute private executionConfig : ExecutionConfig from class org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable to private executionConfig : ExecutionConfig from class org.apache.flink.runtime.jobgraph.JobGraph | From | To | |
Extract Variable | 1 | ||
Extract Variable EXEC_CONFIG_KEY : String in method public testExecutionConfigSerialization() : void from class org.apache.flink.streaming.api.graph.StreamingJobGraphGeneratorTest | From | To | |
Rename Parameter | 1 | ||
Rename Parameter jobName : String to config : ExecutionConfig in method public JobGraph(config ExecutionConfig, vertices JobVertex...) in class org.apache.flink.runtime.jobgraph.JobGraph | From | To |