alluxio.master.file.meta

Class UfsSyncPathCache

java.lang.Object

alluxio.master.file.meta.UfsSyncPathCache

@ThreadSafe
public final class UfsSyncPathCache
extends java.lang.Object

This cache maintains the Alluxio paths which have been synced with UFS.

Constructor Summary

Constructors

Constructor and Description
UfsSyncPathCache() Creates a new instance of UfsSyncPathCache.

Method Summary

Modifier and Type	Method and Description
void	notifySyncedPath(java.lang.String path, DescendantType descendantType) Notifies the cache that the path was synced.
boolean	shouldSyncPath(java.lang.String path, long intervalMs, boolean isGetFileInfo) The logic of shouldSyncPath need to consider the difference between file and directory, with the variable isGetFileInfo we just process getFileInfo specially.

Methods inherited from class java.lang.Object

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

Constructor Detail

UfsSyncPathCache

public UfsSyncPathCache()

Creates a new instance of UfsSyncPathCache.

Method Detail

notifySyncedPath

public void notifySyncedPath(java.lang.String path,
                             DescendantType descendantType)

Notifies the cache that the path was synced.

Parameters:

path - the path that was synced

descendantType - the descendant type that the path was synced with

shouldSyncPath

public boolean shouldSyncPath(java.lang.String path,
                              long intervalMs,
                              boolean isGetFileInfo)

The logic of shouldSyncPath need to consider the difference between file and directory, with the variable isGetFileInfo we just process getFileInfo specially. There are three cases needed to address: 1. the ancestor directories 2. the direct parent directory 3. the difference with file and directory

Parameters:

path - the path to check

intervalMs - the sync interval, in ms

isGetFileInfo - the operate is from getFileInfo or not

Returns:

true if a sync should occur for the path and interval setting, false otherwise