com.asakusafw.runtime.directio.api

Class DirectIoDelegate

java.lang.Object

org.apache.hadoop.conf.Configured

com.asakusafw.runtime.directio.api.DirectIoDelegate

All Implemented Interfaces:

DirectIoApi, org.apache.hadoop.conf.Configurable

public class DirectIoDelegate
extends org.apache.hadoop.conf.Configured
implements DirectIoApi

Delegating object for DirectIo.

Since:

0.7.3

Version:

0.9.0

Constructor Summary

Constructors

Constructor and Description
DirectIoDelegate(org.apache.hadoop.conf.Configuration configuration) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
<T> ModelInput<T>	open(Class<? extends DataFormat<T>> formatClass, String basePath, String resourcePattern) Returns data model objects from Direct I/O data sources.

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

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

Constructor Detail

DirectIoDelegate

public DirectIoDelegate(org.apache.hadoop.conf.Configuration configuration)

Creates a new instance.

Parameters:

configuration - the current configuration

Method Detail

open

public <T> ModelInput<T> open(Class<? extends DataFormat<T>> formatClass,
                              String basePath,
                              String resourcePattern)
                       throws IOException

Description copied from interface: DirectIoApi

Returns data model objects from Direct I/O data sources.

Specified by:

open in interface DirectIoApi

Type Parameters:

T - the data model object type

Parameters:

formatClass - the Direct I/O data format class

basePath - the base path (must not contain variables)

resourcePattern - the resource pattern (must not contain variables)

Returns:

the data model objects

Throws:

IOException - if failed to open data model objects on the data source