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 |
---|---|
OutputTransactionContext |
OutputAttemptContext.getTransactionContext()
Returns the corresponded transaction context.
|
Modifier and Type | Method and Description |
---|---|
void |
DirectDataSource.cleanupTransactionOutput(OutputTransactionContext context)
Cleanup output on the transaction.
|
void |
DirectDataSource.commitTransactionOutput(OutputTransactionContext context)
Commits output on the transaction.
|
void |
DirectDataSource.setupTransactionOutput(OutputTransactionContext context)
Prepares output area for the transaction.
|
Modifier and Type | Method and Description |
---|---|
static OutputTransactionContext |
HadoopDataSourceUtil.createContext(org.apache.hadoop.mapreduce.JobContext context,
String datasourceId)
Deprecated.
|
static OutputTransactionContext |
HadoopDataSourceUtil.createContext(String executionId,
String datasourceId)
Creates output context from execution ID and datasource ID.
|
Modifier and Type | Method and Description |
---|---|
void |
HadoopDataSourceCore.cleanupTransactionOutput(OutputTransactionContext context) |
void |
HadoopDataSource.cleanupTransactionOutput(OutputTransactionContext context) |
void |
HadoopDataSourceCore.commitTransactionOutput(OutputTransactionContext context) |
void |
HadoopDataSource.commitTransactionOutput(OutputTransactionContext context) |
void |
HadoopDataSourceCore.setupTransactionOutput(OutputTransactionContext context) |
void |
HadoopDataSource.setupTransactionOutput(OutputTransactionContext context) |
Modifier and Type | Method and Description |
---|---|
void |
KeepAliveDataSource.cleanupTransactionOutput(OutputTransactionContext context) |
void |
KeepAliveDataSource.commitTransactionOutput(OutputTransactionContext context) |
void |
KeepAliveDataSource.setupTransactionOutput(OutputTransactionContext context) |
Modifier and Type | Method and Description |
---|---|
static OutputTransactionContext |
BridgeOutputFormat.createContext(org.apache.hadoop.mapreduce.JobContext context,
String datasourceId)
Creates output context from Hadoop context.
|
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.