public interface HiveHistory
Modifier and Type | Interface and Description |
---|---|
static class |
HiveHistory.Info
Info.
|
static class |
HiveHistory.Keys
Keys.
|
static interface |
HiveHistory.Listener
Listener interface.
|
static class |
HiveHistory.QueryInfo
QueryInfo.
|
static class |
HiveHistory.RecordTypes
RecordTypes.
|
static class |
HiveHistory.SessionInfo
SessionInfo.
|
static class |
HiveHistory.TaskInfo
TaskInfo.
|
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.
|
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.
|
java.lang.String getHistFileName()
void startQuery(java.lang.String cmd, java.lang.String id)
void setQueryProperty(java.lang.String queryId, HiveHistory.Keys propName, java.lang.String propValue)
queryId
- propName
- propValue
- void setTaskProperty(java.lang.String queryId, java.lang.String taskId, HiveHistory.Keys propName, java.lang.String propValue)
taskId
- propName
- propValue
- void setTaskCounters(java.lang.String queryId, java.lang.String taskId, Counters ctrs)
queryId
- taskId
- ctrs
- void printRowCount(java.lang.String queryId)
void endQuery(java.lang.String queryId)
queryId
- void startTask(java.lang.String queryId, Task<? extends java.io.Serializable> task, java.lang.String taskName)
task
- void endTask(java.lang.String queryId, Task<? extends java.io.Serializable> task)
task
- void progressTask(java.lang.String queryId, Task<? extends java.io.Serializable> task)
task
- void logPlanProgress(QueryPlan plan) throws java.io.IOException
plan
- java.io.IOException
void setIdToTableMap(java.util.Map<java.lang.String,java.lang.String> map)
map
- void closeStream()
Copyright © 2012 The Apache Software Foundation