|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface HiveHistory
HiveHistory. Logs information such as query, query plan, runtime statistics into a file. Each session uses a new object, which creates a new file.
Nested Class Summary | |
---|---|
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. |
Method Summary | |
---|---|
void |
closeStream()
Close the log file stream |
void |
endQuery(String queryId)
Called at the end of a query |
void |
endTask(String queryId,
Task<? extends Serializable> task)
Called at the end of a task. |
String |
getHistFileName()
|
void |
logPlanProgress(QueryPlan plan)
Logs the current plan state |
void |
printRowCount(String queryId)
|
void |
progressTask(String queryId,
Task<? extends Serializable> task)
Logs progress of a task if ConfVars.HIVE_LOG_INCREMENTAL_PLAN_PROGRESS is set to true |
void |
setIdToTableMap(Map<String,String> map)
Set the id to table name map |
void |
setQueryProperty(String queryId,
HiveHistory.Keys propName,
String propValue)
Used to set query status and other attributes of a query |
void |
setTaskCounters(String queryId,
String taskId,
org.apache.hadoop.mapred.Counters ctrs)
Serialize the task counters and set as a task property. |
void |
setTaskProperty(String queryId,
String taskId,
HiveHistory.Keys propName,
String propValue)
Used to set task properties. |
void |
startQuery(String cmd,
String id)
Called at the start of query execution in Driver.execute(). |
void |
startTask(String queryId,
Task<? extends Serializable> task,
String taskName)
Called at the start of a task. |
Method Detail |
---|
String getHistFileName()
void startQuery(String cmd, String id)
void setQueryProperty(String queryId, HiveHistory.Keys propName, String propValue)
queryId
- propName
- propValue
- void setTaskProperty(String queryId, String taskId, HiveHistory.Keys propName, String propValue)
taskId
- propName
- propValue
- void setTaskCounters(String queryId, String taskId, org.apache.hadoop.mapred.Counters ctrs)
queryId
- taskId
- ctrs
- void printRowCount(String queryId)
void endQuery(String queryId)
queryId
- void startTask(String queryId, Task<? extends Serializable> task, String taskName)
task
- void endTask(String queryId, Task<? extends Serializable> task)
task
- void progressTask(String queryId, Task<? extends Serializable> task)
task
- void logPlanProgress(QueryPlan plan) throws IOException
plan
-
IOException
void setIdToTableMap(Map<String,String> map)
map
- void closeStream()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |