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
String	getDiagnostics()
int	getTerminalWidth() NOTE: Use this method only if isUnixTerminal is true.
static void	initShutdownHook()
static void	killRunningJobs() killRunningJobs tries to terminate execution of all currently running tez queries.
int	monitorExecution(org.apache.tez.dag.api.client.DAGClient dagClient, HiveTxnManager txnMgr, HiveConf conf, org.apache.tez.dag.api.DAG dag) monitorExecution handles status printing, failures during execution and final status retrieval.
void	repositionCursor() NOTE: Use this method only if isUnixTerminal is true.
void	reprintLine(String line) NOTE: Use this method only if isUnixTerminal is true.
void	reprintLineWithColorAsBold(String line, org.fusesource.jansi.Ansi.Color color) NOTE: Use this method only if isUnixTerminal is true.
void	reprintMultiLine(String line) NOTE: Use this method only if isUnixTerminal is true.

Methods inherited from class java.lang.Object

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

Constructor Detail

TezJobMonitor

public TezJobMonitor()

Method Detail

initShutdownHook

public static void initShutdownHook()

reprintLine

public void reprintLine(String line)

NOTE: Use this method only if isUnixTerminal is true. Erases the current line and prints the given line.

Parameters:

line - - line to print

reprintLineWithColorAsBold

public void reprintLineWithColorAsBold(String line,
                              org.fusesource.jansi.Ansi.Color color)

NOTE: Use this method only if isUnixTerminal is true. Erases the current line and prints the given line with the specified color.

Parameters:

line - - line to print

color - - color for the line

reprintMultiLine

public void reprintMultiLine(String line)

NOTE: Use this method only if isUnixTerminal is true. Erases the current line and prints the given multiline. Make sure the specified line is not terminated by linebreak.

Parameters:

line - - line to print

repositionCursor

public void repositionCursor()

NOTE: Use this method only if isUnixTerminal is true. Repositions the cursor back to line 0.

getTerminalWidth

public int getTerminalWidth()

NOTE: Use this method only if isUnixTerminal is true. Gets the width of the terminal

Returns:

- width of terminal

monitorExecution

public int monitorExecution(org.apache.tez.dag.api.client.DAGClient dagClient,
                   HiveTxnManager txnMgr,
                   HiveConf conf,
                   org.apache.tez.dag.api.DAG dag)
                     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

killRunningJobs

public static void killRunningJobs()

killRunningJobs tries to terminate execution of all currently running tez queries. No guarantees, best effort only.

getDiagnostics

public String getDiagnostics()