org.apache.hadoop.hive.ql.hooks

Class HookContext

java.lang.Object

org.apache.hadoop.hive.ql.hooks.HookContext

public class HookContext
extends Object

Hook Context keeps all the necessary information for all the hooks. New implemented hook can get the query plan, job conf and the list of all completed tasks from this hook context

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HookContext.HookType

Constructor Summary

Constructors

Constructor and Description
HookContext(QueryPlan queryPlan, HiveConf conf, Map<String,org.apache.hadoop.fs.ContentSummary> inputPathToContentSummary, String userName, String ipAddress, String operationId)

Method Summary

Methods

Modifier and Type	Method and Description
void	addCompleteTask(TaskRunner completeTaskRunner)
List<TaskRunner>	getCompleteTaskList()
HiveConf	getConf()
HookContext.HookType	getHookType()
Map<String,org.apache.hadoop.fs.ContentSummary>	getInputPathToContentSummary()
Set<ReadEntity>	getInputs()
String	getIpAddress()
LineageInfo	getLinfo()
String	getOperationId()
String	getOperationName()
Set<WriteEntity>	getOutputs()
QueryPlan	getQueryPlan()
org.apache.hadoop.security.UserGroupInformation	getUgi()
String	getUserName()
void	setCompleteTaskList(List<TaskRunner> completeTaskList)
void	setConf(HiveConf conf)
void	setHookType(HookContext.HookType hookType)
void	setInputs(Set<ReadEntity> inputs)
void	setLinfo(LineageInfo linfo)
void	setOutputs(Set<WriteEntity> outputs)
void	setQueryPlan(QueryPlan queryPlan)
void	setUgi(org.apache.hadoop.security.UserGroupInformation ugi)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HookContext

public HookContext(QueryPlan queryPlan,
           HiveConf conf,
           Map<String,org.apache.hadoop.fs.ContentSummary> inputPathToContentSummary,
           String userName,
           String ipAddress,
           String operationId)
            throws Exception

Throws:

Exception

Method Detail

getQueryPlan

public QueryPlan getQueryPlan()

setQueryPlan

public void setQueryPlan(QueryPlan queryPlan)

getConf

public HiveConf getConf()

setConf

public void setConf(HiveConf conf)

getCompleteTaskList

public List<TaskRunner> getCompleteTaskList()

setCompleteTaskList

public void setCompleteTaskList(List<TaskRunner> completeTaskList)

addCompleteTask

public void addCompleteTask(TaskRunner completeTaskRunner)

getInputs

public Set<ReadEntity> getInputs()

setInputs

public void setInputs(Set<ReadEntity> inputs)

getOutputs

public Set<WriteEntity> getOutputs()

setOutputs

public void setOutputs(Set<WriteEntity> outputs)

getLinfo

public LineageInfo getLinfo()

setLinfo

public void setLinfo(LineageInfo linfo)

getUgi

public org.apache.hadoop.security.UserGroupInformation getUgi()

setUgi

public void setUgi(org.apache.hadoop.security.UserGroupInformation ugi)

getInputPathToContentSummary

public Map<String,org.apache.hadoop.fs.ContentSummary> getInputPathToContentSummary()

getHookType

public HookContext.HookType getHookType()

setHookType

public void setHookType(HookContext.HookType hookType)

getIpAddress

public String getIpAddress()

getOperationName

public String getOperationName()

getUserName

public String getUserName()

getOperationId

public String getOperationId()