final Snapshot.State snapshotState;
try {
- snapshotState = convertSnapshot(snapshotBytes);
+ snapshotState = snapshotCohort.deserializeSnapshot(snapshotBytes);
} catch (IOException e) {
LOG.debug("{}: failed to convert InstallSnapshot to state", memberId(), e);
snapshot.callback().onFailure();
this.snapshotCohort = requireNonNull(snapshotCohort);
}
- Snapshot.@NonNull State convertSnapshot(final ByteSource snapshotBytes) throws IOException {
- return snapshotCohort.deserializeSnapshot(snapshotBytes);
- }
-
long getLastSequenceNumber() {
return task instanceof Persist persist ? persist.lastSequenceNumber() : -1;
}