org.apache.hadoop.hive.ql.wm

Class ExecutionTrigger

java.lang.Object

org.apache.hadoop.hive.ql.wm.ExecutionTrigger

All Implemented Interfaces:

Trigger

public class ExecutionTrigger
extends Object
implements Trigger

Trigger with query level scope that contains a name, trigger expression violating which defined action will be executed.

Constructor Summary

Constructors

Constructor and Description
ExecutionTrigger(String name, Expression expression, Action action)

Method Summary

Modifier and Type	Method and Description
boolean	apply(long current) Based on current value, returns true if trigger is applied else false.
Trigger	clone() Return cloned copy of this trigger
boolean	equals(Object other)
static ExecutionTrigger	fromWMTrigger(org.apache.hadoop.hive.metastore.api.WMTrigger trigger)
Action	getAction() Return the action that will get executed when trigger expression evaluates to true
Expression	getExpression() Get trigger expression
String	getName() Return the name of the trigger
String	getViolationMsg() Get error message set during trigger violation.
int	hashCode()
void	setViolationMsg(String violationMsg) Set trigger violation message.
String	toString()

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ExecutionTrigger

public ExecutionTrigger(String name,
                        Expression expression,
                        Action action)

Method Detail

getName

public String getName()

Description copied from interface: Trigger

Return the name of the trigger

Specified by:

getName in interface Trigger

Returns:

trigger name

getExpression

public Expression getExpression()

Description copied from interface: Trigger

Get trigger expression

Specified by:

getExpression in interface Trigger

Returns:

expression

getAction

public Action getAction()

Description copied from interface: Trigger

Return the action that will get executed when trigger expression evaluates to true

Specified by:

getAction in interface Trigger

Returns:

action

clone

public Trigger clone()

Description copied from interface: Trigger

Return cloned copy of this trigger

Specified by:

clone in interface Trigger

Overrides:

clone in class Object

Returns:

clone copy

getViolationMsg

public String getViolationMsg()

Description copied from interface: Trigger

Get error message set during trigger violation.

Specified by:

getViolationMsg in interface Trigger

Returns:

trigger violation message

setViolationMsg

public void setViolationMsg(String violationMsg)

Description copied from interface: Trigger

Set trigger violation message. When Trigger.apply(long) returns false, this can be used to set message for trigger violation which will be sent as response to clients.

Specified by:

setViolationMsg in interface Trigger

Parameters:

violationMsg - violation message

apply

public boolean apply(long current)

Description copied from interface: Trigger

Based on current value, returns true if trigger is applied else false.

Specified by:

apply in interface Trigger

Parameters:

current - - current value

Returns:

true if trigger got applied false otherwise

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object other)

Overrides:

equals in class Object

fromWMTrigger

public static ExecutionTrigger fromWMTrigger(org.apache.hadoop.hive.metastore.api.WMTrigger trigger)