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.
|
com.asakusafw.runtime.stage.output |
Classes for stage outputs.
|
Modifier and Type | Method and Description |
---|---|
void |
DirectDataSource.cleanupAttemptOutput(OutputAttemptContext context)
Cleanup output on the attempt.
|
void |
DirectDataSource.commitAttemptOutput(OutputAttemptContext context)
Commits output on the attempt.
|
<T> ModelOutput<T> |
DirectDataSource.openOutput(OutputAttemptContext context,
DataDefinition<T> definition,
String basePath,
String resourcePath,
Counter counter)
Opens a resource for output.
|
void |
DirectDataSource.setupAttemptOutput(OutputAttemptContext context)
Prepares output area for the attempt.
|
Modifier and Type | Method and Description |
---|---|
static OutputAttemptContext |
HadoopDataSourceUtil.createContext(org.apache.hadoop.mapreduce.TaskAttemptContext context,
String datasourceId)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
HadoopDataSourceCore.cleanupAttemptOutput(OutputAttemptContext context) |
void |
HadoopDataSource.cleanupAttemptOutput(OutputAttemptContext context) |
void |
HadoopDataSourceCore.commitAttemptOutput(OutputAttemptContext context) |
void |
HadoopDataSource.commitAttemptOutput(OutputAttemptContext context) |
<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) |
void |
HadoopDataSourceCore.setupAttemptOutput(OutputAttemptContext context) |
void |
HadoopDataSource.setupAttemptOutput(OutputAttemptContext context) |
Modifier and Type | Method and Description |
---|---|
void |
KeepAliveDataSource.cleanupAttemptOutput(OutputAttemptContext context) |
void |
KeepAliveDataSource.commitAttemptOutput(OutputAttemptContext context) |
<T> ModelOutput<T> |
KeepAliveDataSource.openOutput(OutputAttemptContext context,
DataDefinition<T> definition,
String basePath,
String resourcePath,
Counter counter) |
void |
KeepAliveDataSource.setupAttemptOutput(OutputAttemptContext context) |
Modifier and Type | Method and Description |
---|---|
static OutputAttemptContext |
BridgeOutputFormat.createContext(org.apache.hadoop.mapreduce.TaskAttemptContext context,
String datasourceId)
Creates output context from Hadoop context.
|
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.