com.espertech.esper.runtime.internal.kernel.service

Class EPEventServiceImpl

java.lang.Object

com.espertech.esper.runtime.internal.kernel.service.EPEventServiceImpl

All Implemented Interfaces:

com.espertech.esper.common.internal.context.util.InternalEventRouteDest, com.espertech.esper.common.internal.event.core.EventServiceSendEventCommon, com.espertech.esper.common.internal.event.util.EPRuntimeEventProcessWrapped, EPEventService, EPEventServiceRouteEvent, EPEventServiceSendEvent, EPEventServiceTimeControl, EPEventServiceSPI, TimerCallback

public class EPEventServiceImpl
extends Object
implements EPEventServiceSPI, com.espertech.esper.common.internal.context.util.InternalEventRouteDest, TimerCallback, com.espertech.esper.common.internal.event.util.EPRuntimeEventProcessWrapped

Implements runtime interface. Also accepts timer callbacks for synchronizing time events with regular events sent in.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	isPrioritized
protected static org.slf4j.Logger	log
protected ThreadLocal<com.espertech.esper.common.internal.collection.ArrayBackedCollection<com.espertech.esper.common.internal.filtersvc.FilterHandle>>	matchesArrayThreadLocal
protected EPServicesContext	services
protected UnmatchedListener	unmatchedListener

Constructor Summary

Constructors

Constructor and Description
EPEventServiceImpl(EPServicesContext services) Constructor.

Method Summary

Modifier and Type	Method and Description
void	advanceTime(long time) Advance time by jumping to the given time in milliseconds (or nanoseconds if so configured).
void	advanceTimeSpan(long targetTime) Advance time by continually-sliding to the given time in milliseconds (or nanoseconds if so configured) at the smallest resolution (non-hopping).
void	advanceTimeSpan(long targetTime, long resolution) Advance time by continually-sliding to the given time in milliseconds (or nanoseconds if so configured) at the provided resolution (hopping).
void	clearCaches()
void	clockExternal() Switches off the internal timer which tracks system time.
void	clockInternal() Switches on the internal timer which tracks system time.
void	destroy() Destroy for destroying an runtime instance: sets references to null and clears thread-locals
void	dispatch() Dispatch events.
long	getCurrentTime() Returns current engine time.
com.espertech.esper.common.client.EventSender	getEventSender(String eventTypeName) Returns a facility to process event objects that are of a known type.
Long	getNextScheduledTime() Returns the time at which the next schedule execution is expected, returns null if no schedule execution is outstanding.
long	getNumEventsEvaluated() Number of events evaluated over the lifetime of the event stream processing runtime, or since the last resetStats() call.
long	getRoutedExternal()
long	getRoutedInternal()
String	getRuntimeURI()
EPServicesContext	getServices()
Map<com.espertech.esper.common.internal.util.DeploymentIdNamePair,Long>	getStatementNearestSchedules()
protected void	handleFilterFault(com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle faultingHandle, com.espertech.esper.common.client.EventBean theEvent, int filterFaultCount)
void	initialize()
boolean	isExternalClockingEnabled() Returns true for external clocking, false for internal clocking.
protected void	processMatches(com.espertech.esper.common.client.EventBean theEvent)
void	processScheduleHandles(com.espertech.esper.common.internal.collection.ArrayBackedCollection<com.espertech.esper.common.internal.schedule.ScheduleHandle> handles)
void	processStatementFilterMultiple(com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle handle, Object callbackList, com.espertech.esper.common.client.EventBean theEvent, long version, int filterFaultCount) Processing multiple filter matches for a statement.
void	processStatementFilterSingle(com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle handle, com.espertech.esper.common.internal.context.util.EPStatementHandleCallbackFilter handleCallback, com.espertech.esper.common.client.EventBean theEvent, long version, int filterFaultCount) Process a single match.
static void	processStatementScheduleMultiple(com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle handle, Object callbackObject, EPServicesContext services) Processing multiple schedule matches for a statement.
static void	processStatementScheduleSingle(com.espertech.esper.common.internal.context.util.EPStatementHandleCallbackSchedule handle, EPServicesContext services) Processing single schedule matche for a statement.
void	processThreadWorkQueue() Works off the thread's work queue.
void	processWrappedEvent(com.espertech.esper.common.client.EventBean eventBean)
void	resetStats() Reset the count of the number of events received and emitted
void	route(com.espertech.esper.common.client.EventBean theEvent, com.espertech.esper.common.internal.context.util.EPStatementHandle epStatementHandle, boolean addToFront)
void	routeEventAvro(Object avroGenericDataDotRecord, String eventTypeName) Route the event object back to the runtime for internal dispatching, to avoid the possibility of a stack overflow due to nested calls to sendEvent.
void	routeEventBean(com.espertech.esper.common.client.EventBean theEvent)
void	routeEventBean(Object event, String eventTypeName) Route the event object back to the runtime for internal dispatching, to avoid the possibility of a stack overflow due to nested calls to sendEvent.
void	routeEventMap(Map<String,Object> map, String eventTypeName) Route the event object back to the runtime for internal dispatching, to avoid the possibility of a stack overflow due to nested calls to sendEvent.
void	routeEventObjectArray(Object[] event, String eventTypeName) Route the event object back to the runtime for internal dispatching, to avoid the possibility of a stack overflow due to nested calls to sendEvent.
void	routeEventXMLDOM(Node event, String eventTypeName) Route the event object back to the runtime for internal dispatching, to avoid the possibility of a stack overflow due to nested calls to sendEvent.
void	sendEventAvro(Object avroGenericDataDotRecord, String avroEventTypeName) Send an event represented by a Avro GenericData.Record to the runtime.
void	sendEventBean(Object theEvent, String eventTypeName) Send an event represented by an object to the runtime.
void	sendEventMap(Map<String,Object> map, String mapEventTypeName) Send a map containing event property values to the runtime.
void	sendEventObjectArray(Object[] propertyValues, String eventTypeName) Send an object array containing event property values to the runtime.
void	sendEventXMLDOM(Node node, String eventTypeName) Send an event represented by a DOM node to the runtime.
void	setInternalEventRouter(com.espertech.esper.common.internal.context.util.InternalEventRouter internalEventRouter) Sets the route for events to use
void	setUnmatchedListener(UnmatchedListener listener) Sets a listener to receive events that are unmatched by any statement.
void	timerCallback() Invoked by the internal clocking service at regular intervals.

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.slf4j.Logger log

