public static class CheckpointStreamWithResultProvider.PrimaryAndSecondaryStream extends Object implements CheckpointStreamWithResultProvider
CheckpointStreamWithResultProvider
that creates both, the
primary/remote/jm-owned state and the secondary/local/tm-owned state.CheckpointStreamWithResultProvider.KeyedStateHandleFactory, CheckpointStreamWithResultProvider.PrimaryAndSecondaryStream, CheckpointStreamWithResultProvider.PrimaryStreamOnly
Constructor and Description |
---|
PrimaryAndSecondaryStream(CheckpointStateOutputStream primaryOut,
CheckpointStateOutputStream secondaryOut) |
Modifier and Type | Method and Description |
---|---|
SnapshotResult<StreamStateHandle> |
closeAndFinalizeCheckpointStreamResult()
Closes the stream ans returns a snapshot result with the stream handle(s).
|
DuplicatingCheckpointOutputStream |
getCheckpointOutputStream()
Returns the encapsulated output stream.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, createDuplicatingStream, createSimpleStream, toKeyedStateHandleSnapshotResult
public PrimaryAndSecondaryStream(@Nonnull CheckpointStateOutputStream primaryOut, CheckpointStateOutputStream secondaryOut) throws IOException
IOException
@Nonnull public SnapshotResult<StreamStateHandle> closeAndFinalizeCheckpointStreamResult() throws IOException
CheckpointStreamWithResultProvider
closeAndFinalizeCheckpointStreamResult
in interface CheckpointStreamWithResultProvider
IOException
@Nonnull public DuplicatingCheckpointOutputStream getCheckpointOutputStream()
CheckpointStreamWithResultProvider
getCheckpointOutputStream
in interface CheckpointStreamWithResultProvider
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.