alluxio.master.file.meta

Class InodeTreeBufferedIterator

java.lang.Object

alluxio.master.file.meta.InodeTreeBufferedIterator

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.util.Iterator<Journal.JournalEntry>

public class InodeTreeBufferedIterator
extends java.lang.Object
implements java.util.Iterator<Journal.JournalEntry>, java.io.Closeable

Used to iterate this InodeTree's state, while doing a read-ahead buffering. Traversal is done concurrently and depth order for each branch is preserved in the final iteration order. This makes applying those entries later more efficient by guaranteeing that a parent of an inode is iterated before it.

Method Summary

Modifier and Type	Method and Description
void	close()
static CloseableIterator<Journal.JournalEntry>	create(InodeStore inodeStore, InodeDirectory rootInode) Creates buffered iterator with closeable interface.
boolean	hasNext()
Journal.JournalEntry	next()
void	remove()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Method Detail

create

public static CloseableIterator<Journal.JournalEntry> create(InodeStore inodeStore,
                                                             InodeDirectory rootInode)

Creates buffered iterator with closeable interface.

Parameters:

inodeStore - the inode store

rootInode - root inode

Returns:

the buffered iterator

hasNext

public boolean hasNext()

Specified by:

hasNext in interface java.util.Iterator<Journal.JournalEntry>

next

public Journal.JournalEntry next()

Specified by:

next in interface java.util.Iterator<Journal.JournalEntry>

remove

public void remove()

Specified by:

remove in interface java.util.Iterator<Journal.JournalEntry>

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable