This is an automated email from the ASF dual-hosted git repository.
zakelly pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 3a9597339a0 [FLINK-36494][table-common] Remove deprecated method
Catalog#getTableFactory (#25948)
new 4fce102f844 [FLINK-37045][Runtime] Move state descriptor v2 to
flink-core
new 04802953a1e [FLINK-37045][Runtime] Merge two versions of
KeyedStateStore
new c999e7e9a5d [FLINK-37045][Runtime] Merge two versions of
OperatorStateStore
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/api/common/state/KeyedStateStore.java | 115 +++++++++++++++++
.../flink/api/common/state/OperatorStateStore.java | 84 +++++++++++++
.../state/v2/AggregatingStateDescriptor.java | 4 +-
.../api/common}/state/v2/ListStateDescriptor.java | 5 +-
.../api/common}/state/v2/MapStateDescriptor.java | 5 +-
.../common}/state/v2/ReducingStateDescriptor.java | 4 +-
.../api/common}/state/v2/StateDescriptor.java | 7 +-
.../common}/state/v2/StateSerializerReference.java | 6 +-
.../api/common}/state/v2/ValueStateDescriptor.java | 5 +-
.../state/v2/AggregatingStateDescriptorTest.java | 2 +-
.../common}/state/v2/ListStateDescriptorTest.java | 2 +-
.../common}/state/v2/MapStateDescriptorTest.java | 2 +-
.../state/v2/ReducingStateDescriptorTest.java | 2 +-
.../api/common}/state/v2/StateDescriptorTest.java | 2 +-
.../common}/state/v2/ValueStateDescriptorTest.java | 2 +-
.../impl/context/AbstractPartitionedContext.java | 2 +-
.../impl/context/DefaultPartitionedContext.java | 2 +-
.../impl/context/DefaultStateManager.java | 12 +-
.../DefaultTwoOutputPartitionedContext.java | 2 +-
.../impl/operators/TwoOutputProcessOperator.java | 2 +-
.../apache/flink/cep/utils/TestSharedBuffer.java | 44 +++++++
.../AbstractAsyncStateStreamOperator.java | 10 +-
.../AbstractAsyncStateStreamOperatorV2.java | 9 +-
.../runtime/state/AsyncKeyedStateBackend.java | 2 +-
.../runtime/state/DefaultKeyedStateStore.java | 138 ++++++++++++++++++++-
.../runtime/state/DefaultOperatorStateBackend.java | 6 +-
.../flink/runtime/state/OperatorStateBackend.java | 4 -
.../runtime/state/v2/AbstractAggregatingState.java | 1 +
.../flink/runtime/state/v2/AbstractKeyedState.java | 1 +
.../flink/runtime/state/v2/AbstractListState.java | 1 +
.../flink/runtime/state/v2/AbstractMapState.java | 1 +
.../runtime/state/v2/AbstractReducingState.java | 1 +
.../flink/runtime/state/v2/AbstractValueState.java | 1 +
.../state/v2/AggregatingStateDescriptor.java | 48 ++-----
.../runtime/state/v2/DefaultKeyedStateStore.java | 109 ----------------
.../flink/runtime/state/v2/KeyedStateStore.java | 105 ----------------
.../runtime/state/v2/ListStateDescriptor.java | 29 +----
.../flink/runtime/state/v2/MapStateDescriptor.java | 89 ++-----------
.../flink/runtime/state/v2/OperatorStateStore.java | 117 -----------------
.../runtime/state/v2/ReducingStateDescriptor.java | 43 ++-----
.../v2/RegisteredKeyValueStateBackendMetaInfo.java | 1 +
.../runtime/state/v2/StateDescriptorUtils.java | 7 ++
.../runtime/state/v2/ValueStateDescriptor.java | 29 +----
.../v2/adaptor/AsyncKeyedStateBackendAdaptor.java | 2 +-
.../runtime/state/v2/ttl/TtlStateFactory.java | 12 +-
.../StreamGroupedReduceAsyncStateOperator.java | 2 +-
.../api/operators/StreamOperatorStateHandler.java | 27 +---
.../api/operators/StreamingRuntimeContext.java | 69 +++--------
.../AsyncExecutionControllerTest.java | 2 +-
.../flink/runtime/state/StateBackendTestUtils.java | 4 +-
.../state/v2/AbstractAggregatingStateTest.java | 1 +
.../state/v2/AbstractKeyedStateTestBase.java | 1 +
.../runtime/state/v2/AbstractListStateTest.java | 1 +
.../runtime/state/v2/AbstractMapStateTest.java | 1 +
.../state/v2/AbstractReducingStateTest.java | 1 +
.../runtime/state/v2/AbstractValueStateTest.java | 1 +
.../v2/AsyncKeyedStateBackendAdaptorTest.java | 6 +
.../runtime/state/v2/StateBackendTestV2Base.java | 1 +
.../api/operators/StreamingRuntimeContextTest.java | 63 ++++------
.../flink/state/forst/ForStAggregatingState.java | 2 +-
.../flink/state/forst/ForStKeyedStateBackend.java | 10 +-
.../apache/flink/state/forst/ForStListState.java | 2 +-
.../apache/flink/state/forst/ForStMapState.java | 4 +-
.../flink/state/forst/ForStReducingState.java | 2 +-
.../apache/flink/state/forst/ForStValueState.java | 2 +-
.../state/forst/ForStDBOperationTestBase.java | 8 +-
.../flink/state/forst/ForStListStateTest.java | 2 +-
.../ForStIncrementalSnapshotStrategyTest.java | 2 +-
.../collect/utils/MockOperatorStateStore.java | 9 +-
.../state/JoinRecordAsyncStateViews.java | 4 +-
.../state/OuterJoinRecordAsyncStateViews.java | 4 +-
71 files changed, 577 insertions(+), 731 deletions(-)
copy {flink-runtime/src/main/java/org/apache/flink/runtime =>
flink-core/src/main/java/org/apache/flink/api/common}/state/v2/AggregatingStateDescriptor.java
(96%)
copy {flink-runtime/src/main/java/org/apache/flink/runtime =>
flink-core/src/main/java/org/apache/flink/api/common}/state/v2/ListStateDescriptor.java
(94%)
copy {flink-runtime/src/main/java/org/apache/flink/runtime =>
flink-core/src/main/java/org/apache/flink/api/common}/state/v2/MapStateDescriptor.java
(97%)
copy {flink-runtime/src/main/java/org/apache/flink/runtime =>
flink-core/src/main/java/org/apache/flink/api/common}/state/v2/ReducingStateDescriptor.java
(96%)
rename {flink-runtime/src/main/java/org/apache/flink/runtime =>
flink-core/src/main/java/org/apache/flink/api/common}/state/v2/StateDescriptor.java
(97%)
rename {flink-runtime/src/main/java/org/apache/flink/runtime =>
flink-core/src/main/java/org/apache/flink/api/common}/state/v2/StateSerializerReference.java
(95%)
copy {flink-runtime/src/main/java/org/apache/flink/runtime =>
flink-core/src/main/java/org/apache/flink/api/common}/state/v2/ValueStateDescriptor.java
(95%)
rename {flink-runtime/src/test/java/org/apache/flink/runtime =>
flink-core/src/test/java/org/apache/flink/api/common}/state/v2/AggregatingStateDescriptorTest.java
(98%)
rename {flink-runtime/src/test/java/org/apache/flink/runtime =>
flink-core/src/test/java/org/apache/flink/api/common}/state/v2/ListStateDescriptorTest.java
(97%)
rename {flink-runtime/src/test/java/org/apache/flink/runtime =>
flink-core/src/test/java/org/apache/flink/api/common}/state/v2/MapStateDescriptorTest.java
(98%)
rename {flink-runtime/src/test/java/org/apache/flink/runtime =>
flink-core/src/test/java/org/apache/flink/api/common}/state/v2/ReducingStateDescriptorTest.java
(98%)
rename {flink-runtime/src/test/java/org/apache/flink/runtime =>
flink-core/src/test/java/org/apache/flink/api/common}/state/v2/StateDescriptorTest.java
(99%)
rename {flink-runtime/src/test/java/org/apache/flink/runtime =>
flink-core/src/test/java/org/apache/flink/api/common}/state/v2/ValueStateDescriptorTest.java
(97%)
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/DefaultKeyedStateStore.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/KeyedStateStore.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/OperatorStateStore.java
