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
[FLINK-34977][API] Introduce State Access on DataStream API V2 #24725
base: master
Are you sure you want to change the base?
Conversation
8e8ae38
to
1d8ee5d
Compare
24ece2b
to
8dcaa92
Compare
01c49c9
to
186e36a
Compare
Hello @jeyhunkarimov, have you completed this pull request?I'd like to review it. BTW, you should add the introduction of this pr. |
Hi @WencongLiu the PR is theorethically ready for review. I did not marked as |
186e36a
to
f37668b
Compare
28979f3
to
10638df
Compare
What is the purpose of the change
This PR introduces a series of sub-PRs to support state access on Datastream API v2 (FLIP-433)
Brief change log
usesStates()
) of their first input and for their both first and second input (viausesStatesForSideInput()
)StateManager
getState()
with underlying state infrastructureVerifying this change
This change is covered by tests:
TypeDescriptionUtilsTest
DefaultStateManagerTest
BroadcastStreamImplTest
GlobalStreamImplTest
KeyedPartitionStreamImplTest
NonKeyedPartitionStreamImplTest
Does this pull request potentially affect one of the following parts:
@Public(Evolving)
: (yes)Documentation