com.asakusafw.testdriver.directio

Class DirectIoTestHelper

java.lang.Object

com.asakusafw.testdriver.directio.DirectIoTestHelper

public final class DirectIoTestHelper
extends Object

Utilities for this package.

Since:

0.2.5

Version:

0.7.3

Constructor Summary

Constructors

Constructor and Description
DirectIoTestHelper(TestContext context, String rootPath) Creates a new instance.
DirectIoTestHelper(TestContext context, String rootPath, org.apache.hadoop.conf.Configuration configuration) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
<T> ModelInput<T>	openInput(Class<T> dataType, DirectFileOutputDescription description) Opens input for the target output.
<T> ModelOutput<T>	openOutput(Class<T> dataType, DirectFileInputDescription description) Opens output for the target input.
void	truncate() Truncates the current target (deletes all on base path).
void	truncate(String resourcePattern) Truncates the current target.

Methods inherited from class java.lang.Object

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

Constructor Detail

DirectIoTestHelper

public DirectIoTestHelper(TestContext context,
                          String rootPath)
                   throws IOException

Creates a new instance.

Parameters:

context - current test context

rootPath - the bare original base path

Throws:

IOException - if failed to create a new instance

IllegalArgumentException - if some parameters were null

DirectIoTestHelper

public DirectIoTestHelper(TestContext context,
                          String rootPath,
                          org.apache.hadoop.conf.Configuration configuration)
                   throws IOException

Creates a new instance.

Parameters:

context - current test context

rootPath - the bare original base path

configuration - the testing configuration

Throws:

IOException - if failed to create a new instance

IllegalArgumentException - if some parameters were null

Since:

0.7.3

Method Detail

truncate

public void truncate()
              throws IOException

Truncates the current target (deletes all on base path).

Throws:

IOException - if failed to perform by I/O error

truncate

public void truncate(String resourcePattern)
              throws IOException

Truncates the current target.

Parameters:

resourcePattern - the target resource pattern

Throws:

IOException - if failed to perform by I/O error

Since:

0.7.3

openOutput

public <T> ModelOutput<T> openOutput(Class<T> dataType,
                                     DirectFileInputDescription description)
                              throws IOException

Opens output for the target input.

Type Parameters:

T - data type

Parameters:

dataType - data type

description - target description

Returns:

the opened output

Throws:

IOException - if failed to perform by I/O error

IllegalArgumentException - if some parameters were null

openInput

public <T> ModelInput<T> openInput(Class<T> dataType,
                                   DirectFileOutputDescription description)
                            throws IOException

Opens input for the target output.

Type Parameters:

T - data type

Parameters:

dataType - data type

description - target description

Returns:

the opened output

Throws:

IOException - if failed to perform by I/O error

IllegalArgumentException - if some parameters were null