forked from apache/flink
-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
1 changed file
with
41 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,41 @@ | ||
# Jira | ||
https://issues.apache.org/jira/browse/FLINK-35153 | ||
|
||
# Commits | ||
|
||
- [FLINK-35153][State] Internal async map state and corresponding state descriptor | ||
- [FLINK-35153][State] Internal async list state and corresponding state descriptor | ||
|
||
# PR title | ||
|
||
[FLINK-35153][State] Internal Async State Implementation and StateDescriptor for Map/List State | ||
|
||
# PR description | ||
|
||
## What is the purpose of the change | ||
|
||
This PR provides the direct implementation of user-facing list/map State V2 APIs, which simply create async `StateRequest` and hand it to the `AsyncExecutionController`. | ||
|
||
## Brief change log | ||
|
||
- Implement `InternalMapState` and corresponding `MapStateDescriptor` under `org.apache.flink.runtime.state.v2`. | ||
- Implement `InternalListState` and corresponding `ListStateDescriptor` under `org.apache.flink.runtime.state.v2`. | ||
|
||
|
||
## Verifying this change | ||
|
||
- Added UTs for newly introduced state implementations and descriptors. | ||
|
||
## Does this pull request potentially affect one of the following parts: | ||
|
||
- Dependencies (does it add or upgrade a dependency): no | ||
- The public API, i.e., is any changed class annotated with `@Public(Evolving)`: no | ||
- The serializers: no | ||
- The runtime per-record code paths (performance sensitive): no | ||
- Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: no | ||
- The S3 file system connector: no | ||
|
||
## Documentation | ||
|
||
- Does this pull request introduce a new feature? no | ||
- If yes, how is the feature documented? not applicable |