[FLINK-10042][state] (part 2) Refactoring of snapshot algorithms for …

…better abstraction and cleaner resource management This closes apache#6556.
sceee · Aug 21, 2018 · f803280 · f803280
1 parent aba02eb
commit f803280
Show file tree

Hide file tree

Showing 22 changed files with 1,329 additions and 1,146 deletions.
diff --git a/...e/src/main/java/org/apache/flink/runtime/io/async/AbstractAsyncCallableWithResources.java b/...e/src/main/java/org/apache/flink/runtime/io/async/AbstractAsyncCallableWithResources.java
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/async/AsyncDoneCallback.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/async/AsyncDoneCallback.java
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/async/AsyncStoppable.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/async/AsyncStoppable.java
diff --git a/...ntime/src/main/java/org/apache/flink/runtime/io/async/AsyncStoppableTaskWithCallback.java b/...ntime/src/main/java/org/apache/flink/runtime/io/async/AsyncStoppableTaskWithCallback.java
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/async/StoppableCallbackCallable.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/async/StoppableCallbackCallable.java