cf49ebbb488822c2dea7f59d35dbcc4a85da88c5
Files Diff
- Added: 0
- Removed: 5
- Renamed: 0
- Modified: 8
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public getCheckpointedState() : T renamed to public restore() : OperatorState<T> in class org.apache.flink.runtime.state.StateCheckpoint | From | To | |
| Pull Up Method | 1 | ||
| Pull Up Method public checkpoint() : StateCheckpoint<T> from class org.apache.flink.streaming.state.SimpleState to public checkpoint() : StateCheckpoint<T> from class org.apache.flink.runtime.state.OperatorState | From | To | |
| Move And Rename Method | 1 | ||
| Move And Rename Method public SimpleState(initialState T) from class org.apache.flink.streaming.state.SimpleState to public PartitionableState(initialState T) from class org.apache.flink.streaming.state.PartitionableState | From | To | |
| Change Return Type | 1 | ||
| Change Return Type T to OperatorState<T> in method public restore() : OperatorState<T> in class org.apache.flink.runtime.state.StateCheckpoint | From | To | |
| Move Attribute | 1 | ||
| Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.state.SimpleState to private serialVersionUID : long from class org.apache.flink.streaming.connectors.kafka.api.simple.PersistentKafkaSource | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute state : T to stateObject : T in class org.apache.flink.runtime.state.OperatorState | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type lastKafkaOffSet : SimpleState<Long> to lastKafkaOffSet : OperatorState<Long> in method public open(parameters Configuration) : void in class org.apache.flink.streaming.connectors.kafka.api.simple.PersistentKafkaSource | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type checkpointedState : T to checkpointedState : OperatorState<T> in class org.apache.flink.runtime.state.StateCheckpoint | From | To | |
| Change Attribute Type kafkaOffSet : SimpleState<Long> to kafkaOffSet : OperatorState<Long> in class org.apache.flink.streaming.connectors.kafka.api.simple.PersistentKafkaSource | From | To |