org.apache.hadoop.hive.ql.exec.tez
Class TezJobMonitor

java.lang.Object
  org.apache.hadoop.hive.ql.exec.tez.TezJobMonitor

public class TezJobMonitor
extends Object

TezJobMonitor keeps track of a tez job while it's being executed. It will print status to the console and retrieve final status of the job after completion.

Constructor Summary

TezJobMonitor()

Method Summary

int	monitorExecution(org.apache.tez.dag.api.client.DAGClient dagClient, HiveTxnManager txnMgr, HiveConf conf) monitorExecution handles status printing, failures during execution and final status retrieval.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TezJobMonitor

public TezJobMonitor()

Method Detail

monitorExecution

public int monitorExecution(org.apache.tez.dag.api.client.DAGClient dagClient,
                            HiveTxnManager txnMgr,
                            HiveConf conf)
                     throws InterruptedException

monitorExecution handles status printing, failures during execution and final status retrieval.

Parameters:

dagClient - client that was used to kick off the job

txnMgr - transaction manager for this operation

conf - configuration file for this operation

Returns:

int 0 - success, 1 - killed, 2 - failed

Throws:

InterruptedException