com.asakusafw.runtime.io.sequencefile

Class SequenceFileModelInput<T extends org.apache.hadoop.io.Writable>

java.lang.Object

com.asakusafw.runtime.io.sequencefile.SequenceFileModelInput<T>

Type Parameters:

T - value type

All Implemented Interfaces:

ModelInput<T>, Closeable, AutoCloseable

public class SequenceFileModelInput<T extends org.apache.hadoop.io.Writable>
extends Object
implements ModelInput<T>

A bridge implementation to SequenceFile into ModelInput. The key type of sequence file must be NullWritable.

Since:

0.2.5

Constructor Summary

Constructors

Constructor and Description
SequenceFileModelInput(org.apache.hadoop.io.SequenceFile.Reader reader) Creates a new instance.
SequenceFileModelInput(org.apache.hadoop.io.SequenceFile.Reader reader, Closeable closeable) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	readTo(T model) Reads contents and write them into the target data model object.

Methods inherited from class java.lang.Object

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

Constructor Detail

SequenceFileModelInput

public SequenceFileModelInput(org.apache.hadoop.io.SequenceFile.Reader reader)

Creates a new instance.

Parameters:

reader - target reader

Throws:

IllegalArgumentException - if some parameters were null

SequenceFileModelInput

public SequenceFileModelInput(org.apache.hadoop.io.SequenceFile.Reader reader,
                              Closeable closeable)

Creates a new instance.

Parameters:

reader - target reader

closeable - chained close target (nullable)

Throws:

IllegalArgumentException - if some parameters were null

Method Detail

readTo

public boolean readTo(T model)
               throws IOException

Description copied from interface: ModelInput

Reads contents and write them into the target data model object. The target data model object will be changed even if the next data does not exist.

Specified by:

readTo in interface ModelInput<T extends org.apache.hadoop.io.Writable>

Parameters:

model - the target data model object

Returns:

true if the next data was successfully read, or false if there is no any more

Throws:

IOException - if error occurred while reading the next data

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException