com.asakusafw.runtime.directio

Class AbstractDirectDataSource

java.lang.Object

com.asakusafw.runtime.directio.AbstractDirectDataSource

All Implemented Interfaces:

DirectDataSource

Direct Known Subclasses:

HadoopDataSource

public abstract class AbstractDirectDataSource
extends Object
implements DirectDataSource

An abstract implementation of DirectDataSourceRepository.

Since:

0.2.5

Constructor Summary

Constructors

Constructor and Description
AbstractDirectDataSource()

Method Summary

Modifier and Type	Method and Description
abstract void	configure(DirectDataSourceProfile profile) Configures this data source.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.asakusafw.runtime.directio.DirectDataSource

cleanupAttemptOutput, cleanupTransactionOutput, commitAttemptOutput, commitTransactionOutput, delete, findInputFragments, findProperty, list, openInput, openOutput, path, path, setupAttemptOutput, setupTransactionOutput

Constructor Detail

AbstractDirectDataSource

public AbstractDirectDataSource()

Method Detail

configure

public abstract void configure(DirectDataSourceProfile profile)
                        throws IOException,
                               InterruptedException

Configures this data source.

Parameters:

profile - profile object

Throws:

IOException - if failed to configure this object

InterruptedException - if interrupted