private final ShardDataTree store;
private final String shardName;
private final Logger log;
- private final byte[] restoreFromSnapshot;
+ private final Snapshot restoreFromSnapshot;
private boolean open;
- ShardRecoveryCoordinator(final ShardDataTree store, final byte[] restoreFromSnapshot, final String shardName,
+ ShardRecoveryCoordinator(final ShardDataTree store, final Snapshot restoreFromSnapshot, final String shardName,
final Logger log) {
this.store = Preconditions.checkNotNull(store);
this.shardName = Preconditions.checkNotNull(shardName);
/**
* Applies a recovered snapshot to the data store.
*
- * @param snapshotBytes the serialized snapshot
+ * @param snapshotState the serialized snapshot
*/
@Override
@SuppressWarnings("checkstyle:IllegalCatch")
}
@Override
- public byte[] getRestoreFromSnapshot() {
+ public Snapshot getRestoreFromSnapshot() {
return restoreFromSnapshot;
}
@Override
@Deprecated
- public State deserializePreCarbonSnapshot(byte[] from) {
+ public State deserializePreCarbonSnapshot(final byte[] from) {
try {
- return new ShardSnapshotState(ShardDataTreeSnapshot.deserialize(from));
+ return new ShardSnapshotState(ShardDataTreeSnapshot.deserializePreCarbon(from));
} catch (IOException e) {
log.error("{}: failed to deserialize snapshot", shardName, e);
throw Throwables.propagate(e);