services

protected EPServicesContext services

isPrioritized

protected boolean isPrioritized

unmatchedListener

protected volatile UnmatchedListener unmatchedListener

matchesArrayThreadLocal

protected ThreadLocal<com.espertech.esper.common.internal.collection.ArrayBackedCollection<com.espertech.esper.common.internal.filtersvc.FilterHandle>> matchesArrayThreadLocal

Constructor Detail

EPEventServiceImpl

public EPEventServiceImpl(EPServicesContext services)

Constructor.

Parameters:

services - - references to services

Method Detail

getServices

public EPServicesContext getServices()

setInternalEventRouter

public void setInternalEventRouter(com.espertech.esper.common.internal.context.util.InternalEventRouter internalEventRouter)

Sets the route for events to use

Specified by:

setInternalEventRouter in interface com.espertech.esper.common.internal.context.util.InternalEventRouteDest

Parameters:

internalEventRouter - router

getRoutedInternal

public long getRoutedInternal()

Specified by:

getRoutedInternal in interface EPEventServiceSPI

getRoutedExternal

public long getRoutedExternal()

Specified by:

getRoutedExternal in interface EPEventServiceSPI

timerCallback

public void timerCallback()

Description copied from interface: TimerCallback

Invoked by the internal clocking service at regular intervals.

Specified by:

timerCallback in interface TimerCallback

sendEventAvro

public void sendEventAvro(Object avroGenericDataDotRecord,
                          String avroEventTypeName)

Description copied from interface: EPEventServiceSendEvent

Send an event represented by a Avro GenericData.Record to the runtime.

Use the route method for sending events into the runtime from within UpdateListener code, to avoid the possibility of a stack overflow due to nested calls to sendEvent (except with the outbound-threading configuration), see EPEventServiceRouteEvent.routeEventAvro(Object, String)}).

Specified by:

sendEventAvro in interface com.espertech.esper.common.internal.event.core.EventServiceSendEventCommon

Specified by:

sendEventAvro in interface EPEventServiceSendEvent

Parameters:

avroGenericDataDotRecord - is the event to sent to the runtime

avroEventTypeName - event type name

sendEventBean

public void sendEventBean(Object theEvent,
                          String eventTypeName)

Description copied from interface: EPEventServiceSendEvent

Send an event represented by an object to the runtime.

