| Package | Description |
|---|---|
| com.asakusafw.runtime.directio |
Direct I/O access from Asakusa Framework.
|
| com.asakusafw.runtime.directio.hadoop |
Direct I/O access for Hadoop Environment.
|
| com.asakusafw.runtime.directio.keepalive |
Keep-alive utilities for Direct I/O access.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SimpleDataDefinition<T>
A simple implementation of
DataDefinition. |
| Modifier and Type | Method and Description |
|---|---|
static <T> DataDefinition<T> |
SimpleDataDefinition.newInstance(Class<?> dataClass,
DataFormat<T> dataFormat)
Creates a new instance.
|
static <T> DataDefinition<T> |
SimpleDataDefinition.newInstance(Class<?> dataClass,
DataFormat<T> dataFormat,
DataFilter<?> dataFilter)
Creates a new instance.
|
| Modifier and Type | Method and Description |
|---|---|
<T> List<DirectInputFragment> |
DirectDataSource.findInputFragments(DataDefinition<T> definition,
String basePath,
ResourcePattern resourcePattern)
Collects input fragments about target resources.
|
<T> ModelInput<T> |
DirectDataSource.openInput(DataDefinition<T> definition,
DirectInputFragment fragment,
Counter counter)
Opens a fragment for input.
|
<T> ModelOutput<T> |
DirectDataSource.openOutput(OutputAttemptContext context,
DataDefinition<T> definition,
String basePath,
String resourcePath,
Counter counter)
Opens a resource for output.
|
| Modifier and Type | Method and Description |
|---|---|
<T> List<DirectInputFragment> |
HadoopDataSourceCore.findInputFragments(DataDefinition<T> definition,
String basePath,
ResourcePattern resourcePattern) |
<T> List<DirectInputFragment> |
HadoopDataSource.findInputFragments(DataDefinition<T> definition,
String basePath,
ResourcePattern resourcePattern) |
<T> ModelInput<T> |
HadoopDataSourceCore.openInput(DataDefinition<T> definition,
DirectInputFragment fragment,
Counter counter) |
<T> ModelInput<T> |
HadoopDataSource.openInput(DataDefinition<T> definition,
DirectInputFragment fragment,
Counter counter) |
<T> ModelOutput<T> |
HadoopDataSourceCore.openOutput(OutputAttemptContext context,
DataDefinition<T> definition,
String basePath,
String resourcePath,
Counter counter) |
<T> ModelOutput<T> |
HadoopDataSource.openOutput(OutputAttemptContext context,
DataDefinition<T> definition,
String basePath,
String resourcePath,
Counter counter) |
| Modifier and Type | Method and Description |
|---|---|
<T> List<DirectInputFragment> |
KeepAliveDataSource.findInputFragments(DataDefinition<T> definition,
String basePath,
ResourcePattern resourcePattern) |
<T> ModelInput<T> |
KeepAliveDataSource.openInput(DataDefinition<T> definition,
DirectInputFragment fragment,
Counter counter) |
<T> ModelOutput<T> |
KeepAliveDataSource.openOutput(OutputAttemptContext context,
DataDefinition<T> definition,
String basePath,
String resourcePath,
Counter counter) |
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.