[Hadoop] [API] [翻訳] Class JobHistory.MapAttempt

[Hadoop] [API] [翻訳] Class JobHistory.MapAttemptorg.apache.hadoop.mapred

Class JobHistory.MapAttempt

java.lang.Object
└ org.apache.hadoop.mapred.JobHistory.Task
└ org.apache.hadoop.mapred.JobHistory.TaskAttempt
└ org.apache.hadoop.mapred.JobHistory.MapAttempt

周囲クラス
JobHistory

public static class JobHistory.MapAttempt
extends JobHistory.TaskAttempt
ロギング、またはリーディングバックイベントに関連したジョブの開始や終了、失敗のためのヘルパークラス


コンストラクタ

JobHistory.MapAttempt()

メソッド

String get(JobHistory.Keys k)
指定されたキーの文字列の値を取得

int getInt(JobHistory.Keys k)
ヒストリーから値をint型に変換し返す

long getLong(JobHistory.Keys k)
ヒストリーから値をint型に変換し返す

Map getValues()
マップが格納した全てのキー値を返す

void handle(Map values)
ヒストリから戻したバリューを読み込み、入力はマップがparseHistory()によりリスナーへのパスと同じ

static void logFailed(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error) 
非推奨:代替にlogFailed(TaskAttemptID, long, String, String, String)を使用

static void logFailed(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error, String taskType) 
失敗タスクイベントの記録

static void logFinished(TaskAttemptID taskAttemptId, long finishTime, String hostName) 
非推奨:代替にlogFinished(TaskAttemptID, long, String, String, String, Counters)を使用

static void logFinished(TaskAttemptID taskAttemptId, long finishTime, String hostName, String taskType, String stateString, Counters counter) 
マップタスク終了時間を記録

static void logKilled(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error) 
非推奨:代替にlogKilled(TaskAttemptID, long, String, String, String)を使用

static void logKilled(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error, String taskType) 
強制終了タスクイベントを記録

static void logStarted(TaskAttemptID taskAttemptId, long startTime, String hostName) 
非推奨:代替にlogStarted(TaskAttemptID, long, String, int, String)を使用

static void logStarted(TaskAttemptID taskAttemptId, long startTime, String trackerName, int httpPort, String taskType) 
マップタスク開始時間を記録

void set(JobHistory.Keys k, String s) 
キーの値を設定

void set(Map m) 
マップ引数内の全ての値を独自の値に追加

class org.apache.hadoop.mapred.JobHistory.Task クラスの継承メソッド 
getTaskAttempts, logFailed, logFailed, logFinished, logStarted, logUpdates

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


コンストラクタ詳細

JobHistory.MapAttempt
public JobHistory.MapAttempt()

メソッド詳細

logStarted
public static void logStarted(TaskAttemptID taskAttemptId, long startTime, String hostName)
非推奨:代替にlogStarted(TaskAttemptID, long, String, int, String)を使用
マップタスクの開始時間を記録
Parameters:
taskAttemptId
startTime - タスクトラッカーが報告するタスク開始時間
hostName

logStarted
public static void logStarted(TaskAttemptID taskAttemptId, long startTime, String trackerName, int httpPort, String taskType)
マップタスクの開始時間を記録
Parameters:
taskAttemptId
startTime - タスクトラッカーが報告するタスク開始時間
trackerName - タスクを実行しているトラッカーネーム
httpPort - タスクを実行しているトラッカーのHTTPポート
taskType - クリーンアップ、セットアップ、またはマップを試行するか

logFinished
public static void logFinished(TaskAttemptID taskAttemptId, long finishTime, String hostName)
非推奨:代替にlogFinished(TaskAttemptID, long, String, String, String, Counters)を使用
マップタスクの終了時間を記録
Parameters:
taskAttemptId
finishTime
hostName

logFinished
public static void logFinished(TaskAttemptID taskAttemptId, long finishTime, String hostName, String taskType, String stateString, Counters counter)
マップタスクの終了時間を記録
Parameters:
taskAttemptId
finishTime
hostName
taskType - クリーンアップ、セットアップ、またはマップを試行するか
stateString - タスクの状態文字列
counter - タスクのコンテナ

logFailed
public static void logFailed(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error)
非推奨:代替にlogFailed(TaskAttemptID, long, String, String, String)を使用
失敗タスクイベントの記録
Parameters:
taskAttemptId
timestamp
hostName
error - 存在する場合はエラーメッセージ

logFailed
public static void logFailed(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error, String taskType)
失敗タスクイベントの記録
Parameters:
taskAttemptId
timestamp
hostName
error - 存在する場合はエラーメッセージ
taskType - クリーンアップ、セットアップ、またはマップを試行するか

logKilled
public static void logKilled(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error)
非推奨:代替にlogKilled(TaskAttemptID, long, String, String, String)を使用
強制終了タスクイベントを記録
Parameters:
taskAttemptId
timestamp
hostName
error - 存在する場合はエラーメッセージ

logKilled
public static void logKilled(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error, String taskType)
強制終了タスクイベントを記録
Parameters:
taskAttemptId
timestamp
hostName
error - 存在する場合はエラーメッセージ
taskType - クリーンアップ、セットアップ、またはマップを試行するか

get
public String get(JobHistory.Keys k)
指定されたキーの文字列の値を取得
デフォルトのメソッドでは最も多く使われた文字列の値を返す。このメソッドはGUI上でnullを返さない、もし値が見つからない場合は空の文字列""を返す
Parameters:
k -
Returns:
もし返り値がnullの場合は空文字""を返す

getInt
public int getInt(JobHistory.Keys k)
ヒストリーから値をint型に変換し返す。もし値が見つからない場合は0を返す
Parameters:
k - key

getLong
public long getLong(JobHistory.Keys k)
ヒストリーから値をint型に変換し返す。もし値が見つからない場合は0を返す
Parameters:
k -

set
public void set(JobHistory.Keys k, String s)
キーの値を設定
Parameters:
k -
s -

set
public void set(Map m)
マップ引数内の全ての値を独自の値に追加
Parameters:
m -

handle
public void handle(Map values)
ヒストリから戻したバリューを読み込み、入力はマップがparseHistory()によりリスナーへのパスと同じParameters:
values -

getValues
public Map getValues()
Returns Map containing all key-values.

原文:
Class JobHistory.MapAttempt (Hadoop 0.20.205.0 API)

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

About the author
  • コメントを残す