e4d05f72e91f03e4f350cf42c31c5ec85fe86c53
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 11
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 3 | ||
| Rename Method public getPartitionedState(stateDescriptor StateDescriptor<S>) : S renamed to public getReducingState(stateProperties ReducingStateDescriptor<T>) : ReducingState<T> in class org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext | From | To | |
| Rename Method public getPartitionedState(stateDescriptor StateDescriptor<S>) : S renamed to public getReducingState(stateProperties ReducingStateDescriptor<T>) : ReducingState<T> in class org.apache.flink.api.common.functions.RuntimeContext | From | To | |
| Rename Method public getPartitionedState(stateDescriptor StateDescriptor<S>) : S renamed to public getReducingState(stateProperties ReducingStateDescriptor<T>) : ReducingState<T> in class org.apache.flink.streaming.connectors.kafka.testutils.MockRuntimeContext | From | To | |
| Change Parameter Type | 3 | ||
| Change Parameter Type stateDescriptor : StateDescriptor<S> to stateProperties : ReducingStateDescriptor<T> in method public getReducingState(stateProperties ReducingStateDescriptor<T>) : ReducingState<T> in class org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext | From | To | |
| Change Parameter Type stateDescriptor : StateDescriptor<S> to stateProperties : ReducingStateDescriptor<T> in method public getReducingState(stateProperties ReducingStateDescriptor<T>) : ReducingState<T> in class org.apache.flink.api.common.functions.RuntimeContext | From | To | |
| Change Parameter Type stateDescriptor : StateDescriptor<S> to stateProperties : ReducingStateDescriptor<T> in method public getReducingState(stateProperties ReducingStateDescriptor<T>) : ReducingState<T> in class org.apache.flink.streaming.connectors.kafka.testutils.MockRuntimeContext | From | To | |
| Rename Variable | 1 | ||
| Rename Variable stateDesc : ValueStateDescriptor<S> to stateProps : ValueStateDescriptor<S> in method public getKeyValueState(name String, stateType TypeInformation<S>, defaultState S) : OperatorState<S> in class org.apache.flink.streaming.api.operators.StreamingRuntimeContext | From | To | |
| Change Return Type | 4 | ||
| Change Return Type ValueState<S> to OperatorState<S> in method public getKeyValueState(name String, stateType TypeInformation<S>, defaultState S) : OperatorState<S> in class org.apache.flink.streaming.connectors.kafka.testutils.MockRuntimeContext | From | To | |
| Change Return Type S to ReducingState<T> in method public getReducingState(stateProperties ReducingStateDescriptor<T>) : ReducingState<T> in class org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext | From | To | |
| Change Return Type S to ReducingState<T> in method public getReducingState(stateProperties ReducingStateDescriptor<T>) : ReducingState<T> in class org.apache.flink.api.common.functions.RuntimeContext | From | To | |
| Change Return Type S to ReducingState<T> in method public getReducingState(stateProperties ReducingStateDescriptor<T>) : ReducingState<T> in class org.apache.flink.streaming.connectors.kafka.testutils.MockRuntimeContext | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type state : OperatorState<Integer> to state : ValueState<Integer> in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest.StatefulFunction | From | To | |
| Change Attribute Type state : OperatorState<Integer> to state : ValueState<Integer> in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest.StatefulFunction | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter stateDescriptor : StateDescriptor<S> to stateProperties : ReducingStateDescriptor<T> in method public getReducingState(stateProperties ReducingStateDescriptor<T>) : ReducingState<T> in class org.apache.flink.api.common.functions.RuntimeContext | From | To | |
| Rename Parameter stateDescriptor : StateDescriptor<S> to stateProperties : ReducingStateDescriptor<T> in method public getReducingState(stateProperties ReducingStateDescriptor<T>) : ReducingState<T> in class org.apache.flink.streaming.connectors.kafka.testutils.MockRuntimeContext | From | To | |
| Rename Parameter stateDescriptor : StateDescriptor<S> to stateProperties : ReducingStateDescriptor<T> in method public getReducingState(stateProperties ReducingStateDescriptor<T>) : ReducingState<T> in class org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext | From | To |