public class TezJobMonitor extends Object
Constructor and Description |
---|
TezJobMonitor() |
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.
|
public static void initShutdownHook()
public void reprintLine(String line)
line
- - line to printpublic void reprintLineWithColorAsBold(String line, org.fusesource.jansi.Ansi.Color color)
line
- - line to printcolor
- - color for the linepublic void reprintMultiLine(String line)
line
- - line to printpublic void repositionCursor()
public int getTerminalWidth()
public int monitorExecution(org.apache.tez.dag.api.client.DAGClient dagClient, HiveTxnManager txnMgr, HiveConf conf, org.apache.tez.dag.api.DAG dag) throws InterruptedException
dagClient
- client that was used to kick off the jobtxnMgr
- transaction manager for this operationconf
- configuration file for this operationInterruptedException
public static void killRunningJobs()
public String getDiagnostics()
Copyright © 2017 The Apache Software Foundation. All rights reserved.