This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 0daa8de [FLINK-13996][docs] Update instructions on building with
Maven 3.3+
add 033e3e3 [FLINK-21151] Separate iterator creation from metadata
writing in RocksFullSnapshotStrategy
add dfb0275 [FLINK-21151] Pass whole resources instead of fields in
RocksFullSnapshotStrategy
add 09c230f [FLINK-21151] Move iterator creation one level up in
RocksFullSnapshotStrategy
add 3dd0940 [FLINK-21151] Properly take ownership in merging iterator in
RocksFullSnapshotStrategy
add 9d46ff4 [FLINK-21151] Use CloseableRegistry to keep track of merging
RocksDB iterator resources
add a397360 [FLINK-21151] Move KV-State iterator creation to RocksDB
snapshot resources
add 5308dbd [FLINK-21151] Extract common interfaces from RocksDB state
iterator and resources
add 9a74bd6 [FLINK-21151] Move asynchronous writing part out of RocksDB
strategy
add dd0ee24 [FLINK-21151] Make RocksDBFullSnapshotResources a toplevel
class
No new revisions were added by this update.
Summary of changes:
.../runtime/state/FullSnapshotAsyncWriter.java | 233 ++++++++++++++
.../flink/runtime/state/FullSnapshotResources.java | 57 ++++
.../flink/runtime/state/FullSnapshotUtil.java | 15 +-
.../flink/runtime/state/KeyValueStateIterator.java | 73 +++++
.../state/iterator/RocksSingleStateIterator.java | 4 +-
.../RocksStatesPerKeyGroupMergeIterator.java | 73 +++--
.../state/restore/RocksDBFullRestoreOperation.java | 6 +-
.../snapshot/RocksDBFullSnapshotResources.java | 203 ++++++++++++
.../state/snapshot/RocksFullSnapshotStrategy.java | 354 ++-------------------
.../state/snapshot/RocksSnapshotUtil.java | 18 +-
.../streaming/state/RocksDBAsyncSnapshotTest.java | 10 +-
...RocksKeyGroupsRocksSingleStateIteratorTest.java | 5 +-
12 files changed, 644 insertions(+), 407 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/state/FullSnapshotAsyncWriter.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/state/FullSnapshotResources.java
copy
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksSnapshotUtil.java
=>
flink-runtime/src/main/java/org/apache/flink/runtime/state/FullSnapshotUtil.java
(74%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyValueStateIterator.java
create mode 100644
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksDBFullSnapshotResources.java
