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