com.espertech.esper.event.vaevent
Class VAERevisionProcessorMerge

java.lang.Object
  com.espertech.esper.event.vaevent.VAERevisionProcessorBase
      com.espertech.esper.event.vaevent.VAERevisionProcessorMerge

All Implemented Interfaces:

ValueAddEventProcessor

public class VAERevisionProcessorMerge
extends VAERevisionProcessorBase
implements ValueAddEventProcessor

Provides a set of merge-strategies for merging individual properties (rather then overlaying groups).

Field Summary

Fields inherited from class com.espertech.esper.event.vaevent.VAERevisionProcessorBase

eventAdapterService, revisionEventType, revisionEventTypeName, revisionSpec, typeDescriptors

Constructor Summary

VAERevisionProcessorMerge(java.lang.String revisioneventTypeName, RevisionSpec spec, StatementStopService statementStopService, EventAdapterService eventAdapterService, EventTypeIdGenerator eventTypeIdGenerator)
Ctor.

Method Summary

java.util.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.
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) 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.

Methods inherited from class com.espertech.esper.event.vaevent.VAERevisionProcessorBase

getEventAdapterService, getValueAddEventType, validateEventType

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.espertech.esper.event.vaevent.ValueAddEventProcessor

getValueAddEventType, validateEventType

Constructor Detail

VAERevisionProcessorMerge

public VAERevisionProcessorMerge(java.lang.String revisioneventTypeName,
                                 RevisionSpec spec,
                                 StatementStopService statementStopService,
                                 EventAdapterService eventAdapterService,
                                 EventTypeIdGenerator eventTypeIdGenerator)

Ctor.

Parameters:

revisioneventTypeName - name

spec - specification

statementStopService - for stop handling

eventAdapterService - for nested property handling

Method Detail

getValueAddEventBean

public EventBean getValueAddEventBean(EventBean theEvent)

Description copied from interface: ValueAddEventProcessor

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

Specified by:

getValueAddEventBean in interface ValueAddEventProcessor

Parameters:

theEvent - to wrap

Returns:

revision event bean

onUpdate

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

Description copied from interface: ValueAddEventProcessor

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).

Specified by:

onUpdate in interface ValueAddEventProcessor

Parameters:

newData - new events

oldData - remove stream

namedWindowRootView - the root view

indexRepository - delete and select indexes

getSnapshot

public java.util.Collection<EventBean> getSnapshot(EPStatementAgentInstanceHandle createWindowStmtHandle,
                                                   Viewable parent)

Description copied from interface: ValueAddEventProcessor

Handle iteration over revision event contents.

Specified by:

getSnapshot in interface ValueAddEventProcessor

Parameters:

createWindowStmtHandle - statement handle for safe iteration

parent - the provider of data

Returns:

collection to iterate

removeOldData

public void removeOldData(EventBean[] oldData,
                          EventTableIndexRepository indexRepository)

Description copied from interface: ValueAddEventProcessor

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.

Specified by:

removeOldData in interface ValueAddEventProcessor

Parameters:

oldData - to remove

indexRepository - the indexes to update