com.asakusafw.windgate.hadoopfs.temporary

Class ModelOutputDrainDriver<T>

java.lang.Object

com.asakusafw.windgate.hadoopfs.temporary.ModelOutputDrainDriver<T>

Type Parameters:

T - the data model type

All Implemented Interfaces:

DrainDriver<T>, Preparable, Closeable, AutoCloseable

public class ModelOutputDrainDriver<T>
extends Object
implements DrainDriver<T>

An implementation of DrainDriver using ModelOutput.

Since:

0.2.5

Constructor Summary

Constructors

Constructor and Description
ModelOutputDrainDriver(ModelOutput<T> output) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	close() Disposes this object.
void	prepare() Prepares this driver to invoke DrainDriver.put(Object) method.
void	put(T object) Puts each data model object into the connected resource.

Methods inherited from class java.lang.Object

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

Constructor Detail

ModelOutputDrainDriver

public ModelOutputDrainDriver(ModelOutput<T> output)

Creates a new instance.

Parameters:

output - target output

Throws:

IllegalArgumentException - if some parameters were null

Method Detail

prepare

public void prepare()
             throws IOException

Description copied from interface: DrainDriver

Prepares this driver to invoke DrainDriver.put(Object) method. This method will be invoked before DrainDriver.put(Object) only once. This operation can execute only on the same thread as created this object.

Specified by:

prepare in interface DrainDriver<T>

Specified by:

prepare in interface Preparable

Throws:

IOException - if failed to begin

put

public void put(T object)
         throws IOException

Description copied from interface: DrainDriver

Puts each data model object into the connected resource. This operation can execute only on the same thread as created this object.

Specified by:

put in interface DrainDriver<T>

Parameters:

object - the data model object to be put

Throws:

IOException - if failed to put data

close

public void close()
           throws IOException

Description copied from interface: DrainDriver

Disposes this object. This operation can execute only on the same thread as created this object.

Specified by:

close in interface DrainDriver<T>

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException - if failed to connect