-
Notifications
You must be signed in to change notification settings - Fork 13.8k
[FLINK-34978][State] Introduce Asynchronous State APIs #24595
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
|
Rebase on FLINK-34548 and introduce this in |
masteryhx
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for the PR.
PTAL my comments.
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/AppendingState.java
Outdated
Show resolved
Hide resolved
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/MapState.java
Show resolved
Hide resolved
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/State.java
Show resolved
Hide resolved
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/MapState.java
Show resolved
Hide resolved
|
@masteryhx Thanks for your suggestion! I modified accordingly, PTAL. Thanks! By the way, the CI failure is caused by #24596 |
Thanks for the update. Overall LGTM. |
masteryhx
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for the update.
LGTM.
What is the purpose of the change
As discussed in FLIP-424, we will introduce a new set of State APIs for asynchronous state access. This PR provides the definition of this API as described in FLIP-424.
Brief change log
org.apache.flink.api.common.state.v2.Verifying this change
This change is a trivial rework without any test coverage.
Does this pull request potentially affect one of the following parts:
@Public(Evolving): noDocumentation