alluxio.master.metastore

Class DelegatingReadOnlyInodeStore

java.lang.Object

alluxio.master.metastore.DelegatingReadOnlyInodeStore

All Implemented Interfaces:

ReadOnlyInodeStore, Closeable, AutoCloseable

public class DelegatingReadOnlyInodeStore
extends Object
implements ReadOnlyInodeStore

Wrapper for providing read-only access to an inode store.

Constructor Summary

Constructors

Constructor and Description
DelegatingReadOnlyInodeStore(InodeStore delegate)

Method Summary

Modifier and Type	Method and Description
Set<EdgeEntry>	allEdges()
Set<MutableInode<?>>	allInodes()
void	close()
Optional<Inode>	get(long id, ReadOption option)
Optional<Inode>	getChild(InodeDirectoryView inode, String name, ReadOption option)
Optional<Inode>	getChild(Long inodeId, String name, ReadOption option)
Optional<Long>	getChildId(InodeDirectoryView inode, String name, ReadOption option)
Optional<Long>	getChildId(Long inodeId, String name, ReadOption option)
Iterable<Long>	getChildIds(InodeDirectoryView inode, ReadOption option) Returns an iterable for the ids of the children of the given directory.
Iterable<Long>	getChildIds(Long inodeId, ReadOption option) Returns an iterable for the ids of the children of the given directory.
Iterable<? extends Inode>	getChildren(InodeDirectoryView inode, ReadOption option)
Iterable<? extends Inode>	getChildren(Long inodeId, ReadOption option) Returns an iterator over the children of the specified inode.
boolean	hasChildren(InodeDirectoryView inode, ReadOption option)

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.master.metastore.ReadOnlyInodeStore

get, getChild, getChild, getChildId, getChildId, getChildIds, getChildIds, getChildren, getChildren, hasChildren

Constructor Detail

DelegatingReadOnlyInodeStore

public DelegatingReadOnlyInodeStore(InodeStore delegate)

Parameters:

delegate - the delegate inode store

Method Detail

get

public Optional<Inode> get(long id,
                           ReadOption option)

Specified by:

get in interface ReadOnlyInodeStore

Parameters:

id - an inode id

option - the options

Returns:

the inode with the given id, if it exists

getChildIds

public Iterable<Long> getChildIds(Long inodeId,
                                  ReadOption option)

Description copied from interface: ReadOnlyInodeStore

Returns an iterable for the ids of the children of the given directory.

Specified by:

getChildIds in interface ReadOnlyInodeStore

Parameters:

inodeId - an inode id to list child ids for

option - the options

Returns:

the child ids iterable

getChildIds

public Iterable<Long> getChildIds(InodeDirectoryView inode,
                                  ReadOption option)

Description copied from interface: ReadOnlyInodeStore

Returns an iterable for the ids of the children of the given directory.

Specified by:

getChildIds in interface ReadOnlyInodeStore

Parameters:

inode - the inode to list child ids for

option - the options

Returns:

the child ids iterable

getChildren

public Iterable<? extends Inode> getChildren(Long inodeId,
                                             ReadOption option)

Description copied from interface: ReadOnlyInodeStore

Returns an iterator over the children of the specified inode. The iterator is weakly consistent. It can operate in the presence of concurrent modification, but it is undefined whether concurrently removed inodes will be excluded or whether concurrently added inodes will be included.

Specified by:

getChildren in interface ReadOnlyInodeStore

Parameters:

inodeId - an inode id

option - the options

Returns:

an iterable over the children of the inode with the given id

getChildren

public Iterable<? extends Inode> getChildren(InodeDirectoryView inode,
                                             ReadOption option)

Specified by:

getChildren in interface ReadOnlyInodeStore

Parameters:

inode - an inode directory

option - the options

Returns:

an iterable over the children of the inode with the given id

getChildId

public Optional<Long> getChildId(Long inodeId,
                                 String name,
                                 ReadOption option)

Specified by:

getChildId in interface ReadOnlyInodeStore

Parameters:

inodeId - an inode id

name - an inode name

option - the options

Returns:

the id of the child of the inode with the given name

getChildId

public Optional<Long> getChildId(InodeDirectoryView inode,
                                 String name,
                                 ReadOption option)

Specified by:

getChildId in interface ReadOnlyInodeStore

Parameters:

inode - an inode directory

name - an inode name

option - the options

Returns:

the id of the child of the inode with the given name

getChild

public Optional<Inode> getChild(Long inodeId,
                                String name,
                                ReadOption option)

Specified by:

getChild in interface ReadOnlyInodeStore

Parameters:

inodeId - an inode id

name - an inode name

option - the options

Returns:

the child of the inode with the given name

getChild

public Optional<Inode> getChild(InodeDirectoryView inode,
                                String name,
                                ReadOption option)

Specified by:

getChild in interface ReadOnlyInodeStore

Parameters:

inode - an inode directory

name - an inode name

option - the options

Returns:

the child of the inode with the given name

hasChildren

public boolean hasChildren(InodeDirectoryView inode,
                           ReadOption option)

Specified by:

hasChildren in interface ReadOnlyInodeStore

Parameters:

inode - an inode directory

option - the options

Returns:

whether the inode has any children

allEdges

public Set<EdgeEntry> allEdges()

Specified by:

allEdges in interface ReadOnlyInodeStore

Returns:

all edges in the inode store

allInodes

public Set<MutableInode<?>> allInodes()

Specified by:

allInodes in interface ReadOnlyInodeStore

Returns:

all inodes in the inode store

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException