public class RemoteSparkJobMonitor extends Object
Modifier and Type | Class and Description |
---|---|
protected static class |
SparkJobMonitor.StageState |
Modifier and Type | Field and Description |
---|---|
protected int |
checkInterval |
protected static String |
CLASS_NAME |
protected SessionState.LogHelper |
console |
protected boolean |
inPlaceUpdate |
protected static org.slf4j.Logger |
LOG |
protected long |
monitorTimeoutInterval |
protected PerfLogger |
perfLogger |
protected long |
startTime |
Constructor and Description |
---|
RemoteSparkJobMonitor(HiveConf hiveConf,
RemoteSparkJobStatus sparkJobStatus) |
Modifier and Type | Method and Description |
---|---|
protected void |
printStatus(Map<String,SparkStageProgress> progressMap,
Map<String,SparkStageProgress> lastProgressMap) |
int |
startMonitor() |
protected static final String CLASS_NAME
protected static final org.slf4j.Logger LOG
protected final transient SessionState.LogHelper console
protected final PerfLogger perfLogger
protected final int checkInterval
protected final long monitorTimeoutInterval
protected long startTime
protected final boolean inPlaceUpdate
public RemoteSparkJobMonitor(HiveConf hiveConf, RemoteSparkJobStatus sparkJobStatus)
public int startMonitor()
protected void printStatus(Map<String,SparkStageProgress> progressMap, Map<String,SparkStageProgress> lastProgressMap)
Copyright © 2017 The Apache Software Foundation. All rights reserved.