public class HookContext extends Object
Modifier and Type | Class and Description |
---|---|
static class |
HookContext.HookType |
Constructor and Description |
---|
HookContext(QueryPlan queryPlan,
QueryState queryState,
Map<String,org.apache.hadoop.fs.ContentSummary> inputPathToContentSummary,
String userName,
String ipAddress,
String hiveInstanceAddress,
String operationId,
String sessionId,
String threadId,
boolean isHiveServerQuery,
PerfLogger perfLogger) |
public HookContext(QueryPlan queryPlan, QueryState queryState, Map<String,org.apache.hadoop.fs.ContentSummary> inputPathToContentSummary, String userName, String ipAddress, String hiveInstanceAddress, String operationId, String sessionId, String threadId, boolean isHiveServerQuery, PerfLogger perfLogger) throws Exception
Exception
public QueryPlan getQueryPlan()
public void setQueryPlan(QueryPlan queryPlan)
public HiveConf getConf()
public void setConf(HiveConf conf)
public List<TaskRunner> getCompleteTaskList()
public void setCompleteTaskList(List<TaskRunner> completeTaskList)
public void addCompleteTask(TaskRunner completeTaskRunner)
public Set<ReadEntity> getInputs()
public void setInputs(Set<ReadEntity> inputs)
public Set<WriteEntity> getOutputs()
public void setOutputs(Set<WriteEntity> outputs)
public LineageInfo getLinfo()
public void setLinfo(LineageInfo linfo)
public LineageCtx.Index getIndex()
public void setIndex(LineageCtx.Index depMap)
public org.apache.hadoop.security.UserGroupInformation getUgi()
public void setUgi(org.apache.hadoop.security.UserGroupInformation ugi)
public Map<String,org.apache.hadoop.fs.ContentSummary> getInputPathToContentSummary()
public HookContext.HookType getHookType()
public void setHookType(HookContext.HookType hookType)
public String getIpAddress()
public String getHiveInstanceAddress()
public void setErrorMessage(String errorMessage)
public String getErrorMessage()
public void setException(Throwable exception)
public Throwable getException()
public String getOperationName()
public String getUserName()
public String getOperationId()
public QueryState getQueryState()
public String getSessionId()
public String getThreadId()
public boolean isHiveServerQuery()
public PerfLogger getPerfLogger()
Copyright © 2021 The Apache Software Foundation. All rights reserved.