com.asakusafw.runtime.directio.hadoop

Class DirectIoTransactionEditor

java.lang.Object

org.apache.hadoop.conf.Configured

com.asakusafw.runtime.directio.hadoop.DirectIoTransactionEditor

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable

public final class DirectIoTransactionEditor
extends org.apache.hadoop.conf.Configured

Edits Direct I/O transactions.

Since:

0.2.5

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DirectIoTransactionEditor.TransactionInfo Represents a tranaction info.

Constructor Summary

Constructors

Constructor and Description
DirectIoTransactionEditor() Creates a new instance.
DirectIoTransactionEditor(DirectDataSourceRepository repository) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
boolean	abort(String executionId) Aborts Direct I/O transaction for an execution.
boolean	apply(String executionId) Applies Direct I/O transaction for an execution.
DirectIoTransactionEditor.TransactionInfo	get(String executionId) Returns the corresponded transaction information to the execution ID.
List<DirectIoTransactionEditor.TransactionInfo>	list() Lists Direct I/O transaction information.

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

DirectIoTransactionEditor

public DirectIoTransactionEditor()

Creates a new instance.

DirectIoTransactionEditor

public DirectIoTransactionEditor(DirectDataSourceRepository repository)

Creates a new instance.

Parameters:

repository - repository, or null if create repository from Configuration

Method Detail

get

public DirectIoTransactionEditor.TransactionInfo get(String executionId)
                                              throws IOException

Returns the corresponded transaction information to the execution ID.

Parameters:

executionId - target ID

Returns:

the corresponded transaction information, or null if does not exist

Throws:

IOException - if failed to obtain information

IllegalArgumentException - if some parameters were null

list

public List<DirectIoTransactionEditor.TransactionInfo> list()
                                                     throws IOException

Lists Direct I/O transaction information.

Returns:

transactions, or an empty list if not exist

Throws:

IOException - if failed to obtain transactions information

IllegalArgumentException - if some parameters were null

apply

public boolean apply(String executionId)
              throws IOException,
                     InterruptedException

Applies Direct I/O transaction for an execution.

Parameters:

executionId - target execution ID

Returns:

true if successfully applied, or false if nothing to do

Throws:

IOException - if failed to apply by I/O error

InterruptedException - if interrupted

IllegalArgumentException - if some parameters were null

abort

public boolean abort(String executionId)
              throws IOException,
                     InterruptedException

Aborts Direct I/O transaction for an execution.

Parameters:

executionId - target execution ID

Returns:

true if successfully aborted, or false if nothing to do

Throws:

IOException - if failed to abort by I/O error

InterruptedException - if interrupted

IllegalArgumentException - if some parameters were null