org.apache.hadoop.hive.ql.wm

Class WmContext

java.lang.Object

org.apache.hadoop.hive.ql.wm.WmContext

All Implemented Interfaces:

PrintSummary

@MXBean
public class WmContext
extends Object
implements PrintSummary

Some context information that are required for rule evaluation.

Constructor Summary

Constructors

Constructor and Description
WmContext(long queryStartTime, String queryId)

Method Summary

Modifier and Type	Method and Description
void	addSubscribedCounters(Set<String> moreCounters)
void	addTriggers(List<Trigger> triggers)
void	addWMEvent(WmEvent wmEvent)
Set<Trigger>	getAppliedTriggers()
Map<String,Long>	getCurrentCounters()
long	getElapsedTime()
long	getQueryEndTime()
String	getQueryId()
long	getQueryStartTime()
Set<String>	getSubscribedCounters()
boolean	isQueryCompleted()
void	print(SessionState.LogHelper console)
void	printJson(SessionState.LogHelper console)
void	setCurrentCounters(Map<String,Long> currentCounters)
void	setQueryCompleted(boolean queryCompleted)
void	setQueryId(String queryId)
void	setReturnEventFuture(Future<Boolean> returnEventFuture)
void	setSubscribedCounters(Set<String> subscribedCounters)
void	shortPrint(SessionState.LogHelper console)
void	updateElapsedTimeCounter()

Methods inherited from class java.lang.Object

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

Constructor Detail

WmContext

public WmContext(long queryStartTime,
                 String queryId)

Method Detail

getAppliedTriggers

public Set<Trigger> getAppliedTriggers()

addTriggers

public void addTriggers(List<Trigger> triggers)

getQueryId

public String getQueryId()

setQueryId

public void setQueryId(String queryId)

getSubscribedCounters

public Set<String> getSubscribedCounters()

setSubscribedCounters

public void setSubscribedCounters(Set<String> subscribedCounters)

addSubscribedCounters

public void addSubscribedCounters(Set<String> moreCounters)

getCurrentCounters

public Map<String,Long> getCurrentCounters()

setCurrentCounters

public void setCurrentCounters(Map<String,Long> currentCounters)

getElapsedTime

public long getElapsedTime()

isQueryCompleted

public boolean isQueryCompleted()

setQueryCompleted

public void setQueryCompleted(boolean queryCompleted)

addWMEvent

public void addWMEvent(WmEvent wmEvent)

getQueryStartTime

public long getQueryStartTime()

getQueryEndTime

public long getQueryEndTime()

setReturnEventFuture

public void setReturnEventFuture(Future<Boolean> returnEventFuture)

print

public void print(SessionState.LogHelper console)

Specified by:

print in interface PrintSummary

printJson

public void printJson(SessionState.LogHelper console)

shortPrint

public void shortPrint(SessionState.LogHelper console)
                throws ExecutionException,
                       InterruptedException

Throws:

ExecutionException

InterruptedException

updateElapsedTimeCounter

public void updateElapsedTimeCounter()