@NotThreadSafe public final class UfsSyncChecker extends Object
Constructor and Description |
---|
UfsSyncChecker(MountTable mountTable,
ReadOnlyInodeStore inodeStore)
Create a new instance of
UfsSyncChecker . |
Modifier and Type | Method and Description |
---|---|
void |
checkDirectory(InodeDirectory inode,
AlluxioURI alluxioUri)
Check if immediate children of directory are in sync with UFS.
|
boolean |
isDirectoryInSync(AlluxioURI alluxioUri)
Based on directories for which
checkDirectory(InodeDirectory, AlluxioURI) was called, this
method returns whether any un-synced entries were found. |
public UfsSyncChecker(MountTable mountTable, ReadOnlyInodeStore inodeStore)
UfsSyncChecker
.mountTable
- to resolve path in under storageinodeStore
- to look up inode childrenpublic void checkDirectory(InodeDirectory inode, AlluxioURI alluxioUri) throws FileDoesNotExistException, InvalidPathException, IOException
inode
- read-locked directory to checkalluxioUri
- path of directory to to checkFileDoesNotExistException
InvalidPathException
IOException
public boolean isDirectoryInSync(AlluxioURI alluxioUri)
checkDirectory(InodeDirectory, AlluxioURI)
was called, this
method returns whether any un-synced entries were found.alluxioUri
- path of directory to checkCopyright © 2023. All Rights Reserved.