com.asakusafw.windgate.hadoopfs.temporary

Class ModelInputSourceDriver<T>

java.lang.Object

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

Type Parameters:

T - the value type

All Implemented Interfaces:

SourceDriver<T>, Preparable, Closeable, AutoCloseable

public class ModelInputSourceDriver<T>
extends Object
implements SourceDriver<T>

An implementation of SourceDriver using ModelInputProvider.

Since:

0.2.5

Constructor Summary

Constructors

Constructor and Description
ModelInputSourceDriver(ModelInputProvider<T> provider, T value) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	close() Disposes this object.
T	get() Gets the current data model object prepared by the SourceDriver.next() method.
boolean	next() Returns true iff the next data model object exists, and then the SourceDriver.get() method returns its object.
void	prepare() Prepares this driver to invoke SourceDriver.next() method.

Methods inherited from class java.lang.Object

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

Constructor Detail

ModelInputSourceDriver

public ModelInputSourceDriver(ModelInputProvider<T> provider,
                              T value)

Creates a new instance.

Parameters:

provider - the source model inputs

value - the value object used for buffer

Throws:

IllegalArgumentException - if any parameter is null

Method Detail

prepare

public void prepare()

Description copied from interface: SourceDriver

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

Specified by:

prepare in interface SourceDriver<T>

Specified by:

prepare in interface Preparable

next

public boolean next()
             throws IOException

Description copied from interface: SourceDriver

Returns true iff the next data model object exists, and then the SourceDriver.get() method returns its object. This operation can execute only on the same thread as created this object.

Specified by:

next in interface SourceDriver<T>

Returns:

true if the next data model object exists, otherwise false

Throws:

IOException - if failed to prepare the next data

get

public T get()
      throws IOException

Description copied from interface: SourceDriver

Gets the current data model object prepared by the SourceDriver.next() method. This operation can execute only on the same thread as created this object.

Specified by:

get in interface SourceDriver<T>

Returns:

the next data model object

Throws:

IOException - if failed to prepare the next data

See Also:

SourceDriver.next()

close

public void close()
           throws IOException

Description copied from interface: SourceDriver

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

Specified by:

close in interface SourceDriver<T>

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException - if failed to connect