Use the route method for sending events into the runtime from within UpdateListener code, to avoid the possibility of a stack overflow due to nested calls to sendEvent (except with the outbound-threading configuration), see EPEventServiceRouteEvent.routeEventBean(Object, String).

Specified by:

sendEventBean in interface com.espertech.esper.common.internal.event.core.EventServiceSendEventCommon

Specified by:

sendEventBean in interface EPEventServiceSendEvent

Parameters:

theEvent - is the event to sent to the runtime

eventTypeName - event type name

advanceTime

public void advanceTime(long time)

Description copied from interface: EPEventServiceTimeControl

Advance time by jumping to the given time in milliseconds (or nanoseconds if so configured).

For externally controlling the time within a runtime.

External clocking must be first be enabled by configuration ConfigurationRuntimeThreading.setInternalTimerEnabled(boolean) passing false or by calling EPEventServiceTimeControl.clockExternal().

Time should never move backwards (unless for testing purposes where previous results can be thrown away)

Specified by:

advanceTime in interface EPEventServiceTimeControl

Parameters:

time - time

advanceTimeSpan

public void advanceTimeSpan(long targetTime)

Description copied from interface: EPEventServiceTimeControl

Advance time by continually-sliding to the given time in milliseconds (or nanoseconds if so configured) at the smallest resolution (non-hopping).

For externally controlling the time within a runtime.

External clocking must be first be enabled by configuration ConfigurationRuntimeThreading.setInternalTimerEnabled(boolean) passing false or by calling EPEventServiceTimeControl.clockExternal().

Time should never move backwards (unless for testing purposes where previous results can be thrown away)

Specified by:

advanceTimeSpan in interface EPEventServiceTimeControl

Parameters:

targetTime - time

advanceTimeSpan

public void advanceTimeSpan(long targetTime,
                            long resolution)

Description copied from interface: EPEventServiceTimeControl

Advance time by continually-sliding to the given time in milliseconds (or nanoseconds if so configured) at the provided resolution (hopping).

For externally controlling the time within a runtime.

External clocking must be first be enabled by configuration ConfigurationRuntimeThreading.setInternalTimerEnabled(boolean) passing false or by calling EPEventServiceTimeControl.clockExternal().

Time should never move backwards (unless for testing purposes where previous results can be thrown away)

Specified by:

advanceTimeSpan in interface EPEventServiceTimeControl

Parameters:

targetTime - time

resolution - the resolution to use

getNextScheduledTime

public Long getNextScheduledTime()

Description copied from interface: EPEventServiceTimeControl

Returns the time at which the next schedule execution is expected, returns null if no schedule execution is outstanding.

Specified by:

getNextScheduledTime in interface EPEventServiceTimeControl

Returns:

time of next schedule if any

sendEventXMLDOM

public void sendEventXMLDOM(Node node,
                            String eventTypeName)

Description copied from interface: EPEventServiceSendEvent

Send an event represented by a DOM node to the runtime.

Use the route method for sending events into the runtime from within UpdateListener code. to avoid the possibility of a stack overflow due to nested calls to sendEvent (except with the outbound-threading configuration), see EPEventServiceRouteEvent.routeEventXMLDOM(Node, String).

Specified by:

sendEventXMLDOM in interface com.espertech.esper.common.internal.event.core.EventServiceSendEventCommon

Specified by:

sendEventXMLDOM in interface EPEventServiceSendEvent

Parameters:

node - is the DOM node as an event

eventTypeName - event type name

sendEventObjectArray

public void sendEventObjectArray(Object[] propertyValues,
                                 String eventTypeName)
                          throws com.espertech.esper.common.client.EPException

Description copied from interface: EPEventServiceSendEvent

Send an object array containing event property values to the runtime.

Use the route method for sending events into the runtime from within UpdateListener code. to avoid the possibility of a stack overflow due to nested calls to sendEvent (except with the outbound-threading configuration), see EPEventServiceRouteEvent.routeEventObjectArray(Object[], String).

Specified by:

sendEventObjectArray in interface com.espertech.esper.common.internal.event.core.EventServiceSendEventCommon

Specified by:

sendEventObjectArray in interface EPEventServiceSendEvent

Parameters:

propertyValues - - array that contains event property values. Your application must ensure that property values match the exact same order that the property names and types have been declared, and that the array length matches the number of properties declared.

eventTypeName - - event type name

Throws:

com.espertech.esper.common.client.EPException - - when the processing of the event leads to an error

