public class TezJobMonitor extends Object
Constructor and Description |
---|
TezJobMonitor(Map<String,BaseWork> workMap) |
Modifier and Type | Method and Description |
---|---|
String |
getDiagnostics() |
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,
HiveConf conf,
org.apache.tez.dag.api.DAG dag,
Context ctx)
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 monitorExecution(org.apache.tez.dag.api.client.DAGClient dagClient, HiveConf conf, org.apache.tez.dag.api.DAG dag, Context ctx) throws InterruptedException
dagClient
- client that was used to kick off the jobconf
- configuration file for this operationInterruptedException
public static void killRunningJobs()
public String getDiagnostics()
Copyright © 2016 The Apache Software Foundation. All rights reserved.