This is an automated email from the ASF dual-hosted git repository.
hangxiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from d271495c5be [hotfix] Fix compile error in
DataStreamV2SinkTransformation
add f38d8ca43f6 [FLINK-34978][State] Introduce Asynchronous State APIs
(#24595)
No new revisions were added by this update.
Summary of changes:
.../flink/api/common/state/v2/AppendingState.java | 65 +++++++++
.../flink/api/common/state/v2/ListState.java | 71 ++++++++++
.../apache/flink/api/common/state/v2/MapState.java | 149 +++++++++++++++++++++
.../flink/api/common/state/v2/MergingState.java | 32 +++++
.../apache/flink/api/common/state/v2/State.java | 36 +++++
.../flink/api/common/state/v2/StateFuture.java | 75 +++++++++++
.../api/common/state/v2/StateFutureUtils.java | 50 +++++++
.../flink/api/common/state/v2/StateIterator.java | 55 ++++++++
.../flink/api/common/state/v2/ValueState.java | 61 +++++++++
9 files changed, 594 insertions(+)
create mode 100644
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/AppendingState.java
create mode 100644
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/ListState.java
create mode 100644
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/MapState.java
create mode 100644
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/MergingState.java
create mode 100644
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/State.java
create mode 100644
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/StateFuture.java
create mode 100644
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/StateFutureUtils.java
create mode 100644
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/StateIterator.java
create mode 100644
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/ValueState.java