alluxio.master.file.meta

Class AsyncUfsAbsentPathCache

java.lang.Object

alluxio.master.file.meta.AsyncUfsAbsentPathCache

All Implemented Interfaces:

UfsAbsentPathCache

@ThreadSafe
public class AsyncUfsAbsentPathCache
extends Object
implements UfsAbsentPathCache

This is a UfsAbsentPathCache which implements asynchronous addition and removal to the cache, since the processing of the path may be slow.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.master.file.meta.UfsAbsentPathCache

UfsAbsentPathCache.Factory

Field Summary

Fields inherited from interface alluxio.master.file.meta.UfsAbsentPathCache

ALWAYS, NEVER

Constructor Summary

Constructors

Constructor and Description
AsyncUfsAbsentPathCache(MountTable mountTable, int numThreads, java.time.Clock clock) Creates a new instance of AsyncUfsAbsentPathCache.

Method Summary

Modifier and Type	Method and Description
void	addSinglePath(AlluxioURI path) Add a single path to the absent cache synchronously.
protected long	getCachedGaugeTimeoutMillis()
boolean	isAbsentSince(AlluxioURI path, long absentSince) Returns true if the given path was found to be absent since absentSince, according to this cache.
void	processAsync(AlluxioURI path, List<Inode> prefixInodes) Processes the given path for the cache.
void	processExisting(AlluxioURI path) Processes the given path that already exists.

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncUfsAbsentPathCache

public AsyncUfsAbsentPathCache(MountTable mountTable,
                               int numThreads,
                               java.time.Clock clock)

Creates a new instance of AsyncUfsAbsentPathCache.

Parameters:

mountTable - the mount table

numThreads - the maximum number of threads for the async thread pool

clock - the clock to use to compute the sync times

Method Detail

getCachedGaugeTimeoutMillis

protected long getCachedGaugeTimeoutMillis()

processAsync

public void processAsync(AlluxioURI path,
                         List<Inode> prefixInodes)

Description copied from interface: UfsAbsentPathCache

Processes the given path for the cache. This will asynchronously and sequentially walk down the path to find components which do and do not exist in the UFS, and updates the cache accordingly.

Specified by:

processAsync in interface UfsAbsentPathCache

Parameters:

path - the path to process for the cache

prefixInodes - the existing inodes for the path prefix

addSinglePath

public void addSinglePath(AlluxioURI path)

Description copied from interface: UfsAbsentPathCache

Add a single path to the absent cache synchronously.

Specified by:

addSinglePath in interface UfsAbsentPathCache

Parameters:

path - the path to process for the cache

processExisting

public void processExisting(AlluxioURI path)

Description copied from interface: UfsAbsentPathCache

Processes the given path that already exists. This will sequentially walk down the path and update the cache accordingly.

Specified by:

processExisting in interface UfsAbsentPathCache

Parameters:

path - the path to process for the cache

isAbsentSince

public boolean isAbsentSince(AlluxioURI path,
                             long absentSince)

Description copied from interface: UfsAbsentPathCache

Returns true if the given path was found to be absent since absentSince, according to this cache. A path is absent if one of its ancestors is absent.

Specified by:

isAbsentSince in interface UfsAbsentPathCache

Parameters:

path - the path to check

absentSince - the time when the cache entry would be considered valid

Returns:

true if the path is absent according to the cache