|
Change Parameter Type stateDescriptor : AggregatingStateDescriptor<IN,ACC,OUT> to stateDescriptor : StateDescriptor<S,ACC> in method public createState(stateDescriptor StateDescriptor<S,ACC>, serializedState byte[]) : S in class org.apache.flink.queryablestate.client.state.ImmutableAggregatingState |
From |
To |
|
Change Parameter Type stateDescriptor : ReducingStateDescriptor<V> to stateDescriptor : StateDescriptor<S,V> in method public createState(stateDescriptor StateDescriptor<S,V>, serializedState byte[]) : S in class org.apache.flink.queryablestate.client.state.ImmutableReducingState |
From |
To |
|
Change Parameter Type stateDescriptor : FoldingStateDescriptor<IN,ACC> to stateDescriptor : StateDescriptor<S,ACC> in method public createState(stateDescriptor StateDescriptor<S,ACC>, serializedState byte[]) : S in class org.apache.flink.queryablestate.client.state.ImmutableFoldingState |
From |
To |
|
Change Parameter Type stateDescriptor : ValueStateDescriptor<V> to stateDescriptor : StateDescriptor<S,V> in method public createState(stateDescriptor StateDescriptor<S,V>, serializedState byte[]) : S in class org.apache.flink.queryablestate.client.state.ImmutableValueState |
From |
To |
|
Change Return Type ImmutableFoldingState<IN,ACC> to S in method public createState(stateDescriptor StateDescriptor<S,ACC>, serializedState byte[]) : S in class org.apache.flink.queryablestate.client.state.ImmutableFoldingState |
From |
To |
|
Change Return Type ImmutableMapState<K,V> to S in method public createState(stateDescriptor StateDescriptor<S,T>, serializedState byte[]) : S in class org.apache.flink.queryablestate.client.state.ImmutableMapState |
From |
To |
|
Change Return Type ImmutableValueState<V> to S in method public createState(stateDescriptor StateDescriptor<S,V>, serializedState byte[]) : S in class org.apache.flink.queryablestate.client.state.ImmutableValueState |
From |
To |
|
Change Return Type ImmutableReducingState<V> to S in method public createState(stateDescriptor StateDescriptor<S,V>, serializedState byte[]) : S in class org.apache.flink.queryablestate.client.state.ImmutableReducingState |
From |
To |
|
Change Return Type ImmutableAggregatingState<IN,OUT> to S in method public createState(stateDescriptor StateDescriptor<S,ACC>, serializedState byte[]) : S in class org.apache.flink.queryablestate.client.state.ImmutableAggregatingState |
From |
To |
|
Change Attribute Type aggrState : ImmutableAggregatingState<Long,String> to aggrState : AggregatingState<Long,String> in class org.apache.flink.queryablestate.client.state.ImmutableAggregatingStateTest |
From |
To |
|
Change Attribute Type foldingState : ImmutableFoldingState<Long,String> to foldingState : FoldingState<Long,String> in class org.apache.flink.queryablestate.client.state.ImmutableFoldingStateTest |
From |
To |
|
Change Attribute Type mapState : ImmutableMapState<Long,Long> to mapState : MapState<Long,Long> in class org.apache.flink.queryablestate.client.state.ImmutableMapStateTest |
From |
To |
|
Change Attribute Type listState : ImmutableListState<Long> to listState : ListState<Long> in class org.apache.flink.queryablestate.client.state.ImmutableListStateTest |
From |
To |
|
Change Attribute Type valueState : ImmutableValueState<Long> to valueState : ValueState<Long> in class org.apache.flink.queryablestate.client.state.ImmutableValueStateTest |
From |
To |
|
Change Attribute Type reduceState : ImmutableReducingState<Long> to reduceState : ReducingState<Long> in class org.apache.flink.queryablestate.client.state.ImmutableReducingStateTest |
From |
To |