| Package | Description |
|---|---|
| com.espertech.esper.common.client |
Common API: Classes that are generally relevant to both the compiler API and the processEvent API.
|
| com.espertech.esper.common.client.dataflow.core |
Client API for data flows.
|
| com.espertech.esper.common.client.fireandforget |
Classes related to fire-and-forget execution
|
| com.espertech.esper.common.client.hook.aggmultifunc |
Aggregation multi-function extension API for aggregation functions that hold events, share state and/or operate with tables.
|
| com.espertech.esper.common.client.hook.exception |
Callbacks for exception handling.
|
| com.espertech.esper.common.client.hook.expr |
Invocation contexts for external code.
|
| com.espertech.esper.common.client.hook.vdw |
Virtual data window extension API classes.
|
| com.espertech.esper.common.client.render |
Classes related to event rendering to JSON or XML format
|
| com.espertech.esper.common.client.scopetest |
Test framework classes.
|
| com.espertech.esper.common.client.serde |
Serdes are for serializing and de-serializing.
|
| com.espertech.esper.runtime.client |
Runtime API: Runs compiled EPL.
|
| com.espertech.esper.runtime.client.scopetest |
Runtime-related classes for facilitating automated regression testing.
|
| Modifier and Type | Method and Description |
|---|---|
EventBean |
EventBeanFactory.wrap(java.lang.Object underlying)
Wraps the underlying event object.
|
| Modifier and Type | Method and Description |
|---|---|
java.lang.Object |
EventPropertyValueGetter.get(EventBean eventBean)
Return the value for the property in the event object specified when the instance was obtained.
|
java.lang.Object |
EventPropertyGetterIndexed.get(EventBean eventBean,
int index)
Return the value for the property in the event object specified when the instance was obtained.
|
java.lang.Object |
EventPropertyGetterMapped.get(EventBean eventBean,
java.lang.String mapKey)
Return the value for the property in the event object specified when the instance was obtained.
|
java.lang.Object |
EventPropertyGetter.getFragment(EventBean eventBean)
|
boolean |
EventPropertyGetter.isExistsProperty(EventBean eventBean)
Returns true if the property exists, or false if the type does not have such a property.
|
| Modifier and Type | Method and Description |
|---|---|
EventBean |
EPDataFlowEventBeanCollectorContext.getEvent()
Returns the event to process.
|
EventBean[] |
EPDataFlowIRStreamCollectorContext.getNewEvents()
Returns insert stream.
|
EventBean[] |
EPDataFlowIRStreamCollectorContext.getOldEvents()
Returns remove stream.
|
| Modifier and Type | Method and Description |
|---|---|
void |
EPDataFlowEventBeanCollectorContext.setEvent(EventBean event)
Sets the event to process.
|
| Constructor and Description |
|---|
EPDataFlowEventBeanCollectorContext(com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowEmitter emitter,
boolean submitEventBean,
EventBean event)
Ctor.
|
EPDataFlowIRStreamCollectorContext(com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowEmitter emitter,
boolean submitEventBean,
EventBean[] newEvents,
EventBean[] oldEvents,
java.lang.Object statement,
java.lang.Object runtime)
Ctor.
|
EPDataFlowIRStreamCollectorContext(com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowEmitter emitter,
boolean submitEventBean,
EventBean[] newEvents,
EventBean[] oldEvents,
java.lang.Object statement,
java.lang.Object runtime)
Ctor.
|
| Modifier and Type | Method and Description |
|---|---|
EventBean[] |
EPFireAndForgetQueryResult.getArray()
Returns an array representing query result rows, may return a null value or empty array to indicate an empty result set.
|
| Modifier and Type | Method and Description |
|---|---|
java.util.Iterator<EventBean> |
EPFireAndForgetQueryResult.iterator()
Returns an iterator representing query result rows.
|
| Modifier and Type | Method and Description |
|---|---|
default EventBean |
AggregationMultiFunctionAccessor.getEnumerableEvent(AggregationMultiFunctionState state,
EventBean[] eventsPerStream,
boolean isNewData,
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
Return the aggregation state value consisting of a single event.
|
default EventBean |
AggregationMultiFunctionAggregationMethod.getValueEventBean(int aggColNum,
com.espertech.esper.common.internal.epl.agg.core.AggregationRow row,
EventBean[] eventsPerStream,
boolean isNewData,
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
Returns a single event or null when not available.
|
| Modifier and Type | Method and Description |
|---|---|
default java.util.Collection<EventBean> |
AggregationMultiFunctionAccessor.getEnumerableEvents(AggregationMultiFunctionState state,
EventBean[] eventsPerStream,
boolean isNewData,
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
Return the aggregation state value consisting of a collection of events.
|
| Modifier and Type | Method and Description |
|---|---|
void |
AggregationMultiFunctionState.applyEnter(EventBean[] eventsPerStream,
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
Enter an event.
|
void |
AggregationMultiFunctionAgent.applyEnter(EventBean[] eventsPerStream,
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext,
com.espertech.esper.common.internal.epl.agg.core.AggregationRow row,
int column)
Enter-into (add to) an aggregation
|
void |
AggregationMultiFunctionState.applyLeave(EventBean[] eventsPerStream,
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
Remove an event.
|
void |
AggregationMultiFunctionAgent.applyLeave(EventBean[] eventsPerStream,
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext,
com.espertech.esper.common.internal.epl.agg.core.AggregationRow row,
int column)
Leave-from (remove from) an aggregation
|
default EventBean |
AggregationMultiFunctionAccessor.getEnumerableEvent(AggregationMultiFunctionState state,
EventBean[] eventsPerStream,
boolean isNewData,
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
Return the aggregation state value consisting of a single event.
|
default java.util.Collection<EventBean> |
AggregationMultiFunctionAccessor.getEnumerableEvents(AggregationMultiFunctionState state,
EventBean[] eventsPerStream,
boolean isNewData,
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
Return the aggregation state value consisting of a collection of events.
|
default java.util.Collection<java.lang.Object> |
AggregationMultiFunctionAccessor.getEnumerableScalar(AggregationMultiFunctionState state,
EventBean[] eventsPerStream,
boolean isNewData,
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
Return the aggregation state value consisting of a collection of scalar values.
|
java.lang.Object |
AggregationMultiFunctionAccessor.getValue(AggregationMultiFunctionState state,
EventBean[] eventsPerStream,
boolean isNewData,
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
Return the aggregation state value either as a scalar value or any other object.
|
java.lang.Object |
AggregationMultiFunctionAggregationMethod.getValue(int aggColNum,
com.espertech.esper.common.internal.epl.agg.core.AggregationRow row,
EventBean[] eventsPerStream,
boolean isNewData,
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
Returns the plain value
|
default java.util.Collection |
AggregationMultiFunctionAggregationMethod.getValueCollectionEvents(int aggColNum,
com.espertech.esper.common.internal.epl.agg.core.AggregationRow row,
EventBean[] eventsPerStream,
boolean isNewData,
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
Return a collection of events or null when not available.
|
default java.util.Collection |
AggregationMultiFunctionAggregationMethod.getValueCollectionScalar(int aggColNum,
com.espertech.esper.common.internal.epl.agg.core.AggregationRow row,
EventBean[] eventsPerStream,
boolean isNewData,
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
Return a collection of values or null when not available.
|
default EventBean |
AggregationMultiFunctionAggregationMethod.getValueEventBean(int aggColNum,
com.espertech.esper.common.internal.epl.agg.core.AggregationRow row,
EventBean[] eventsPerStream,
boolean isNewData,
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
Returns a single event or null when not available.
|
| Modifier and Type | Method and Description |
|---|---|
EventBean |
ExceptionHandlerContext.getCurrentEvent()
Returns the current event, when available.
|
| Constructor and Description |
|---|
ExceptionHandlerContext(java.lang.String runtimeURI,
java.lang.Throwable throwable,
java.lang.String deploymentId,
java.lang.String statementName,
java.lang.String epl,
ExceptionHandlerExceptionType type,
EventBean currentEvent)
Ctor.
|
| Modifier and Type | Method and Description |
|---|---|
EventBean |
EventBeanService.adapterForAvro(java.lang.Object avroGenericDataDotRecord,
java.lang.String eventTypeName)
Construct an event bean for a given Avro GenericData.Record using the event type name to look up the Avro event type
|
EventBean |
EventBeanService.adapterForBean(java.lang.Object theEvent,
java.lang.String eventTypeName)
Construct an event bean for a given bean (Object, POJO) using the class of the object to determine the Bean-only event type (not for Map/Object-Array/Avro/XML events)
|
EventBean |
EventBeanService.adapterForDOM(org.w3c.dom.Node node,
java.lang.String eventTypeName)
Construct an event bean for a given XML-DOM using the node root node name to look up the XML-DOM event type
|
EventBean |
EventBeanService.adapterForMap(java.util.Map<java.lang.String,java.lang.Object> theEvent,
java.lang.String eventTypeName)
Construct an event bean for a given Map using the event type name to look up the Map event type
|
EventBean |
EventBeanService.adapterForObjectArray(java.lang.Object[] theEvent,
java.lang.String eventTypeName)
Construct an event bean for a given Object-Array using the event type name to look up the Object-Array event type
|
| Modifier and Type | Method and Description |
|---|---|
java.util.Iterator<EventBean> |
VirtualDataWindow.iterator()
This method is called when a consuming statement to the named window
receives initial state from the named window, for example "select sum(field) from MyVirtualDataWindow"
in order to initialize its state.
|
java.util.Set<EventBean> |
VirtualDataWindowLookup.lookup(java.lang.Object[] keys,
EventBean[] eventsPerStream)
Invoked by an EPL statement that queries a virtual data window to perform a lookup.
|
| Modifier and Type | Method and Description |
|---|---|
java.util.Set<EventBean> |
VirtualDataWindowLookup.lookup(java.lang.Object[] keys,
EventBean[] eventsPerStream)
Invoked by an EPL statement that queries a virtual data window to perform a lookup.
|
void |
VirtualDataWindowOutStream.update(EventBean[] newData,
EventBean[] oldData)
Post insert stream (new data) and remove stream (old data) events.
|
void |
VirtualDataWindowOutStream.update(EventBean[] newData,
EventBean[] oldData)
Post insert stream (new data) and remove stream (old data) events.
|
void |
VirtualDataWindow.update(EventBean[] newData,
EventBean[] oldData)
This method is invoked when events are inserted-into or removed-from the
virtual data window.
|
void |
VirtualDataWindow.update(EventBean[] newData,
EventBean[] oldData)
This method is invoked when events are inserted-into or removed-from the
virtual data window.
|
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
JSONEventRendererJsonEventType.render(EventBean theEvent) |
java.lang.String |
JSONEventRenderer.render(EventBean theEvent)
Render a given event in the JSON format.
|
java.lang.String |
XMLEventRenderer.render(java.lang.String rootElementName,
EventBean theEvent)
Render a given event in the XML format.
|
java.lang.String |
JSONEventRendererJsonEventType.render(java.lang.String title,
EventBean theEvent) |
java.lang.String |
JSONEventRenderer.render(java.lang.String title,
EventBean theEvent)
Render a given event in the JSON format.
|
java.lang.String |
EPRenderEventService.renderJSON(java.lang.String title,
EventBean theEvent)
Quick-access method to render a given event in the JSON format.
|
java.lang.String |
EPEventTypeRuntime.renderJSON(java.lang.String title,
EventBean theEvent)
Quick-access method to render a given event in the JSON format.
|
java.lang.String |
EPRenderEventService.renderJSON(java.lang.String title,
EventBean theEvent,
JSONRenderingOptions options)
Quick-access method to render a given event in the JSON format.
|
java.lang.String |
EPEventTypeRuntime.renderJSON(java.lang.String title,
EventBean theEvent,
JSONRenderingOptions options)
Quick-access method to render a given event in the JSON format.
|
java.lang.String |
EPRenderEventService.renderXML(java.lang.String rootElementName,
EventBean theEvent)
Quick-access method to render a given event in the XML format.
|
java.lang.String |
EPEventTypeRuntime.renderXML(java.lang.String rootElementName,
EventBean theEvent)
Quick-access method to render a given event in the XML format.
|
java.lang.String |
EPRenderEventService.renderXML(java.lang.String rootElementName,
EventBean theEvent,
XMLRenderingOptions options)
Quick-access method to render a given event in the XML format.
|
java.lang.String |
EPEventTypeRuntime.renderXML(java.lang.String rootElementName,
EventBean theEvent,
XMLRenderingOptions options)
Quick-access method to render a given event in the XML format.
|
| Modifier and Type | Method and Description |
|---|---|
static EventBean[] |
EPAssertionUtil.iteratorToArray(java.util.Iterator<EventBean> iterator)
Convert an iterator of event beans to an array of event beans.
|
static EventBean[] |
EPAssertionUtil.sort(EventBean[] events,
java.lang.String property)
Sort events according to natural ordering of the values or a property.
|
static EventBean[] |
EPAssertionUtil.sort(java.util.Iterator<EventBean> events,
java.lang.String property)
Sort events according to natural ordering of the values or a property.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
EPAssertionUtil.assertAllPropsSortedByName(EventBean received,
java.lang.Object[] expected)
Asserts that the property values of a single event, using property names as provided by the event type in sorted order by property name, match against the expected values.
|
static void |
EPAssertionUtil.assertEqualsAnyOrder(EventBean[][] expected,
EventBean[][] actual)
Compare two 2-dimensional event arrays.
|
static void |
EPAssertionUtil.assertEqualsAnyOrder(EventBean[][] expected,
EventBean[][] actual)
Compare two 2-dimensional event arrays.
|
static void |
EPAssertionUtil.assertEqualsExactOrder(EventBean[] expected,
java.util.Iterator<EventBean> actual)
Compare the iterator-returned events against the expected events
|
static void |
EPAssertionUtil.assertEqualsExactOrderUnderlying(java.lang.Object[] expected,
EventBean[] actual)
Comparing the underlying events to the expected events using equals-semantics.
|
static void |
EPAssertionUtil.assertNameValuePairs(EventBean[] lastData,
java.lang.Object[][] namesAndValues)
Assert that the event properties match the name-value pairs for each event
|
static void |
EPAssertionUtil.assertProps(EventBean received,
java.util.Map<java.lang.String,java.lang.Object> expected)
Assert that the event properties of the event match the properties provided by the map, taking the map properties as the comparison source.
|
static void |
EPAssertionUtil.assertProps(EventBean received,
java.lang.String[] propertyNames,
java.lang.Object[] expected)
Assert that the property values of a single event match the expected values.
|
static void |
EPAssertionUtil.assertPropsAllValuesSame(EventBean received,
java.lang.String[] propertyNames,
java.lang.Object expected)
Assert that all properties of an event have the same value as passed in.
|
static void |
EPAssertionUtil.assertPropsPerRow(EventBean[] received,
java.util.List<java.util.Map<java.lang.String,java.lang.Object>> expected)
Compare properties of events against a list of maps.
|
static void |
EPAssertionUtil.assertPropsPerRow(EventBean[] received,
java.lang.String[] propertyNames,
java.lang.Object[][] expected)
Compare the property values of events with the expected values, using exact-order semantics.
|
static void |
EPAssertionUtil.assertPropsPerRow(EventBean[] actual,
java.lang.String[] propertyNames,
java.lang.Object[][] expected,
java.lang.String streamName)
Compare the property values of events with the expected values, using exact-order semantics.
|
static void |
EPAssertionUtil.assertPropsPerRowAnyOrder(EventBean[] actual,
java.lang.String[] propertyNames,
java.lang.Object[][] expected)
Compare the property values of events with the expected values, using any-order semantics.
|
static boolean |
EPAssertionUtil.compareEqualsExactOrder(EventBean[] actual,
EventBean[] expected)
Compare the events in the two object arrays assuming the exact same order.
|
static boolean |
EPAssertionUtil.compareEqualsExactOrder(EventBean[] actual,
EventBean[] expected)
Compare the events in the two object arrays assuming the exact same order.
|
static java.lang.Object[] |
EPAssertionUtil.eventsToObjectArr(EventBean[] events,
java.lang.String propertyName)
Extract the property value of the event property for the given events and return an object array of values.
|
static java.lang.Object[][] |
EPAssertionUtil.eventsToObjectArr(EventBean[] events,
java.lang.String[] propertyNames)
Extract the property value of the event properties for the given events and return an object array of values.
|
static java.lang.Object[] |
EPAssertionUtil.getUnderlying(EventBean[] events)
Return an array of underlying objects for an array of events.
|
static EventBean[] |
EPAssertionUtil.sort(EventBean[] events,
java.lang.String property)
Sort events according to natural ordering of the values or a property.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
EPAssertionUtil.assertEqualsExactOrder(EventBean[] expected,
java.util.Iterator<EventBean> actual)
Compare the iterator-returned events against the expected events
|
static void |
EPAssertionUtil.assertEqualsExactOrderUnderlying(java.lang.Object[] expected,
java.util.Iterator<EventBean> actual)
Compare the underlying events returned by the iterator to the expected values.
|
static void |
EPAssertionUtil.assertProps(com.espertech.esper.common.internal.collection.UniformPair<EventBean> received,
java.lang.String[] propertyNames,
java.lang.Object[] expectedInsert,
java.lang.Object[] expectedRemoved)
Assert that the property values of a new event and a removed event match the expected insert and removed values.
|
static void |
EPAssertionUtil.assertPropsPerRow(java.util.Iterator<EventBean> iterator,
java.util.List<java.util.Map<java.lang.String,java.lang.Object>> expected)
Compare properties of events against a list of maps.
|
static void |
EPAssertionUtil.assertPropsPerRow(java.util.Iterator<EventBean> iterator,
SafeIterator<EventBean> safeIterator,
java.lang.String[] propertyNames,
java.lang.Object[][] expected)
Compare the property values returned by events of both iterators with the expected values, using exact-order semantics.
|
static void |
EPAssertionUtil.assertPropsPerRow(java.util.Iterator<EventBean> iterator,
SafeIterator<EventBean> safeIterator,
java.lang.String[] propertyNames,
java.lang.Object[][] expected)
Compare the property values returned by events of both iterators with the expected values, using exact-order semantics.
|
static void |
EPAssertionUtil.assertPropsPerRow(java.util.Iterator<EventBean> iterator,
java.lang.String[] propertyNames,
java.lang.Object[][] expected)
Compare the property values returned by events of both iterators with the expected values, using exact-order semantics.
|
static void |
EPAssertionUtil.assertPropsPerRowAnyOrder(java.util.Iterator<EventBean> iterator,
SafeIterator<EventBean> safeIterator,
java.lang.String[] propertyNames,
java.lang.Object[][] expected)
Compare the property values returned by events of both iterators with the expected values, using any-order semantics.
|
static void |
EPAssertionUtil.assertPropsPerRowAnyOrder(java.util.Iterator<EventBean> iterator,
SafeIterator<EventBean> safeIterator,
java.lang.String[] propertyNames,
java.lang.Object[][] expected)
Compare the property values returned by events of both iterators with the expected values, using any-order semantics.
|
static void |
EPAssertionUtil.assertPropsPerRowAnyOrder(java.util.Iterator<EventBean> iterator,
java.lang.String[] propertyNames,
java.lang.Object[][] expected)
Compare the property values returned by events of the iterator with the expected values, using any-order semantics.
|
static void |
EPAssertionUtil.assertPropsPerRowAnyOrder(SafeIterator<EventBean> safeIterator,
java.lang.String[] propertyNames,
java.lang.Object[][] expected)
Compare the property values returned by events of the iterator with the expected values, using any-order semantics.
|
static EventBean[] |
EPAssertionUtil.iteratorToArray(java.util.Iterator<EventBean> iterator)
Convert an iterator of event beans to an array of event beans.
|
static java.lang.Object[] |
EPAssertionUtil.iteratorToArrayUnderlying(java.util.Iterator<EventBean> iterator)
Convert an iterator of event beans to an array of underlying objects.
|
static java.lang.Object[] |
EPAssertionUtil.iteratorToObjectArr(java.util.Iterator<EventBean> iterator,
java.lang.String propertyName)
Extract the property value of the event property for the given events and return an object array of values.
|
static java.lang.Object[][] |
EPAssertionUtil.iteratorToObjectArr(java.util.Iterator<EventBean> iterator,
java.lang.String[] propertyNames)
Extract the property value of the event properties for the given events and return an object array of values.
|
static EventBean[] |
EPAssertionUtil.sort(java.util.Iterator<EventBean> events,
java.lang.String property)
Sort events according to natural ordering of the values or a property.
|
| Modifier and Type | Method and Description |
|---|---|
void |
EventBeanCollatedWriter.writeCollatedEvent(EventBean event,
java.io.DataOutput dataOutput,
byte[] pageFullKey)
Write event collated.
|
| Modifier and Type | Method and Description |
|---|---|
java.util.Iterator<EventBean> |
EPIterable.iterator()
Returns a concurrency-unsafe iterator over events representing statement results (pull API).
|
java.util.Iterator<EventBean> |
EPIterable.iterator(ContextPartitionSelector selector)
For use with statements that have a context declared and that may therefore have multiple context partitions,
allows to iterate over context partitions selectively.
|
SafeIterator<EventBean> |
EPIterable.safeIterator()
Returns a concurrency-safe iterator that iterates over events representing statement results (pull API)
in the face of concurrent event processing by further threads.
|
SafeIterator<EventBean> |
EPIterable.safeIterator(ContextPartitionSelector selector)
For use with statements that have a context declared and that may therefore have multiple context partitions,
allows to safe-iterate over context partitions selectively.
|
| Modifier and Type | Method and Description |
|---|---|
void |
UnmatchedListener.update(EventBean theEvent)
Called upon the runtimeencountering an event not matched to any of the event stream filters
of any active statement.
|
void |
UpdateListener.update(EventBean[] newEvents,
EventBean[] oldEvents,
EPStatement statement,
EPRuntime runtime)
Notify that new events are available or old events are removed.
|
void |
UpdateListener.update(EventBean[] newEvents,
EventBean[] oldEvents,
EPStatement statement,
EPRuntime runtime)
Notify that new events are available or old events are removed.
|
| Modifier and Type | Method and Description |
|---|---|
EventBean |
SupportUpdateListener.assertOneGetNew() |
EventBean |
SupportListener.assertOneGetNew()
Asserts that exactly one insert stream event was received not checking remove stream data, and returns the received event.
|
EventBean |
SupportUpdateListener.assertOneGetNewAndReset() |
EventBean |
SupportListener.assertOneGetNewAndReset()
Asserts that exactly one insert stream event was received and no remove stream events, resets the listener clearing all state and returns the received event.
|
EventBean |
SupportUpdateListener.assertOneGetOld() |
EventBean |
SupportListener.assertOneGetOld()
Asserts that exactly one remove stream event was received not checking insert stream data, and returns the received event.
|
EventBean |
SupportUpdateListener.assertOneGetOldAndReset() |
EventBean |
SupportListener.assertOneGetOldAndReset()
Asserts that exactly one remove stream event was received and no insert stream events, resets the listener clearing all state and returns the received event.
|
EventBean[] |
SupportUpdateListener.getAndResetLastNewData() |
EventBean[] |
SupportListener.getAndResetLastNewData()
Returns the last array of events (insert stream) that were received and resets the listener.
|
EventBean[] |
SupportUpdateListener.getAndResetLastOldData() |
EventBean[] |
SupportListener.getAndResetLastOldData()
Returns the last array of events (insert stream) that were received and resets the listener.
|
EventBean[] |
SupportUpdateListener.getLastNewData() |
EventBean[] |
SupportListener.getLastNewData()
Returns the last array of events (insert stream) that were received.
|
EventBean[] |
SupportUpdateListener.getLastOldData() |
EventBean[] |
SupportListener.getLastOldData()
Returns the last array of remove-stream events that were received.
|
EventBean[] |
SupportUpdateListener.getNewDataListFlattened() |
EventBean[] |
SupportListener.getNewDataListFlattened()
Returns an event array that represents all insert-stream events received so far.
|
EventBean[] |
SupportUpdateListener.getOldDataListFlattened()
Returns an event array that represents all remove-stream events received so far.
|
EventBean[] |
SupportListener.getOldDataListFlattened()
Returns an event array that represents all remove-stream events received so far.
|
| Modifier and Type | Method and Description |
|---|---|
com.espertech.esper.common.internal.collection.UniformPair<EventBean> |
SupportUpdateListener.assertGetAndResetIRPair() |
com.espertech.esper.common.internal.collection.UniformPair<EventBean> |
SupportListener.assertGetAndResetIRPair()
Asserts that there is exactly one insert-stream event and one remove-stream event available and resets.
|
com.espertech.esper.common.internal.collection.UniformPair<EventBean> |
SupportUpdateListener.assertPairGetIRAndReset() |
com.espertech.esper.common.internal.collection.UniformPair<EventBean> |
SupportListener.assertPairGetIRAndReset()
Asserts that exactly one insert stream event and exactly one remove stream event was received, resets the listener clearing all state and returns the received events as a pair.
|
| Modifier and Type | Method and Description |
|---|---|
void |
SupportUpdateListener.setLastNewData(EventBean[] lastNewData)
Set an array of events as the last insert-stream events received.
|
void |
SupportUpdateListener.setLastOldData(EventBean[] lastOldData)
Set an array of events as the last remove-stream events received.
|
void |
SupportUpdateListener.update(EventBean[] newData,
EventBean[] oldData,
EPStatement statement,
EPRuntime runtime) |
void |
SupportUpdateListener.update(EventBean[] newData,
EventBean[] oldData,
EPStatement statement,
EPRuntime runtime) |