sendEventMap

public void sendEventMap(Map<String,Object> map,
                         String mapEventTypeName)
                  throws com.espertech.esper.common.client.EPException

Description copied from interface: EPEventServiceSendEvent

Send a map containing event property values to the runtime.

Use the route method for sending events into the runtime from within UpdateListener code. to avoid the possibility of a stack overflow due to nested calls to sendEvent (except with the outbound-threading configuration), see EPEventServiceRouteEvent.routeEventMap(java.util.Map, String)).

Specified by:

sendEventMap in interface com.espertech.esper.common.internal.event.core.EventServiceSendEventCommon

Specified by:

sendEventMap in interface EPEventServiceSendEvent

Parameters:

map - - map that contains event property values. Keys are expected to be of type String while values can be of any type. Keys and values should match those declared via Configuration for the given eventTypeName.

mapEventTypeName - - event type name

Throws:

com.espertech.esper.common.client.EPException - - when the processing of the event leads to an error

routeEventBean

public void routeEventBean(com.espertech.esper.common.client.EventBean theEvent)

Specified by:

routeEventBean in interface com.espertech.esper.common.internal.event.util.EPRuntimeEventProcessWrapped

route

public void route(com.espertech.esper.common.client.EventBean theEvent,
                  com.espertech.esper.common.internal.context.util.EPStatementHandle epStatementHandle,
                  boolean addToFront)

Specified by:

route in interface com.espertech.esper.common.internal.context.util.InternalEventRouteDest

processWrappedEvent

public void processWrappedEvent(com.espertech.esper.common.client.EventBean eventBean)

Specified by:

processWrappedEvent in interface com.espertech.esper.common.internal.event.util.EPRuntimeEventProcessWrapped

processThreadWorkQueue

public void processThreadWorkQueue()

Works off the thread's work queue.

Specified by:

processThreadWorkQueue in interface com.espertech.esper.common.internal.context.util.InternalEventRouteDest

processMatches

protected void processMatches(com.espertech.esper.common.client.EventBean theEvent)

processStatementScheduleMultiple

public static void processStatementScheduleMultiple(com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle handle,
                                                    Object callbackObject,
                                                    EPServicesContext services)

Processing multiple schedule matches for a statement.

Parameters:

handle - statement handle

callbackObject - object containing matches

services - runtime services

processStatementFilterMultiple

public void processStatementFilterMultiple(com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle handle,
                                           Object callbackList,
                                           com.espertech.esper.common.client.EventBean theEvent,
                                           long version,
                                           int filterFaultCount)

Processing multiple filter matches for a statement.

Parameters:

handle - statement handle

callbackList - object containing callbacks

theEvent - to process

version - filter version

filterFaultCount - filter fault count

processStatementFilterSingle

public void processStatementFilterSingle(com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle handle,
                                         com.espertech.esper.common.internal.context.util.EPStatementHandleCallbackFilter handleCallback,
                                         com.espertech.esper.common.client.EventBean theEvent,
                                         long version,
                                         int filterFaultCount)

Process a single match.

Parameters:

handle - statement

handleCallback - callback

theEvent - event to indicate

version - filter version

filterFaultCount - filter fault count

handleFilterFault

protected void handleFilterFault(com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle faultingHandle,
                                 com.espertech.esper.common.client.EventBean theEvent,
                                 int filterFaultCount)

dispatch

public void dispatch()

Dispatch events.

Specified by:

dispatch in interface com.espertech.esper.common.internal.context.util.InternalEventRouteDest

isExternalClockingEnabled

public boolean isExternalClockingEnabled()

Description copied from interface: EPEventServiceTimeControl

Returns true for external clocking, false for internal clocking.

Specified by:

isExternalClockingEnabled in interface EPEventServiceTimeControl

Returns:

clocking indicator

destroy

public void destroy()

Destroy for destroying an runtime instance: sets references to null and clears thread-locals

Specified by:

destroy in interface EPEventServiceSPI

initialize

public void initialize()

Specified by:

initialize in interface EPEventServiceSPI

clearCaches

public void clearCaches()

Specified by:

clearCaches in interface EPEventServiceSPI

setUnmatchedListener

public void setUnmatchedListener(UnmatchedListener listener)

Description copied from interface: EPEventService

Sets a listener to receive events that are unmatched by any statement.

Events that can be unmatched are all events that are send into a runtime via one of the sendEvent methods, or that have been generated via insert-into clause.

