This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from f234fad [FLINK-19247][docs-zh] Update Chinese documentation after
removal of Kafka 0.10 and 0.11
add 1aea5f0 [FLINK-19474] Implement a state backend that holds a single
key at a time
No new revisions were added by this update.
Summary of changes:
.../benchmark/StateBackendBenchmarkUtils.java | 22 +-
.../benchmark/StateBackendBenchmarkUtilsTest.java | 4 +
.../state/AbstractBatchExecutionKeyState.java | 125 ++
.../BatchExecutionInternalPriorityQueueSet.java | 78 ++
.../state/BatchExecutionKeyAggregatingState.java | 90 ++
.../sorted/state/BatchExecutionKeyListState.java | 101 ++
.../sorted/state/BatchExecutionKeyMapState.java | 126 ++
.../state/BatchExecutionKeyReducingState.java | 90 ++
.../sorted/state/BatchExecutionKeyValueState.java | 63 +
.../state/BatchExecutionKeyedStateBackend.java | 260 ++++
.../sorted/state/BatchExecutionStateBackend.java | 86 ++
.../MergingAbstractBatchExecutionKeyState.java | 73 +
.../sorted/state/NonCheckpointingStorage.java | 76 ++
...BatchExecutionInternalPriorityQueueSetTest.java | 37 +
.../state/BatchExecutionStateBackendTest.java | 1431 ++++++++++++++++++++
...BatchExecutionStateBackendVerificationTest.java | 110 ++
16 files changed, 2771 insertions(+), 1 deletion(-)
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sorted/state/AbstractBatchExecutionKeyState.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sorted/state/BatchExecutionInternalPriorityQueueSet.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sorted/state/BatchExecutionKeyAggregatingState.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sorted/state/BatchExecutionKeyListState.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sorted/state/BatchExecutionKeyMapState.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sorted/state/BatchExecutionKeyReducingState.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sorted/state/BatchExecutionKeyValueState.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sorted/state/BatchExecutionKeyedStateBackend.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sorted/state/BatchExecutionStateBackend.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sorted/state/MergingAbstractBatchExecutionKeyState.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sorted/state/NonCheckpointingStorage.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/sorted/state/BatchExecutionInternalPriorityQueueSetTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/sorted/state/BatchExecutionStateBackendTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/sorted/state/BatchExecutionStateBackendVerificationTest.java
