Package org.apache.hadoop.ozone.om.snapshot

Class SnapshotDiffManager

java.lang.Object

org.apache.hadoop.ozone.om.snapshot.SnapshotDiffManager

All Implemented Interfaces:

AutoCloseable

public class SnapshotDiffManager
extends Object
implements AutoCloseable

Class to generate snapshot diff.

Constructor Summary

Constructors

Constructor

Description

SnapshotDiffManager(org.apache.hadoop.hdds.utils.db.managed.ManagedRocksDB db, org.apache.ozone.rocksdiff.RocksDBCheckpointDiffer differ, OzoneManager ozoneManager, org.rocksdb.ColumnFamilyHandle snapDiffJobCfh, org.rocksdb.ColumnFamilyHandle snapDiffReportCfh, org.apache.hadoop.hdds.utils.db.managed.ManagedColumnFamilyOptions familyOptions, org.apache.hadoop.hdds.utils.db.CodecRegistry codecRegistry)

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.ozone.snapshot.CancelSnapshotDiffResponse	cancelSnapshotDiff(String volumeName, String bucketName, String fromSnapshotName, String toSnapshotName)
void	close()
protected org.apache.hadoop.ozone.om.helpers.BucketLayout	getBucketLayout(String volume, String bucket, org.apache.hadoop.ozone.om.OMMetadataManager mManager)
PersistentMap<String,org.apache.hadoop.ozone.om.helpers.SnapshotDiffJob>	getSnapDiffJobTable()
org.apache.hadoop.ozone.snapshot.ListSnapshotDiffJobResponse	getSnapshotDiffJobList(String volumeName, String bucketName, String jobStatus, boolean listAllStatus, String prevDiffJob, int maxEntries)
org.apache.hadoop.ozone.snapshot.SnapshotDiffResponse	getSnapshotDiffReport(String volumeName, String bucketName, String fromSnapshotName, String toSnapshotName, int index, int pageSize, boolean forceFullDiff, boolean disableNativeDiff)
static org.apache.hadoop.ozone.OFSPath	getSnapshotRootPath(String volume, String bucket)
protected Set<String>	getSSTFileListForSnapshot(OmSnapshot snapshot, List<String> tablesToLookUp)
protected Map<Object,String>	getSSTFileMapForSnapshot(OmSnapshot snapshot, List<String> tablesToLookUp)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SnapshotDiffManager

public SnapshotDiffManager(org.apache.hadoop.hdds.utils.db.managed.ManagedRocksDB db,
 org.apache.ozone.rocksdiff.RocksDBCheckpointDiffer differ,
 OzoneManager ozoneManager,
 org.rocksdb.ColumnFamilyHandle snapDiffJobCfh,
 org.rocksdb.ColumnFamilyHandle snapDiffReportCfh,
 org.apache.hadoop.hdds.utils.db.managed.ManagedColumnFamilyOptions familyOptions,
 org.apache.hadoop.hdds.utils.db.CodecRegistry codecRegistry)

Method Details

getSnapDiffJobTable

public PersistentMap<String,org.apache.hadoop.ozone.om.helpers.SnapshotDiffJob> getSnapDiffJobTable()

getSSTFileListForSnapshot

protected Set<String> getSSTFileListForSnapshot(OmSnapshot snapshot,
 List<String> tablesToLookUp)

getSSTFileMapForSnapshot

protected Map<Object,String> getSSTFileMapForSnapshot(OmSnapshot snapshot,
 List<String> tablesToLookUp)
                                               throws IOException

Throws:

IOException

cancelSnapshotDiff

public org.apache.hadoop.ozone.snapshot.CancelSnapshotDiffResponse cancelSnapshotDiff(String volumeName,
 String bucketName,
 String fromSnapshotName,
 String toSnapshotName)
                                                                               throws IOException

Throws:

IOException

getSnapshotDiffJobList

public org.apache.hadoop.ozone.snapshot.ListSnapshotDiffJobResponse getSnapshotDiffJobList(String volumeName,
 String bucketName,
 String jobStatus,
 boolean listAllStatus,
 String prevDiffJob,
 int maxEntries)
                                                                                    throws IOException

Throws:

IOException

getSnapshotDiffReport

public org.apache.hadoop.ozone.snapshot.SnapshotDiffResponse getSnapshotDiffReport(String volumeName,
 String bucketName,
 String fromSnapshotName,
 String toSnapshotName,
 int index,
 int pageSize,
 boolean forceFullDiff,
 boolean disableNativeDiff)
                                                                            throws IOException

Throws:

IOException

getSnapshotRootPath

@Nonnull
public static org.apache.hadoop.ozone.OFSPath getSnapshotRootPath(String volume,
 String bucket)

getBucketLayout

protected org.apache.hadoop.ozone.om.helpers.BucketLayout getBucketLayout(String volume,
 String bucket,
 org.apache.hadoop.ozone.om.OMMetadataManager mManager)
                                                                   throws IOException

Throws:

IOException

close

public void close()

Specified by:

close in interface AutoCloseable