For an event to be unmatched by any statement, the event must not match any statement's event stream filter criteria (a where-clause is NOT a filter criteria for a stream, as below).

Note: In the following statement a MyEvent event does always match this statement's event stream filter criteria, regardless of the value of the 'quantity' property.

select * from MyEvent where quantity > 5

In the following statement only a MyEvent event with a 'quantity' property value of 5 or less does not match this statement's event stream filter criteria:

select * from MyEvent(quantity > 5)

For patterns, if no pattern sub-expression is active for such event, the event is also unmatched.

Specified by:

setUnmatchedListener in interface EPEventService

Parameters:

listener - is the listener to receive notification of unmatched events, or null to unregister a previously registered listener

getCurrentTime

public long getCurrentTime()

Description copied from interface: EPEventServiceTimeControl

Returns current engine time.

If time is provided externally via timer events, the function returns current time as externally provided.

Specified by:

getCurrentTime in interface EPEventServiceTimeControl

Returns:

current engine time

getRuntimeURI

public String getRuntimeURI()

Specified by:

getRuntimeURI in interface com.espertech.esper.common.internal.context.util.InternalEventRouteDest

processScheduleHandles

public void processScheduleHandles(com.espertech.esper.common.internal.collection.ArrayBackedCollection<com.espertech.esper.common.internal.schedule.ScheduleHandle> handles)

processStatementScheduleSingle

public static void processStatementScheduleSingle(com.espertech.esper.common.internal.context.util.EPStatementHandleCallbackSchedule handle,
                                                  EPServicesContext services)

Processing single schedule matche for a statement.

Parameters:

handle - statement handle

services - runtime services

routeEventMap

public void routeEventMap(Map<String,Object> map,
                          String eventTypeName)

Description copied from interface: EPEventServiceRouteEvent

Route the event object back to the runtime for internal dispatching, to avoid the possibility of a stack overflow due to nested calls to sendEvent. The route event is processed just like it was sent to the runtime, that is any active expressions seeking that event receive it. The routed event has priority over other events sent to the runtime. In a single-threaded application the routed event is processed before the next event is sent to the runtime.

Note: when outbound-threading is enabled, the thread delivering to listeners is not the thread processing the original event. Therefore with outbound-threading enabled the sendEvent method should be used by listeners instead.

Specified by:

routeEventMap in interface EPEventServiceRouteEvent

Parameters:

map - to route internally for processing by the runtime

eventTypeName - event type name

routeEventBean

public void routeEventBean(Object event,
                           String eventTypeName)

Description copied from interface: EPEventServiceRouteEvent

Route the event object back to the runtime for internal dispatching, to avoid the possibility of a stack overflow due to nested calls to sendEvent. The route event is processed just like it was sent to the runtime, that is any active expressions seeking that event receive it. The routed event has priority over other events sent to the runtime. In a single-threaded application the routed event is processed before the next event is sent to the runtime.

Note: when outbound-threading is enabled, the thread delivering to listeners is not the thread processing the original event. Therefore with outbound-threading enabled the sendEvent method should be used by listeners instead.

Specified by:

routeEventBean in interface EPEventServiceRouteEvent

Parameters:

event - to route internally for processing by the runtime

eventTypeName - event type name

routeEventObjectArray

public void routeEventObjectArray(Object[] event,
                                  String eventTypeName)

Description copied from interface: EPEventServiceRouteEvent

Route the event object back to the runtime for internal dispatching, to avoid the possibility of a stack overflow due to nested calls to sendEvent. The route event is processed just like it was sent to the runtime, that is any active expressions seeking that event receive it. The routed event has priority over other events sent to the runtime. In a single-threaded application the routed event is processed before the next event is sent to the runtime.

Note: when outbound-threading is enabled, the thread delivering to listeners is not the thread processing the original event. Therefore with outbound-threading enabled the sendEvent method should be used by listeners instead.

Specified by:

routeEventObjectArray in interface EPEventServiceRouteEvent

Parameters:

event - to route internally for processing by the runtime

eventTypeName - event type name

routeEventXMLDOM

public void routeEventXMLDOM(Node event,
                             String eventTypeName)

Description copied from interface: EPEventServiceRouteEvent

Route the event object back to the runtime for internal dispatching, to avoid the possibility of a stack overflow due to nested calls to sendEvent. The route event is processed just like it was sent to the runtime, that is any active expressions seeking that event receive it. The routed event has priority over other events sent to the runtime. In a single-threaded application the routed event is processed before the next event is sent to the runtime.

