com.asakusafw.runtime.stage.temporary

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

java.lang.Object

com.asakusafw.runtime.stage.temporary.TemporaryFileInput<T>

Type Parameters:

T - the data model type

All Implemented Interfaces:

ModelInput<T>, Closeable, AutoCloseable

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

Input raw data.

Since:

0.7.0

Constructor Summary

Constructors

Constructor and Description
TemporaryFileInput(InputStream input, int blocks) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	close()
int	getCurrentBlock() Returns the current block number (0..).
String	getDataTypeName() Returns the target data type name.
int	getPositionInBlock() Returns the byte position in current block.
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

TemporaryFileInput

public TemporaryFileInput(InputStream input,
                          int blocks)

Creates a new instance.

Parameters:

input - the input stream (must be on the head of a block)

blocks - the number of blocks to read, or 0 to read all pages in the stream

Method Detail

getDataTypeName

public String getDataTypeName()
                       throws IOException

Returns the target data type name.

Returns:

the data type name

Throws:

IOException - if failed to extract the data type name

getCurrentBlock

public int getCurrentBlock()

Returns the current block number (0..).

Returns:

the current block number

getPositionInBlock

public int getPositionInBlock()

Returns the byte position in current block.

Returns:

the position in block

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