Uses of Interface
com.espertech.esper.common.client.EventBean
Package
Description
Common API: Classes that are generally relevant to both the compiler API and the processEvent API.
Client API for data flows.
Classes related to fire-and-forget execution
Aggregation multi-function extension API for aggregation functions that hold events, share state and/or operate with tables.
Callbacks for exception handling.
Invocation contexts for external code.
Virtual data window extension API classes.
Classes related to event rendering to JSON or XML format
Test framework classes.
Serdes are for serializing and de-serializing.
Runtime API: Runs compiled EPL.
Runtime-related classes for facilitating automated regression testing.
-
Uses of EventBean in com.espertech.esper.common.client
Modifier and TypeMethodDescriptionWraps the underlying event object.Modifier and TypeMethodDescriptionReturn the value for the property in the event object specified when the instance was obtained.Return the value for the property in the event object specified when the instance was obtained.Return the value for the property in the event object specified when the instance was obtained.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. -
Uses of EventBean in com.espertech.esper.common.client.dataflow.core
Modifier and TypeMethodDescriptionEPDataFlowEventBeanCollectorContext.getEvent()
Returns the event to process.EPDataFlowIRStreamCollectorContext.getNewEvents()
Returns insert stream.EPDataFlowIRStreamCollectorContext.getOldEvents()
Returns remove stream.Modifier and TypeMethodDescriptionvoid
Sets the event to process.ModifierConstructorDescriptionEPDataFlowEventBeanCollectorContext
(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, Object statement, Object runtime) Ctor. -
Uses of EventBean in com.espertech.esper.common.client.fireandforget
Modifier and TypeMethodDescriptionEPFireAndForgetQueryResult.getArray()
Returns an array representing query result rows, may return a null value or empty array to indicate an empty result set. -
Uses of EventBean in com.espertech.esper.common.client.hook.aggmultifunc
Modifier and TypeMethodDescriptiondefault 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 TypeMethodDescriptiondefault 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 TypeMethodDescriptionvoid
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 aggregationvoid
AggregationMultiFunctionState.applyEnter
(EventBean[] eventsPerStream, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext) Enter 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 aggregationvoid
AggregationMultiFunctionState.applyLeave
(EventBean[] eventsPerStream, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext) Remove an event.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 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 Collection<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.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.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 valuedefault 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 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. -
Uses of EventBean in com.espertech.esper.common.client.hook.exception
Modifier and TypeMethodDescriptionExceptionHandlerContext.getCurrentEvent()
Returns the current event, when available.ModifierConstructorDescriptionExceptionHandlerContext
(String runtimeURI, Throwable throwable, String deploymentId, String statementName, String epl, ExceptionHandlerExceptionType type, EventBean currentEvent) Ctor. -
Uses of EventBean in com.espertech.esper.common.client.hook.expr
Modifier and TypeMethodDescriptionEventBeanService.adapterForAvro
(Object avroGenericDataDotRecord, String eventTypeName) Construct an event bean for a given Avro GenericData.Record using the event type name to look up the Avro event typeEventBeanService.adapterForBean
(Object theEvent, 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)EventBeanService.adapterForDOM
(Node node, String eventTypeName) Construct an event bean for a given XML-DOM using the node root node name to look up the XML-DOM event typeEventBeanService.adapterForMap
(Map<String, Object> theEvent, String eventTypeName) Construct an event bean for a given Map using the event type name to look up the Map event typeEventBeanService.adapterForObjectArray
(Object[] theEvent, String eventTypeName) Construct an event bean for a given Object-Array using the event type name to look up the Object-Array event type -
Uses of EventBean in com.espertech.esper.common.client.hook.vdw
Modifier and TypeMethodDescriptionVirtualDataWindow.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.Invoked by an EPL statement that queries a virtual data window to perform a lookup.Modifier and TypeMethodDescriptionInvoked by an EPL statement that queries a virtual data window to perform a lookup.void
This method is invoked when events are inserted-into or removed-from the virtual data window.void
Post insert stream (new data) and remove stream (old data) events. -
Uses of EventBean in com.espertech.esper.common.client.render
Modifier and TypeMethodDescriptionRender a given event in the JSON format.Render a given event in the JSON format.Render a given event in the XML format.EPEventTypeRuntime.renderJSON
(String title, EventBean theEvent) Quick-access method to render a given event in the JSON format.EPEventTypeRuntime.renderJSON
(String title, EventBean theEvent, JSONRenderingOptions options) Quick-access method to render a given event in the JSON format.EPRenderEventService.renderJSON
(String title, EventBean theEvent) Quick-access method to render a given event in the JSON format.EPRenderEventService.renderJSON
(String title, EventBean theEvent, JSONRenderingOptions options) Quick-access method to render a given event in the JSON format.Quick-access method to render a given event in the XML format.EPEventTypeRuntime.renderXML
(String rootElementName, EventBean theEvent, XMLRenderingOptions options) Quick-access method to render a given event in the XML format.Quick-access method to render a given event in the XML format.EPRenderEventService.renderXML
(String rootElementName, EventBean theEvent, XMLRenderingOptions options) Quick-access method to render a given event in the XML format. -
Uses of EventBean in com.espertech.esper.common.client.scopetest
Modifier and TypeMethodDescriptionstatic EventBean[]
EPAssertionUtil.iteratorToArray
(Iterator<EventBean> iterator) Convert an iterator of event beans to an array of event beans.static EventBean[]
Sort events according to natural ordering of the values or a property.static EventBean[]
Sort events according to natural ordering of the values or a property.Modifier and TypeMethodDescriptionstatic void
EPAssertionUtil.assertAllPropsSortedByName
(EventBean received, 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.assertEqualsExactOrder
(EventBean[] expected, Iterator<EventBean> actual) Compare the iterator-returned events against the expected eventsstatic void
EPAssertionUtil.assertEqualsExactOrderUnderlying
(Object[] expected, EventBean[] actual) Comparing the underlying events to the expected events using equals-semantics.static void
EPAssertionUtil.assertNameValuePairs
(EventBean[] lastData, Object[][] namesAndValues) Assert that the event properties match the name-value pairs for each eventstatic void
EPAssertionUtil.assertProps
(EventBean received, String[] propertyNames, Object[] expected) Assert that the property values of a single event match the expected values.static void
EPAssertionUtil.assertProps
(EventBean received, Map<String, 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.assertPropsAllValuesSame
(EventBean received, String[] propertyNames, Object expected) Assert that all properties of an event have the same value as passed in.static void
EPAssertionUtil.assertPropsPerRow
(EventBean[] received, String[] propertyNames, Object[][] expected) Compare the property values of events with the expected values, using exact-order semantics.static void
EPAssertionUtil.assertPropsPerRow
(EventBean[] actual, String[] propertyNames, Object[][] expected, String streamName) Compare the property values of events with the expected values, using exact-order semantics.static void
Compare properties of events against a list of maps.static void
EPAssertionUtil.assertPropsPerRowAnyOrder
(EventBean[] actual, String[] propertyNames, 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 Object[]
EPAssertionUtil.eventsToObjectArr
(EventBean[] events, String propertyName) Extract the property value of the event property for the given events and return an object array of values.static Object[][]
EPAssertionUtil.eventsToObjectArr
(EventBean[] events, String[] propertyNames) Extract the property value of the event properties for the given events and return an object array of values.static Object[]
EPAssertionUtil.getUnderlying
(EventBean[] events) Return an array of underlying objects for an array of events.static EventBean[]
Sort events according to natural ordering of the values or a property.Modifier and TypeMethodDescriptionstatic void
EPAssertionUtil.assertEqualsExactOrder
(EventBean[] expected, Iterator<EventBean> actual) Compare the iterator-returned events against the expected eventsstatic void
EPAssertionUtil.assertEqualsExactOrderUnderlying
(Object[] expected, 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, String[] propertyNames, Object[] expectedInsert, 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
(Iterator<EventBean> iterator, SafeIterator<EventBean> safeIterator, String[] propertyNames, Object[][] expected) Compare the property values returned by events of both iterators with the expected values, using exact-order semantics.static void
EPAssertionUtil.assertPropsPerRow
(Iterator<EventBean> iterator, SafeIterator<EventBean> safeIterator, String[] propertyNames, Object[][] expected) Compare the property values returned by events of both iterators with the expected values, using exact-order semantics.static void
EPAssertionUtil.assertPropsPerRow
(Iterator<EventBean> iterator, String[] propertyNames, Object[][] expected) Compare the property values returned by events of both iterators with the expected values, using exact-order semantics.static void
Compare properties of events against a list of maps.static void
EPAssertionUtil.assertPropsPerRowAnyOrder
(SafeIterator<EventBean> safeIterator, String[] propertyNames, Object[][] expected) Compare the property values returned by events of the iterator with the expected values, using any-order semantics.static void
EPAssertionUtil.assertPropsPerRowAnyOrder
(Iterator<EventBean> iterator, SafeIterator<EventBean> safeIterator, String[] propertyNames, Object[][] expected) Compare the property values returned by events of both iterators with the expected values, using any-order semantics.static void
EPAssertionUtil.assertPropsPerRowAnyOrder
(Iterator<EventBean> iterator, SafeIterator<EventBean> safeIterator, String[] propertyNames, Object[][] expected) Compare the property values returned by events of both iterators with the expected values, using any-order semantics.static void
EPAssertionUtil.assertPropsPerRowAnyOrder
(Iterator<EventBean> iterator, String[] propertyNames, Object[][] expected) Compare the property values returned by events of the iterator with the expected values, using any-order semantics.static EventBean[]
EPAssertionUtil.iteratorToArray
(Iterator<EventBean> iterator) Convert an iterator of event beans to an array of event beans.static Object[]
EPAssertionUtil.iteratorToArrayUnderlying
(Iterator<EventBean> iterator) Convert an iterator of event beans to an array of underlying objects.static Object[]
EPAssertionUtil.iteratorToObjectArr
(Iterator<EventBean> iterator, String propertyName) Extract the property value of the event property for the given events and return an object array of values.static Object[][]
EPAssertionUtil.iteratorToObjectArr
(Iterator<EventBean> iterator, String[] propertyNames) Extract the property value of the event properties for the given events and return an object array of values.static EventBean[]
Sort events according to natural ordering of the values or a property. -
Uses of EventBean in com.espertech.esper.common.client.serde
Modifier and TypeMethodDescriptionvoid
EventBeanCollatedWriter.writeCollatedEvent
(EventBean event, DataOutput dataOutput, byte[] pageFullKey) Write event collated. -
Uses of EventBean in com.espertech.esper.runtime.client
Modifier and TypeMethodDescriptionEPIterable.iterator()
Returns a concurrency-unsafe iterator over events representing statement results (pull API).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.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.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 TypeMethodDescriptionvoid
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. -
Uses of EventBean in com.espertech.esper.runtime.client.scopetest
Modifier and TypeMethodDescriptionSupportListener.assertOneGetNew()
Asserts that exactly one insert stream event was received not checking remove stream data, and returns the received event.SupportUpdateListener.assertOneGetNew()
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.SupportUpdateListener.assertOneGetNewAndReset()
SupportListener.assertOneGetOld()
Asserts that exactly one remove stream event was received not checking insert stream data, and returns the received event.SupportUpdateListener.assertOneGetOld()
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.SupportUpdateListener.assertOneGetOldAndReset()
SupportListener.getAndResetLastNewData()
Returns the last array of events (insert stream) that were received and resets the listener.SupportUpdateListener.getAndResetLastNewData()
SupportListener.getAndResetLastOldData()
Returns the last array of events (insert stream) that were received and resets the listener.SupportUpdateListener.getAndResetLastOldData()
SupportListener.getLastNewData()
Returns the last array of events (insert stream) that were received.SupportUpdateListener.getLastNewData()
SupportListener.getLastOldData()
Returns the last array of remove-stream events that were received.SupportUpdateListener.getLastOldData()
SupportListener.getNewDataListFlattened()
Returns an event array that represents all insert-stream events received so far.SupportUpdateListener.getNewDataListFlattened()
SupportListener.getOldDataListFlattened()
Returns an event array that represents all remove-stream events received so far.SupportUpdateListener.getOldDataListFlattened()
Returns an event array that represents all remove-stream events received so far.Modifier and TypeMethodDescriptioncom.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.com.espertech.esper.common.internal.collection.UniformPair<EventBean>
SupportUpdateListener.assertPairGetIRAndReset()
Modifier and TypeMethodDescriptionvoid
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)