com.asakusafw.windgate.hadoopfs.ssh

Class FileListModelInputProvider<T>

java.lang.Object

com.asakusafw.windgate.hadoopfs.ssh.FileListModelInputProvider<T>

Type Parameters:

T - target data model type

All Implemented Interfaces:

ModelInputProvider<T>, Closeable, AutoCloseable

public class FileListModelInputProvider<T>
extends Object
implements ModelInputProvider<T>

An implementation of ModelInputProvider using FileList.

Since:

0.2.5

Version:

0.7.4

Constructor Summary

Constructors

Constructor and Description
FileListModelInputProvider(org.apache.hadoop.conf.Configuration conf, FileList.Reader fileList, Class<T> dataModelClass) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	next() Returns true iff the next temporary file exists, and then the ModelInputProvider.open() method returns it.
ModelInput<T>	open() Opens the current temporary file prepared by the ModelInputProvider.next() method.

Methods inherited from class java.lang.Object

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

Constructor Detail

FileListModelInputProvider

public FileListModelInputProvider(org.apache.hadoop.conf.Configuration conf,
                                  FileList.Reader fileList,
                                  Class<T> dataModelClass)

Creates a new instance.

Parameters:

conf - the configuration

fileList - target file list

dataModelClass - target data model class

Throws:

IllegalArgumentException - if some parameters were null

Method Detail

next

public boolean next()
             throws IOException

Description copied from interface: ModelInputProvider

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

Specified by:

next in interface ModelInputProvider<T>

Returns:

true if the next data model object exists, otherwise false

Throws:

IOException - if failed to prepare the next data

open

public ModelInput<T> open()
                   throws IOException

Description copied from interface: ModelInputProvider

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

Specified by:

open in interface ModelInputProvider<T>

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