com.espertech.esper.event.vaevent

Interface ValueAddEventProcessor

All Known Implementing Classes:

VAERevisionProcessorBase, VAERevisionProcessorDeclared, VAERevisionProcessorMerge, VAEVariantProcessor

public interface ValueAddEventProcessor

Interface for a processor of base and delta events in a revision event type.

Method Summary

Modifier and Type	Method and Description
Collection<EventBean>	getSnapshot(EPStatementAgentInstanceHandle createWindowStmtHandle, Viewable parent) Handle iteration over revision event contents.
EventBean	getValueAddEventBean(EventBean theEvent) For use in executing an insert-into, wraps the given event applying the revision event type, but not yet computing a new revision.
EventType	getValueAddEventType() Returns the event type that this revision processor generates.
void	onUpdate(EventBean[] newData, EventBean[] oldData, NamedWindowRootViewInstance namedWindowRootView, EventTableIndexRepository indexRepository) Upon new events arriving into a named window (new data), and upon events being deleted via on-delete (old data), update child views of the root view and apply to index repository as required (fast deletion).
void	removeOldData(EventBean[] oldData, EventTableIndexRepository indexRepository, AgentInstanceContext agentInstanceContext) Called each time a data window posts a remove stream event, to indicate that a data window remove an event as it expired according to a specified expiration policy.
void	validateEventType(EventType eventType) For use in checking insert-into statements, validates that the given type is eligible for revision event.

Method Detail

getValueAddEventType

EventType getValueAddEventType()

Returns the event type that this revision processor generates.

Returns:

event type

validateEventType

void validateEventType(EventType eventType)
                throws ExprValidationException

For use in checking insert-into statements, validates that the given type is eligible for revision event.

Parameters:

eventType - the type of the event participating in revision event type (or not)

Throws:

ExprValidationException - if the validation fails

getValueAddEventBean

EventBean getValueAddEventBean(EventBean theEvent)

For use in executing an insert-into, wraps the given event applying the revision event type, but not yet computing a new revision.

Parameters:

theEvent - to wrap

Returns:

revision event bean

onUpdate

void onUpdate(EventBean[] newData,
              EventBean[] oldData,
              NamedWindowRootViewInstance namedWindowRootView,
              EventTableIndexRepository indexRepository)

Upon new events arriving into a named window (new data), and upon events being deleted via on-delete (old data), update child views of the root view and apply to index repository as required (fast deletion).

Parameters:

newData - new events

oldData - remove stream

namedWindowRootView - the root view

indexRepository - delete and select indexes

getSnapshot

Collection<EventBean> getSnapshot(EPStatementAgentInstanceHandle createWindowStmtHandle,
                                  Viewable parent)

Handle iteration over revision event contents.

Parameters:

createWindowStmtHandle - statement handle for safe iteration

parent - the provider of data

Returns:

collection to iterate

removeOldData

void removeOldData(EventBean[] oldData,
                   EventTableIndexRepository indexRepository,
                   AgentInstanceContext agentInstanceContext)

Called each time a data window posts a remove stream event, to indicate that a data window remove an event as it expired according to a specified expiration policy.

Parameters:

oldData - to remove

indexRepository - the indexes to update

agentInstanceContext - agent instance context