This is an automated email from the ASF dual-hosted git repository.
sjwiesman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from f612388 [FLINK-19508][DataStream] Add collect() operation on
DataStream
add d2b86a1 [FLINK-19464][runtime] Rename CheckpointStorage interface to
CheckpointStorageAccess
No new revisions were added by this update.
Summary of changes:
.../flink/streaming/tests/StubStateBackend.java | 4 +--
.../state/api/output/SavepointOutputFormat.java | 4 +--
.../flink/state/api/output/SnapshotUtils.java | 4 +--
.../flink/state/api/runtime/SavepointLoader.java | 4 +--
.../metadata/MetadataV2V3SerializerBase.java | 4 +--
...ntStorage.java => CheckpointStorageAccess.java} | 2 +-
.../runtime/state/CheckpointStorageLocation.java | 4 +--
.../runtime/state/CheckpointStreamFactory.java | 4 +--
.../apache/flink/runtime/state/StateBackend.java | 2 +-
.../state/filesystem/AbstractFileStateBackend.java | 4 +--
...java => AbstractFsCheckpointStorageAccess.java} | 6 ++--
...Storage.java => FsCheckpointStorageAccess.java} | 6 ++--
.../filesystem/FsCheckpointStorageLocation.java | 2 +-
.../runtime/state/filesystem/FsStateBackend.java | 6 ++--
...a => MemoryBackendCheckpointStorageAccess.java} | 6 ++--
.../runtime/state/memory/MemoryStateBackend.java | 6 ++--
...ersistentMetadataCheckpointStorageLocation.java | 4 +--
.../checkpoint/CheckpointCoordinatorTest.java | 8 ++---
.../CheckpointSettingsSerializableTest.java | 6 ++--
...ChannelStateWriteRequestDispatcherImplTest.java | 4 +--
.../OperatorCoordinatorSchedulerTest.java | 4 +--
.../state/StateBackendMigrationTestBase.java | 6 ++--
...ingCheckpointStorageAccessCoordinatorView.java} | 8 ++---
...stractFileCheckpointStorageAccessTestBase.java} | 34 +++++++++---------
...est.java => FsCheckpointStorageAccessTest.java} | 30 ++++++++--------
.../filesystem/FsStateBackendEntropyTest.java | 2 +-
.../filesystem/FsStorageLocationReferenceTest.java | 4 +--
...java => MemoryCheckpointStorageAccessTest.java} | 40 +++++++++++-----------
.../state/testutils/BackendForTestStream.java | 8 ++---
.../runtime/state/ttl/mock/MockStateBackend.java | 6 ++--
.../streaming/state/RocksDBStateBackend.java | 4 +--
.../sorted/state/BatchExecutionStateBackend.java | 6 ++--
...age.java => NonCheckpointingStorageAccess.java} | 6 ++--
.../StreamTaskStateInitializerImplTest.java | 4 +--
.../MockSubtaskCheckpointCoordinatorBuilder.java | 4 +--
.../runtime/tasks/StreamTaskTerminationTest.java | 8 ++---
.../runtime/tasks/TestSpyWrapperStateBackend.java | 4 +--
.../util/AbstractStreamOperatorTestHarness.java | 10 +++---
.../streaming/util/MockStreamTaskBuilder.java | 6 ++--
.../test/streaming/runtime/StateBackendITCase.java | 8 ++---
40 files changed, 147 insertions(+), 145 deletions(-)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/state/{CheckpointStorage.java
=> CheckpointStorageAccess.java} (91%)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/{AbstractFsCheckpointStorage.java
=> AbstractFsCheckpointStorageAccess.java} (98%)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/{FsCheckpointStorage.java
=> FsCheckpointStorageAccess.java} (97%)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/{MemoryBackendCheckpointStorage.java
=> MemoryBackendCheckpointStorageAccess.java} (97%)
rename
flink-runtime/src/test/java/org/apache/flink/runtime/state/{TestingCheckpointStorageCoordinatorView.java
=> TestingCheckpointStorageAccessCoordinatorView.java} (94%)
rename
flink-runtime/src/test/java/org/apache/flink/runtime/state/filesystem/{AbstractFileCheckpointStorageTestBase.java
=> AbstractFileCheckpointStorageAccessTestBase.java} (90%)
rename
flink-runtime/src/test/java/org/apache/flink/runtime/state/filesystem/{FsCheckpointStorageTest.java
=> FsCheckpointStorageAccessTest.java} (87%)
rename
flink-runtime/src/test/java/org/apache/flink/runtime/state/memory/{MemoryCheckpointStorageTest.java
=> MemoryCheckpointStorageAccessTest.java} (79%)
rename
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sorted/state/{NonCheckpointingStorage.java
=> NonCheckpointingStorageAccess.java} (92%)
