Skip to content

Commit

Permalink
README
Browse files Browse the repository at this point in the history
  • Loading branch information
Zakelly committed May 9, 2024
1 parent 3597a2d commit 4f4a30a
Showing 1 changed file with 41 additions and 0 deletions.
41 changes: 41 additions & 0 deletions README-FLINK35153
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

0 comments on commit 4f4a30a

Please sign in to comment.