public interface CheckpointStreamWithResultProvider extends Closeable
SnapshotResult
. This abstracts from different ways that a result is obtained from
checkpoint output streams.Modifier and Type | Interface and Description |
---|---|
static interface |
CheckpointStreamWithResultProvider.KeyedStateHandleFactory
Factory method for a
KeyedStateHandle to be used in toKeyedStateHandleSnapshotResult(SnapshotResult, KeyGroupRangeOffsets,
KeyedStateHandleFactory) . |
static class |
CheckpointStreamWithResultProvider.PrimaryAndSecondaryStream
Implementation of
CheckpointStreamWithResultProvider that creates both, the
primary/remote/jm-owned state and the secondary/local/tm-owned state. |
static class |
CheckpointStreamWithResultProvider.PrimaryStreamOnly
Implementation of
CheckpointStreamWithResultProvider that only creates the
primary/remote/jm-owned state. |
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
LOG |
@Nonnull SnapshotResult<StreamStateHandle> closeAndFinalizeCheckpointStreamResult() throws IOException
IOException
@Nonnull CheckpointStateOutputStream getCheckpointOutputStream()
default void close() throws IOException
close
in interface AutoCloseable
close
in interface Closeable
IOException
@Nonnull static CheckpointStreamWithResultProvider createSimpleStream(@Nonnull CheckpointedStateScope checkpointedStateScope, @Nonnull CheckpointStreamFactory primaryStreamFactory) throws IOException
IOException
@Nonnull static CheckpointStreamWithResultProvider createDuplicatingStream(@Nonnegative long checkpointId, @Nonnull CheckpointedStateScope checkpointedStateScope, @Nonnull CheckpointStreamFactory primaryStreamFactory, @Nonnull LocalRecoveryDirectoryProvider secondaryStreamDirProvider) throws IOException
IOException
@Nonnull static SnapshotResult<KeyedStateHandle> toKeyedStateHandleSnapshotResult(@Nonnull SnapshotResult<StreamStateHandle> snapshotResult, @Nonnull KeyGroupRangeOffsets keyGroupRangeOffsets, @Nonnull CheckpointStreamWithResultProvider.KeyedStateHandleFactory stateHandleFactory)
SnapshotResult
and a KeyGroupRangeOffsets
and creates a SnapshotResult
by combining the
key groups offsets with all the present stream state handles.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.