|
Change Return Type ValueState<S> to OperatorState<S> in method public getKeyValueState(name String, stateType Class<S>, defaultState S) : OperatorState<S> in class org.apache.flink.streaming.api.operators.StreamingRuntimeContext |
From |
To |
|
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.api.common.functions.RuntimeContext |
From |
To |
|
Change Return Type ValueState<S> to OperatorState<S> in method public getKeyValueState(name String, stateType Class<S>, defaultState S) : OperatorState<S> in class org.apache.flink.streaming.connectors.kafka.testutils.MockRuntimeContext |
From |
To |
|
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.api.operators.StreamingRuntimeContext |
From |
To |
|
Change Return Type ValueState<S> to OperatorState<S> in method public getKeyValueState(name String, stateType Class<S>, defaultState S) : OperatorState<S> in class org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext |
From |
To |
|
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.api.common.functions.util.AbstractRuntimeUDFContext |
From |
To |
|
Change Return Type ValueState<S> to OperatorState<S> in method public getKeyValueState(name String, stateType Class<S>, defaultState S) : OperatorState<S> in class org.apache.flink.api.common.functions.RuntimeContext |
From |
To |
|
Change Attribute Type aCounts : OperatorState<NonSerializableLong> to aCounts : ValueState<NonSerializableLong> in class org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase.CounterSink |
From |
To |
|
Change Attribute Type sum : OperatorState<Long> to sum : ValueState<Long> in class org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase.OnceFailingPartitionedSum |
From |
To |
|
Change Attribute Type aCounts : OperatorState<NonSerializableLong> to aCounts : ValueState<NonSerializableLong> in class org.apache.flink.contrib.streaming.state.DBStateCheckpointingTest.CounterSink |
From |
To |
|
Change Attribute Type bCounts : OperatorState<Long> to bCounts : ValueState<Long> in class org.apache.flink.contrib.streaming.state.DBStateCheckpointingTest.CounterSink |
From |
To |
|
Change Attribute Type sum : OperatorState<Long> to sum : ValueState<Long> in class org.apache.flink.contrib.streaming.state.DBStateCheckpointingTest.OnceFailingPartitionedSum |
From |
To |
|
Change Attribute Type pCount : OperatorState<Long> to pCount : ValueState<Long> in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.OnceFailingPrefixCounter |
From |
To |