io.druid.indexer.hadoop

Class FSSpideringIterator

java.lang.Object

io.druid.indexer.hadoop.FSSpideringIterator

All Implemented Interfaces:

Iterator<org.apache.hadoop.fs.FileStatus>

public class FSSpideringIterator
extends Object
implements Iterator<org.apache.hadoop.fs.FileStatus>

Constructor Summary

Constructors

Constructor and Description
FSSpideringIterator(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.FileStatus[] statii)

Method Summary

Modifier and Type	Method and Description
boolean	hasNext()
org.apache.hadoop.fs.FileStatus	next()
void	remove()
static Iterable<org.apache.hadoop.fs.FileStatus>	spiderIterable(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path)
static FSSpideringIterator	spiderPathPropagateExceptions(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path)

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

Constructor Detail

FSSpideringIterator

public FSSpideringIterator(org.apache.hadoop.fs.FileSystem fs,
                           org.apache.hadoop.fs.FileStatus[] statii)

Method Detail

spiderPathPropagateExceptions

public static FSSpideringIterator spiderPathPropagateExceptions(org.apache.hadoop.fs.FileSystem fs,
                                                                org.apache.hadoop.fs.Path path)

spiderIterable

public static Iterable<org.apache.hadoop.fs.FileStatus> spiderIterable(org.apache.hadoop.fs.FileSystem fs,
                                                                       org.apache.hadoop.fs.Path path)

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<org.apache.hadoop.fs.FileStatus>

next

public org.apache.hadoop.fs.FileStatus next()

Specified by:

next in interface Iterator<org.apache.hadoop.fs.FileStatus>

remove

public void remove()

Specified by:

remove in interface Iterator<org.apache.hadoop.fs.FileStatus>