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

Constructors

Constructor and Description
TezJobMonitor()

Method Summary

Methods

Modifier and Type	Method and Description
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