@Internal public interface StateSnapshot
StateSnapshot
is produced
for a state and captures the state at this point in time. Then, in the asynchronous part of the checkpoint, the user
calls getKeyGroupWriter()
to ensure that the snapshot is partitioned into key-groups. For state that is
already partitioned, this can be a NOP. The returned StateSnapshot.StateKeyGroupWriter
can be used by the caller
to write the state by key-group. As a last step, when the state is completely written, the user calls
release()
.Modifier and Type | Interface and Description |
---|---|
static interface |
StateSnapshot.StateKeyGroupWriter
Interface for writing a snapshot that is partitioned into key-groups.
|
Modifier and Type | Method and Description |
---|---|
StateSnapshot.StateKeyGroupWriter |
getKeyGroupWriter()
This method returns
StateSnapshot.StateKeyGroupWriter and should be called in the asynchronous part of the snapshot. |
StateMetaInfoSnapshot |
getMetaInfoSnapshot()
Returns a snapshot of the state's meta data.
|
void |
release()
Release the snapshot.
|
@Nonnull StateSnapshot.StateKeyGroupWriter getKeyGroupWriter()
StateSnapshot.StateKeyGroupWriter
and should be called in the asynchronous part of the snapshot.@Nonnull StateMetaInfoSnapshot getMetaInfoSnapshot()
void release()
StateSnapshot.StateKeyGroupWriter
should no longer be used
after calling this method.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.