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

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

Class JobHistory.Task

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

直系のサブクラス
JobHistory.TaskAttempt

周囲クラス
JobHistory

public static class JobHistory.Task
extends Object
ロギング、またはノード上のマップの開始や終了、失敗に関連したイベントをリードバックのためのヘルパークラス。全てのイベントは、このクラスでジョブトラッカーヒストリーのジョブ毎に分割したファイルを記録する


コンストラクタ

JobHistory.Task()

メソッド

Stringget(JobHistory.Keys k)
与えられたキーから文字列を取得

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

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

MapgetTaskAttempts() このタスクの全ての試行タスクを返す

MapgetValues() マップに格納している全てのキー値を返す

voidhandle(Map values) ヒストリーから読み込み値を返す、入力はparseHistory()によって同じマップをListenerに引き渡す

static voidlogFailed(TaskID taskId, String taskType, long time, String error) 
失敗したイベントのジョブを記録

static voidlogFailed(TaskID taskId, String taskType, long time, String error, TaskAttemptID failedDueToAttempt) 

static voidlogFinished(TaskID taskId, String taskType, long finishTime, Counters counters) 

タスクの終了時間を記録

static voidlogStarted(TaskID taskId, String taskType, long startTime, String splitLocations) 
タスクの開始時間を記録

static voidlogUpdates(TaskID taskId, long finishTime) 
タスクの終了時間を更新

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

voidset(Map m) 
マップの引数内の全ての値を追加する

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


コンストラクタ詳細

JobHistory.Task
public JobHistory.Task()

メソッド詳細

logStarted
public static void logStarted(TaskID taskId,String taskType,long startTime,String splitLocations)
タスクの開始時間を記録
Parameters:
taskId
taskType - MAP 又は REDUCE
startTime

logFinished
public static void logFinished(TaskID taskId, String taskType, long finishTime, Counters counters)
タスクの終了時間を記録
Parameters:
taskId
taskType - MAP 又は REDUCE
finishTime

logUpdates
public static void logUpdates(TaskID taskId,long finishTime)
タスクの終了時間を更新
Parameters:
taskId
finishTime

logFailed
public static void logFailed(TaskID taskId, String taskType, long time, String error)
失敗したジョブを記録
Parameters:
taskId
taskType - MAP 又は REDUCE.
time - ジョブが検出されなかった時のタイムスタンプ
error - 失敗時のエラーメッセージ

logFailed
public static void logFailed(TaskID taskId, String taskType, long time, String error, TaskAttemptID failedDueToAttempt)
Parameters:
failedDueToAttempt - 試行失敗の原因

getTaskAttempts
public Map getTaskAttempts()
全てのタスクの試行を返す

get
public String get(JobHistory.Keys k)
 与えられたキーの文字列を取得。最も多い場所が使用するgetメソッドは標準で値として文字列を返す。このメソッドは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()
マップに格納されている全てのキーの値を返す

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

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

About the author
  • コメントを残す