public class HiveHistoryImpl extends java.lang.Object implements HiveHistory
HiveHistory.Info, HiveHistory.Keys, HiveHistory.Listener, HiveHistory.QueryInfo, HiveHistory.RecordTypes, HiveHistory.SessionInfo, HiveHistory.TaskInfo
Constructor and Description |
---|
HiveHistoryImpl(SessionState ss)
Construct HiveHistoryImpl object and open history log file.
|
Modifier and Type | Method and Description |
---|---|
void |
closeStream()
Close the log file stream
|
void |
endQuery(java.lang.String queryId)
Called at the end of a query
|
void |
endTask(java.lang.String queryId,
Task<? extends java.io.Serializable> task)
Called at the end of a task.
|
void |
finalize() |
java.lang.String |
getHistFileName() |
void |
logPlanProgress(QueryPlan plan)
Logs the current plan state
|
void |
printRowCount(java.lang.String queryId) |
void |
progressTask(java.lang.String queryId,
Task<? extends java.io.Serializable> task)
Logs progress of a task if ConfVars.HIVE_LOG_INCREMENTAL_PLAN_PROGRESS is
set to true
|
void |
setIdToTableMap(java.util.Map<java.lang.String,java.lang.String> map)
Set the id to table name map
|
void |
setQueryProperty(java.lang.String queryId,
HiveHistory.Keys propName,
java.lang.String propValue)
Used to set query status and other attributes of a query
|
void |
setTaskCounters(java.lang.String queryId,
java.lang.String taskId,
Counters ctrs)
Serialize the task counters and set as a task property.
|
void |
setTaskProperty(java.lang.String queryId,
java.lang.String taskId,
HiveHistory.Keys propName,
java.lang.String propValue)
Used to set task properties.
|
void |
startQuery(java.lang.String cmd,
java.lang.String id)
Called at the start of query execution in Driver.execute().
|
void |
startTask(java.lang.String queryId,
Task<? extends java.io.Serializable> task,
java.lang.String taskName)
Called at the start of a task.
|
public HiveHistoryImpl(SessionState ss)
ss
- public java.lang.String getHistFileName()
getHistFileName
in interface HiveHistory
public void startQuery(java.lang.String cmd, java.lang.String id)
HiveHistory
startQuery
in interface HiveHistory
public void setQueryProperty(java.lang.String queryId, HiveHistory.Keys propName, java.lang.String propValue)
HiveHistory
setQueryProperty
in interface HiveHistory
public void setTaskProperty(java.lang.String queryId, java.lang.String taskId, HiveHistory.Keys propName, java.lang.String propValue)
HiveHistory
setTaskProperty
in interface HiveHistory
public void setTaskCounters(java.lang.String queryId, java.lang.String taskId, Counters ctrs)
HiveHistory
setTaskCounters
in interface HiveHistory
public void printRowCount(java.lang.String queryId)
printRowCount
in interface HiveHistory
public void endQuery(java.lang.String queryId)
HiveHistory
endQuery
in interface HiveHistory
public void startTask(java.lang.String queryId, Task<? extends java.io.Serializable> task, java.lang.String taskName)
HiveHistory
startTask
in interface HiveHistory
public void endTask(java.lang.String queryId, Task<? extends java.io.Serializable> task)
HiveHistory
endTask
in interface HiveHistory
public void progressTask(java.lang.String queryId, Task<? extends java.io.Serializable> task)
HiveHistory
progressTask
in interface HiveHistory
public void logPlanProgress(QueryPlan plan) throws java.io.IOException
HiveHistory
logPlanProgress
in interface HiveHistory
java.io.IOException
public void setIdToTableMap(java.util.Map<java.lang.String,java.lang.String> map)
HiveHistory
setIdToTableMap
in interface HiveHistory
public void closeStream()
HiveHistory
closeStream
in interface HiveHistory
public void finalize() throws java.lang.Throwable
finalize
in class java.lang.Object
java.lang.Throwable
Copyright © 2012 The Apache Software Foundation