[Hadoop] [API] [翻訳] Class FileOutputCommitter

[Hadoop] [API] [翻訳] Class FileOutputCommitterorg.apache.hadoop.mapred

Class FileOutputCommitter

java.lang.Object
└ org.apache.hadoop.mapreduce.OutputCommitter
    └ org.apache.hadoop.mapred.OutputCommitter
        └ org.apache.hadoop.mapred.FileOutputCommitter

public class FileOutputCommitter
extends OutputCommitter

OutputCommitterは出力ディレクトリを指定されたファイルをコミットする
例 ${mapred.output.dir}.


フィールド

static org.apache.commons.logging.Log LOG
static String SUCCEEDED_FILE_NAME
static String TEMP_DIR_NAME
テンポラリーディレクトリネーム

コンストラクタ

FileOutputCommitter()


メソッド

void abortJob(JobContext context, int runState)
すべてのワークディレクトリが含まれたテンポラリーディレクトリを削除

void abortTask(TaskAttemptContext context)
タスクの出力を破棄する

void cleanupJob(JobContext context)
非推奨

void commitJob(JobContext context)
ジョブの完了後にコミット

void commitTask(TaskAttemptContext context)
タスクの仮出力をジョブの最終出力ディレクトリに移動

boolean needsTaskCommit(TaskAttemptContext context)
タスクがコミットを必要とするかチェックする

void setupJob(JobContext context)
初期化中にフレームワークのためにジョブをセットアップ

void setupTask(TaskAttemptContext context)
タスクのアウトプットをセットアップ

org.apache.hadoop.mapred.OutputCommitterクラスの継承メソッド
abortJob, abortTask, cleanupJob, commitJob, commitTask, needsTaskCommit, setupJob, setupTask

java.lang.Objectクラスの継承メソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait


フィールド詳細

LOG
public static final org.apache.commons.logging.Log LOG

TEMP_DIR_NAME
public static final String TEMP_DIR_NAME
テンポラリーディレクトリネーム
See Also:
Constant Field Values

SUCCEEDED_FILE_NAME
public static final String SUCCEEDED_FILE_NAME
See Also:
Constant Field Values
Constructor Detail
FileOutputCommitter

コンストラクタ詳細

public FileOutputCommitter()


メソッド詳細

setupJob
publicvoid setupJob(JobContext context) throws IOException
Description copied from class: OutputCommitter
初期化中にフレームワークのためにジョブをセットアップ
Specified by:
setupJob in class OutputCommitter
Parameters:
ジョブの出力コンテキスト
Throws:
IOException - if temporary output could not be created

commitJob
publicvoid commitJob(JobContext context) throws IOException
Description copied from class: OutputCommitter
ジョブの完了後にコミット
Overrides:
commitJob in class OutputCommitter
Parameters:
ジョブの出力コンテキスト
Throws:
IOException

cleanupJob
publicvoid cleanupJob(JobContext context) throws IOException
非推奨
Description copied from class: OutputCommitter
ジョブの完了後にクリーンアップ
Overrides:
cleanupJob in class OutputCommitter
Throws:
IOException

abortJob
publicvoid abortJob(JobContext context, int runState) throws IOException
すべてのワークディレクトリが含まれたテンポラリーディレクトリを削除
Overrides:
abortJob in class OutputCommitter
Parameters:
ジョブの出力コンテキスト
runState - final run state of the job, should be JobStatus.KILLED or JobStatus.FAILED
Throws:
IOException

setupTask
publicvoid setupTask(TaskAttemptContext context) throws IOException
Description copied from class: OutputCommitter
タスクのアウトプットをセットアップ
Specified by:
setupTask in class OutputCommitter
Parameters:
ジョブの出力コンテキスト
Throws:
IOException

commitTask
publicvoid commitTask(TaskAttemptContext context) throws IOException
Description copied from class: OutputCommitter
タスクの仮出力をジョブの最終出力ディレクトリに移動
Specified by:
commitTask in class OutputCommitter
Parameters:
ジョブの出力コンテキスト
Throws:
IOException - if commit is not

abortTask
publicvoid abortTask(TaskAttemptContext context) throws IOException
Description copied from class: OutputCommitter
タスクの出力を破棄する
Specified by:
abortTask in class OutputCommitter
Throws:
IOException

needsTaskCommit
public boolean needsTaskCommit(TaskAttemptContext context) throws IOException
Description copied from class: OutputCommitter
タスクがコミットを必要とするかチェックする
Specified by:
needsTaskCommit in class OutputCommitter
Returns:
true/false
Throws:
IOException

原文:
Class FileOutputCommitter (Hadoop 0.20.205.0 API)

不備や気づいた点ありましたらコメントいただけると助かります。

About the author
  • コメントを残す