com.asakusafw.windgate.hadoopfs.ssh

Class FileList.Reader

java.lang.Object

com.asakusafw.windgate.hadoopfs.ssh.FileList.Reader

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

FileList

public static class FileList.Reader
extends Object
implements Closeable

A FileList read protocol.

Since:

0.2.2

Version:

0.7.4

Method Summary

Modifier and Type	Method and Description
void	close()
org.apache.hadoop.fs.FileStatus	getCurrentFile() Deprecated. Use getCurrentPath() instead
org.apache.hadoop.fs.Path	getCurrentPath() Opens the current file path prepared by the next() method.
boolean	next() Returns true iff the next temporary file exists, and then the getCurrentPath() and openContent() method returns it.
InputStream	openContent() Opens the current file content prepared by the next() method.

Methods inherited from class java.lang.Object

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

Method Detail

next

public boolean next()
             throws IOException

Returns true iff the next temporary file exists, and then the getCurrentPath() and openContent() method returns it.

Returns:

true if the next data model object exists, otherwise false

Throws:

IOException - if failed to prepare the next data

getCurrentPath

public org.apache.hadoop.fs.Path getCurrentPath()
                                         throws IOException

Opens the current file path prepared by the next() method.

Returns:

the current temporary file contents

Throws:

IOException - if failed to get status

Since:

0.7.4

getCurrentFile

@Deprecated
public org.apache.hadoop.fs.FileStatus getCurrentFile()
                                                           throws IOException

Deprecated. Use getCurrentPath() instead

Opens the current file status prepared by the next() method.

Returns:

the current temporary file contents

Throws:

IOException - if failed to get status

openContent

public InputStream openContent()
                        throws IOException

Opens the current file content prepared by the next() method. This operation can perform only once for each temporary file.

Returns:

the current temporary file contents

Throws:

IOException - if failed to open the file

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException