+
+ try {
+ snapshotInputStream = snapshotBytes.openStream();
+ } catch (IOException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ @Override
+ public void close() {
+ closeStream();
+ snapshotBytes = null;
+ }
+
+ private void closeStream() {
+ if (snapshotInputStream != null) {
+ try {
+ snapshotInputStream.close();
+ } catch (IOException e) {
+ LOG.warn("{}: Error closing snapshot stream", logName);
+ }
+
+ snapshotInputStream = null;
+ }