com.espertech.esper.common.internal.epl.ontrigger

Class InfraOnMergeActionUpd

java.lang.Object

com.espertech.esper.common.internal.epl.ontrigger.InfraOnMergeAction

com.espertech.esper.common.internal.epl.ontrigger.InfraOnMergeActionUpd

All Implemented Interfaces:

StatementReadyCallback, TableUpdateStrategyRedoCallback

public class InfraOnMergeActionUpd
extends InfraOnMergeAction
implements TableUpdateStrategyRedoCallback, StatementReadyCallback

Field Summary

Fields

Modifier and Type	Field and Description
static EPTypeClass	EPTYPE

Constructor Summary

Constructors

Constructor and Description
InfraOnMergeActionUpd(ExprEvaluator optionalFilter, EventBeanUpdateHelperNoCopy tableUpdate, Table table)
InfraOnMergeActionUpd(ExprEvaluator optionalFilter, EventBeanUpdateHelperWCopy namedWindowUpdate)

Method Summary

Modifier and Type	Method and Description
void	apply(EventBean matchingEvent, EventBean[] eventsPerStream, OneEventCollection newData, OneEventCollection oldData, AgentInstanceContext agentInstanceContext)
void	apply(EventBean matchingEvent, EventBean[] eventsPerStream, TableInstance tableStateInstance, OnExprViewTableChangeHandler changeHandlerAdded, OnExprViewTableChangeHandler changeHandlerRemoved, AgentInstanceContext agentInstanceContext)
String	getName()
String[]	getTableUpdatedProperties()
void	initTableUpdateStrategy(Table table)
boolean	isMerge()
void	ready(StatementContext statementContext, ModuleIncidentals moduleIncidentals, boolean recovery)

Methods inherited from class com.espertech.esper.common.internal.epl.ontrigger.InfraOnMergeAction

isApplies

Methods inherited from class java.lang.Object

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

Field Detail

EPTYPE

public static final EPTypeClass EPTYPE

Constructor Detail

InfraOnMergeActionUpd

public InfraOnMergeActionUpd(ExprEvaluator optionalFilter,
                             EventBeanUpdateHelperWCopy namedWindowUpdate)

InfraOnMergeActionUpd

public InfraOnMergeActionUpd(ExprEvaluator optionalFilter,
                             EventBeanUpdateHelperNoCopy tableUpdate,
                             Table table)

Method Detail

ready

public void ready(StatementContext statementContext,
                  ModuleIncidentals moduleIncidentals,
                  boolean recovery)

Specified by:

ready in interface StatementReadyCallback

apply

public void apply(EventBean matchingEvent,
                  EventBean[] eventsPerStream,
                  OneEventCollection newData,
                  OneEventCollection oldData,
                  AgentInstanceContext agentInstanceContext)

Specified by:

apply in class InfraOnMergeAction

apply

public void apply(EventBean matchingEvent,
                  EventBean[] eventsPerStream,
                  TableInstance tableStateInstance,
                  OnExprViewTableChangeHandler changeHandlerAdded,
                  OnExprViewTableChangeHandler changeHandlerRemoved,
                  AgentInstanceContext agentInstanceContext)

Specified by:

apply in class InfraOnMergeAction

getName

public String getName()

Specified by:

getName in class InfraOnMergeAction

isMerge

public boolean isMerge()

Specified by:

isMerge in interface TableUpdateStrategyRedoCallback

getTableUpdatedProperties

public String[] getTableUpdatedProperties()

Specified by:

getTableUpdatedProperties in interface TableUpdateStrategyRedoCallback

initTableUpdateStrategy

public void initTableUpdateStrategy(Table table)

Specified by:

initTableUpdateStrategy in interface TableUpdateStrategyRedoCallback