alluxio.master.file.meta

Class AsyncUfsAbsentPathCache

java.lang.Object

alluxio.master.file.meta.AsyncUfsAbsentPathCache

All Implemented Interfaces:

UfsAbsentPathCache

@ThreadSafe
public final 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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
boolean	isAbsent(AlluxioURI path) Returns true if the given path is absent, according to this cache.
void	process(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)

Creates a new instance of AsyncUfsAbsentPathCache.

Parameters:

mountTable - the mount table

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

Method Detail

process

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

Description copied from interface: UfsAbsentPathCache

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

Specified by:

process in interface UfsAbsentPathCache

Parameters:

path - the path to process for the cache

prefixInodes - the existing inodes for the path prefix

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

isAbsent

public boolean isAbsent(AlluxioURI path)

Description copied from interface: UfsAbsentPathCache

Returns true if the given path is absent, according to this cache. A path is absent if one of its ancestors is absent.

Specified by:

isAbsent in interface UfsAbsentPathCache

Parameters:

path - the path to check

Returns:

true if the path is absent according to the cache