Uses of Interface
com.espertech.esper.common.client.EventBean
Packages that use 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
Methods in com.espertech.esper.common.client that return EventBeanModifier and TypeMethodDescriptionWraps the underlying event object.Methods in com.espertech.esper.common.client with parameters of type EventBeanModifier 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
Methods in com.espertech.esper.common.client.dataflow.core that return EventBeanModifier and TypeMethodDescriptionEPDataFlowEventBeanCollectorContext.getEvent()
Returns the event to process.EPDataFlowIRStreamCollectorContext.getNewEvents()
Returns insert stream.EPDataFlowIRStreamCollectorContext.getOldEvents()
Returns remove stream.Methods in com.espertech.esper.common.client.dataflow.core with parameters of type EventBeanModifier and TypeMethodDescriptionvoid
Sets the event to process.Constructors in com.espertech.esper.common.client.dataflow.core with parameters of type EventBeanModifierConstructorDescriptionEPDataFlowEventBeanCollectorContext
(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
Methods in com.espertech.esper.common.client.fireandforget that return EventBeanModifier and TypeMethodDescriptionEPFireAndForgetQueryResult.getArray()
Returns an array representing query result rows, may return a null value or empty array to indicate an empty result set.Methods in com.espertech.esper.common.client.fireandforget that return types with arguments of type EventBean -
Uses of EventBean in com.espertech.esper.common.client.hook.aggmultifunc
Methods in com.espertech.esper.common.client.hook.aggmultifunc that return EventBeanModifier 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.Methods in com.espertech.esper.common.client.hook.aggmultifunc that return types with arguments of type EventBeanModifier 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.Methods in com.espertech.esper.common.client.hook.aggmultifunc with parameters of type EventBeanModifier 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
Methods in com.espertech.esper.common.client.hook.exception that return EventBeanModifier and TypeMethodDescriptionExceptionHandlerContext.getCurrentEvent()
Returns the current event, when available.Constructors in com.espertech.esper.common.client.hook.exception with parameters of type EventBeanModifierConstructorDescriptionExceptionHandlerContext
(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
Methods in com.espertech.esper.common.client.hook.expr that return EventBeanModifier 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
Methods in com.espertech.esper.common.client.hook.vdw that return types with arguments of type EventBeanModifier 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.Methods in com.espertech.esper.common.client.hook.vdw with parameters of type EventBeanModifier 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
Methods in com.espertech.esper.common.client.render with parameters of type EventBeanModifier 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
Methods in com.espertech.esper.common.client.scopetest that return EventBeanModifier 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.Methods in com.espertech.esper.common.client.scopetest with parameters of type EventBeanModifier 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.Method parameters in com.espertech.esper.common.client.scopetest with type arguments of type EventBeanModifier 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
Methods in com.espertech.esper.common.client.serde with parameters of type EventBeanModifier and TypeMethodDescriptionvoid
EventBeanCollatedWriter.writeCollatedEvent
(EventBean event, DataOutput dataOutput, byte[] pageFullKey) Write event collated. -
Uses of EventBean in com.espertech.esper.runtime.client
Methods in com.espertech.esper.runtime.client that return types with arguments of type EventBeanModifier 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.Methods in com.espertech.esper.runtime.client with parameters of type EventBeanModifier 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
Methods in com.espertech.esper.runtime.client.scopetest that return EventBeanModifier 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.Methods in com.espertech.esper.runtime.client.scopetest that return types with arguments of type EventBeanModifier 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()
Methods in com.espertech.esper.runtime.client.scopetest with parameters of type EventBeanModifier 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)