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

static class

HookContext.HookType

Constructor Summary

HookContext(QueryPlan queryPlan, HiveConf conf)

HookContext(QueryPlan queryPlan, HiveConf conf, Map<String,org.apache.hadoop.fs.ContentSummary> inputPathToContentSummary)

Method Summary

void	addCompleteTask(TaskRunner completeTaskRunner)
List<TaskRunner>	getCompleteTaskList()
HiveConf	getConf()
HookContext.HookType	getHookType()
Map<String,org.apache.hadoop.fs.ContentSummary>	getInputPathToContentSummary()
Set<ReadEntity>	getInputs()
LineageInfo	getLinfo()
Set<WriteEntity>	getOutputs()
QueryPlan	getQueryPlan()
org.apache.hadoop.security.UserGroupInformation	getUgi()
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)
            throws Exception

Throws:

Exception

HookContext

public HookContext(QueryPlan queryPlan,
                   HiveConf conf,
                   Map<String,org.apache.hadoop.fs.ContentSummary> inputPathToContentSummary)
            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)