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

Methods

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	spiderPathPropogateExceptions(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

Constructor Detail

FSSpideringIterator

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

Method Detail

spiderPathPropogateExceptions

public static FSSpideringIterator spiderPathPropogateExceptions(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>