Note: when outbound-threading is enabled, the thread delivering to listeners is not the thread processing the original event. Therefore with outbound-threading enabled the sendEvent method should be used by listeners instead.

Specified by:

routeEventXMLDOM in interface EPEventServiceRouteEvent

Parameters:

event - to route internally for processing by the runtime

eventTypeName - event type name

routeEventAvro

public void routeEventAvro(Object avroGenericDataDotRecord,
                           String eventTypeName)

Description copied from interface: EPEventServiceRouteEvent

Route the event object back to the runtime for internal dispatching, to avoid the possibility of a stack overflow due to nested calls to sendEvent. The route event is processed just like it was sent to the runtime, that is any active expressions seeking that event receive it. The routed event has priority over other events sent to the runtime. In a single-threaded application the routed event is processed before the next event is sent to the runtime.

Note: when outbound-threading is enabled, the thread delivering to listeners is not the thread processing the original event. Therefore with outbound-threading enabled the sendEvent method should be used by listeners instead.

Specified by:

routeEventAvro in interface EPEventServiceRouteEvent

Parameters:

avroGenericDataDotRecord - to route internally for processing by the runtime

eventTypeName - event type name

getEventSender

public com.espertech.esper.common.client.EventSender getEventSender(String eventTypeName)
                                                             throws com.espertech.esper.common.client.EventTypeException

Description copied from interface: EPEventService

Returns a facility to process event objects that are of a known type.

Given an event type name this method returns a sender that allows to send in event objects of that type. The event objects send in via the event sender are expected to match the event type, thus the event sender does not inspect the event object other then perform basic checking.

For events backed by a Java class (JavaBean events), the sender ensures that the object send in matches in class, or implements or extends the class underlying the event type for the given event type name. Note that event type identity for Java class events is the Java class. When assigning two different event type names to the same Java class the names are an alias for the same event type i.e. there is always a single event type to represent a given Java class.

For events backed by a Object[] (Object-array events), the sender does not perform any checking other then checking that the event object indeed is an array of object.

For events backed by a java.util.Map (Map events), the sender does not perform any checking other then checking that the event object indeed implements Map.

For events backed by a org.w3c.Node (XML DOM events), the sender checks that the root element name indeed does match the root element name for the event type name.

Specified by:

getEventSender in interface EPEventService

Parameters:

eventTypeName - is the name of the event type

Returns:

sender for fast-access processing of event objects of known type (and content)

Throws:

com.espertech.esper.common.client.EventTypeException - thrown to indicate that the name does not exist

getStatementNearestSchedules

public Map<com.espertech.esper.common.internal.util.DeploymentIdNamePair,Long> getStatementNearestSchedules()

Specified by:

getStatementNearestSchedules in interface EPEventServiceSPI

clockInternal

public void clockInternal()

Description copied from interface: EPEventServiceTimeControl

Switches on the internal timer which tracks system time. There is no effect if the runtime is already on internal time.

Your application may not want to use EPEventServiceTimeControl.advanceTime(long), EPEventServiceTimeControl.advanceTimeSpan(long) or EPEventServiceTimeControl.advanceTimeSpan(long, long) after calling this method, since time advances according to JVM time.

Specified by:

clockInternal in interface EPEventServiceTimeControl

clockExternal

public void clockExternal()

Description copied from interface: EPEventServiceTimeControl

Switches off the internal timer which tracks system time. There is no effect if the runtime is already on external internal time.

Your application may want to use EPEventServiceTimeControl.advanceTime(long), EPEventServiceTimeControl.advanceTimeSpan(long) or EPEventServiceTimeControl.advanceTimeSpan(long, long) after calling this method to set or advance time.

Its generally preferable to turn off internal clocking (and thus turn on external clocking) by configuration ConfigurationRuntimeThreading.setInternalTimerEnabled(boolean) passing false.

Specified by:

clockExternal in interface EPEventServiceTimeControl

getNumEventsEvaluated

public long getNumEventsEvaluated()

Description copied from interface: EPEventService

Number of events evaluated over the lifetime of the event stream processing runtime, or since the last resetStats() call.

Specified by:

getNumEventsEvaluated in interface EPEventService

Returns:

number of events received

resetStats

public void resetStats()

Description copied from interface: EPEventService

Reset the count of the number of events received and emitted

Specified by:

resetStats in interface EPEventService