|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use EventBean | |
---|---|
net.esper.client | This package defines the central Esper Client APIs. |
net.esper.collection | Internal collection classes |
net.esper.core | Implementation of client package interfaces, glue code |
net.esper.eql.core | Contains EQL statement specification classes define the constructs that make up an EQL statement, such as the list of items in the select clause, the insert-into stream name and property names etc. |
net.esper.eql.expression | This package contains the EQL expression nodes that represent all expressions such as used in select clauses, group-by and having clauses, or order-by clauses |
net.esper.eql.join | Join process interfaces and glue code |
net.esper.eql.join.assemble | Outer join result set assembly code |
net.esper.eql.join.exec | Inner join execution |
net.esper.eql.join.rep | Outer join result set handling |
net.esper.eql.join.table | Indexes for views |
net.esper.eql.view | Internal processing views for output rate limiting, filtering and internal event routing |
net.esper.event | This package defines the Esper Client event API. |
net.esper.event.property | Parsers and business objects to handle nested, indexed, mapped or generally complex properties for use in JavaBean access |
net.esper.event.xml | |
net.esper.filter | Main switchboard filtering and routing of incoming events to interested statements is performed in this package. |
net.esper.indicator.jmx | Classes for indicating events through a JMX console |
net.esper.pattern | Pattern expression tree and pattern state objects, the later resembles pattern expression state for each active pattern instance |
net.esper.view | View infrastructure concerned with view creation and destroy, cloning and hooking views trees into filtering. |
net.esper.view.ext | Extension views that providing services such as sorting, which don't fit much into other categories. |
net.esper.view.internal | Internal management views for buffering view results and providing these to joins. |
net.esper.view.stat | Views computing statistical values. |
net.esper.view.std | Base service views that perform typical SQL-like functions such as unique, grouping, size, last etc. |
net.esper.view.window | Window views are in this package |
Uses of EventBean in net.esper.client |
---|
Methods in net.esper.client that return types with arguments of type EventBean | |
---|---|
Iterator<EventBean> |
EPIterable.iterator()
Returns an iterator over events. |
Methods in net.esper.client with parameters of type EventBean | |
---|---|
void |
UpdateListener.update(EventBean[] newEvents,
EventBean[] oldEvents)
Notify that new events are available or old events are removed. |
void |
UpdateListener.update(EventBean[] newEvents,
EventBean[] oldEvents)
Notify that new events are available or old events are removed. |
Uses of EventBean in net.esper.collection |
---|
Methods in net.esper.collection that return EventBean | |
---|---|
EventBean[] |
EventBuffer.getAndFlush()
Get the events currently buffered. |
EventBean |
TimeWindowIterator.next()
|
EventBean |
SingleEventIterator.next()
|
EventBean |
IterablesListIterator.next()
|
Methods in net.esper.collection that return types with arguments of type EventBean | |
---|---|
List<EventBean> |
TimeWindow.expireEvents(long expireBefore)
Return and remove events in time-slots earlier (less) then the timestamp passed in, returning the list of events expired. |
Iterator<EventBean> |
TimeWindow.iterator()
Returns event iterator. |
Methods in net.esper.collection with parameters of type EventBean | |
---|---|
void |
EventBuffer.add(EventBean[] events)
Add an event array to buffer. |
void |
TimeWindow.add(long timestamp,
EventBean bean)
Adds event to the time window for the specified timestamp. |
Constructors in net.esper.collection with parameters of type EventBean | |
---|---|
SingleEventIterator(EventBean eventBean)
Constructor, takes the single event to iterate over as a parameter. |
Constructor parameters in net.esper.collection with type arguments of type EventBean | |
---|---|
IterablesListIterator(List<Iterable<EventBean>> iterables)
Constructor - takes a list of Iterable that supply the iterators to iterate over. |
|
TimeWindowIterator(LinkedList<Pair<Long,LinkedList<EventBean>>> window)
Ctor. |
Uses of EventBean in net.esper.core |
---|
Methods in net.esper.core that return types with arguments of type EventBean | |
---|---|
Iterator<EventBean> |
UpdateDispatchView.iterator()
|
Iterator<EventBean> |
EPPatternStatementImpl.iterator()
|
Iterator<EventBean> |
EPEQLStatementImpl.iterator()
|
Methods in net.esper.core with parameters of type EventBean | |
---|---|
void |
PatternListenerDispatch.add(EventBean event)
Add an event to be dispatched. |
void |
InternalEventRouter.route(EventBean event)
Route the event such that the event is processed as required. |
void |
EPRuntimeImpl.route(EventBean event)
|
void |
UpdateDispatchView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
UpdateDispatchView.update(EventBean[] newData,
EventBean[] oldData)
|
Method parameters in net.esper.core with type arguments of type EventBean | |
---|---|
void |
EPPatternStatementImpl.matchFound(Map<String,EventBean> matchEvent)
|
Uses of EventBean in net.esper.eql.core |
---|
Methods in net.esper.eql.core that return EventBean | |
---|---|
protected static EventBean[] |
ResultSetProcessorSimple.applyOutputLimit(EventBean[] events,
boolean isOutputLimitLastOnly)
Applies the last/all event output limit clause. |
protected static EventBean[] |
ResultSetProcessorSimple.getSelectEventsHaving(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
EventBean[] events,
ExprNode optionalHavingNode,
boolean isOutputLimiting,
boolean isOutputLimitLastOnly)
Applies the select-clause to the given events returning the selected events. |
protected static EventBean[] |
ResultSetProcessorSimple.getSelectEventsHaving(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
Set<MultiKey<EventBean>> events,
ExprNode optionalHavingNode,
boolean isOutputLimiting,
boolean isOutputLimitLastOnly)
Applies the select-clause to the given events returning the selected events. |
protected static EventBean[] |
ResultSetProcessorSimple.getSelectEventsNoHaving(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
EventBean[] events,
boolean isOutputLimiting,
boolean isOutputLimitLastOnly)
Applies the select-clause to the given events returning the selected events. |
protected static EventBean[] |
ResultSetProcessorSimple.getSelectEventsNoHaving(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
Set<MultiKey<EventBean>> events,
boolean isOutputLimiting,
boolean isOutputLimitLastOnly)
Applies the select-clause to the given events returning the selected events. |
EventBean |
SelectExprProcessor.process(EventBean[] eventsPerStream)
Computes the select-clause results and returns an event of the result event type that contains, in it's properties, the selected items. |
EventBean |
SelectExprJoinWildcardProcessor.process(EventBean[] eventsPerStream)
|
EventBean |
SelectExprEvalProcessor.process(EventBean[] eventsPerStream)
|
EventBean[] |
OrderByProcessorSimple.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents)
|
EventBean[] |
OrderByProcessor.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents)
Sort the output events. |
EventBean[] |
OrderByProcessorSimple.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
MultiKey[] groupByKeys)
|
EventBean[] |
OrderByProcessor.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
MultiKey[] groupByKeys)
Sort the output events, using the provided group-by keys for evaluating grouped aggregation functions, and avoiding the cost of recomputing the keys. |
Methods in net.esper.eql.core that return types with arguments of type EventBean | |
---|---|
protected static Set<MultiKey<EventBean>> |
ResultSetProcessorSimple.applyOutputLimit(Set<MultiKey<EventBean>> eventSet,
boolean isOutputLimitLastOnly)
Applies the last/all event output limit clause. |
Methods in net.esper.eql.core with parameters of type EventBean | |
---|---|
void |
AggregationServiceNull.applyEnter(EventBean[] eventsPerStream,
MultiKey optionalGroupKeyPerRow)
|
void |
AggregationServiceGroupByImpl.applyEnter(EventBean[] eventsPerStream,
MultiKey groupByKey)
|
void |
AggregationServiceGroupAllImpl.applyEnter(EventBean[] eventsPerStream,
MultiKey optionalGroupKeyPerRow)
|
void |
AggregationService.applyEnter(EventBean[] eventsPerStream,
MultiKey optionalGroupKeyPerRow)
Apply events as entering a window (new events). |
void |
AggregationServiceNull.applyLeave(EventBean[] eventsPerStream,
MultiKey optionalGroupKeyPerRow)
|
void |
AggregationServiceGroupByImpl.applyLeave(EventBean[] eventsPerStream,
MultiKey groupByKey)
|
void |
AggregationServiceGroupAllImpl.applyLeave(EventBean[] eventsPerStream,
MultiKey optionalGroupKeyPerRow)
|
void |
AggregationService.applyLeave(EventBean[] eventsPerStream,
MultiKey optionalGroupKeyPerRow)
Apply events as leaving a window (old events). |
protected static EventBean[] |
ResultSetProcessorSimple.applyOutputLimit(EventBean[] events,
boolean isOutputLimitLastOnly)
Applies the last/all event output limit clause. |
protected static EventBean[] |
ResultSetProcessorSimple.getSelectEventsHaving(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
EventBean[] events,
ExprNode optionalHavingNode,
boolean isOutputLimiting,
boolean isOutputLimitLastOnly)
Applies the select-clause to the given events returning the selected events. |
protected static EventBean[] |
ResultSetProcessorSimple.getSelectEventsNoHaving(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
EventBean[] events,
boolean isOutputLimiting,
boolean isOutputLimitLastOnly)
Applies the select-clause to the given events returning the selected events. |
EventBean |
SelectExprProcessor.process(EventBean[] eventsPerStream)
Computes the select-clause results and returns an event of the result event type that contains, in it's properties, the selected items. |
EventBean |
SelectExprJoinWildcardProcessor.process(EventBean[] eventsPerStream)
|
EventBean |
SelectExprEvalProcessor.process(EventBean[] eventsPerStream)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorSimple.processViewResult(EventBean[] newData,
EventBean[] oldData)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorSimple.processViewResult(EventBean[] newData,
EventBean[] oldData)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorRowPerGroup.processViewResult(EventBean[] newData,
EventBean[] oldData)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorRowPerGroup.processViewResult(EventBean[] newData,
EventBean[] oldData)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorRowForAll.processViewResult(EventBean[] newData,
EventBean[] oldData)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorRowForAll.processViewResult(EventBean[] newData,
EventBean[] oldData)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorAggregateGrouped.processViewResult(EventBean[] newData,
EventBean[] oldData)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorAggregateGrouped.processViewResult(EventBean[] newData,
EventBean[] oldData)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorAggregateAll.processViewResult(EventBean[] newData,
EventBean[] oldData)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorAggregateAll.processViewResult(EventBean[] newData,
EventBean[] oldData)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessor.processViewResult(EventBean[] newData,
EventBean[] oldData)
For use by views posting their result, process the event rows that are entered and removed (new and old events). |
Pair<EventBean[],EventBean[]> |
ResultSetProcessor.processViewResult(EventBean[] newData,
EventBean[] oldData)
For use by views posting their result, process the event rows that are entered and removed (new and old events). |
EventBean[] |
OrderByProcessorSimple.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents)
|
EventBean[] |
OrderByProcessorSimple.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents)
|
EventBean[] |
OrderByProcessor.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents)
Sort the output events. |
EventBean[] |
OrderByProcessor.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents)
Sort the output events. |
EventBean[] |
OrderByProcessorSimple.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
MultiKey[] groupByKeys)
|
EventBean[] |
OrderByProcessorSimple.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
MultiKey[] groupByKeys)
|
EventBean[] |
OrderByProcessor.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
MultiKey[] groupByKeys)
Sort the output events, using the provided group-by keys for evaluating grouped aggregation functions, and avoiding the cost of recomputing the keys. |
EventBean[] |
OrderByProcessor.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
MultiKey[] groupByKeys)
Sort the output events, using the provided group-by keys for evaluating grouped aggregation functions, and avoiding the cost of recomputing the keys. |
Method parameters in net.esper.eql.core with type arguments of type EventBean | |
---|---|
protected static Set<MultiKey<EventBean>> |
ResultSetProcessorSimple.applyOutputLimit(Set<MultiKey<EventBean>> eventSet,
boolean isOutputLimitLastOnly)
Applies the last/all event output limit clause. |
protected static EventBean[] |
ResultSetProcessorSimple.getSelectEventsHaving(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
Set<MultiKey<EventBean>> events,
ExprNode optionalHavingNode,
boolean isOutputLimiting,
boolean isOutputLimitLastOnly)
Applies the select-clause to the given events returning the selected events. |
protected static EventBean[] |
ResultSetProcessorSimple.getSelectEventsNoHaving(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
Set<MultiKey<EventBean>> events,
boolean isOutputLimiting,
boolean isOutputLimitLastOnly)
Applies the select-clause to the given events returning the selected events. |
Pair<EventBean[],EventBean[]> |
ResultSetProcessorSimple.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorSimple.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorRowPerGroup.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorRowPerGroup.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorRowForAll.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorRowForAll.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorAggregateGrouped.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorAggregateGrouped.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorAggregateAll.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessorAggregateAll.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Pair<EventBean[],EventBean[]> |
ResultSetProcessor.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
For use by joins posting their result, process the event rows that are entered and removed (new and old events). |
Pair<EventBean[],EventBean[]> |
ResultSetProcessor.processJoinResult(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
For use by joins posting their result, process the event rows that are entered and removed (new and old events). |
Uses of EventBean in net.esper.eql.expression |
---|
Methods in net.esper.eql.expression with parameters of type EventBean | |
---|---|
Object |
ExprStaticMethodNode.evaluate(EventBean[] eventsPerStream)
|
Object |
ExprRelationalOpNode.evaluate(EventBean[] eventsPerStream)
|
Object |
ExprOrNode.evaluate(EventBean[] eventsPerStream)
|
Object |
ExprNotNode.evaluate(EventBean[] eventsPerStream)
|
Object |
ExprMinMaxRowNode.evaluate(EventBean[] eventsPerStream)
|
Object |
ExprMathNode.evaluate(EventBean[] eventsPerStream)
|
Object |
ExprInNode.evaluate(EventBean[] eventsPerStream)
|
Object |
ExprIdentNode.evaluate(EventBean[] eventsPerStream)
|
Object |
ExprEvaluator.evaluate(EventBean[] eventsPerStream)
Evaluate event tuple and return result. |
Object |
ExprEqualsNode.evaluate(EventBean[] eventsPerStream)
|
Object |
ExprConstantNode.evaluate(EventBean[] eventsPerStream)
|
Object |
ExprConcatNode.evaluate(EventBean[] eventsPerStream)
|
Object |
ExprCoalesceNode.evaluate(EventBean[] eventsPerStream)
|
Object |
ExprCaseNode.evaluate(EventBean[] eventsPerStream)
|
Object |
ExprBitWiseNode.evaluate(EventBean[] eventsPerStream)
|
Object |
ExprBetweenNode.evaluate(EventBean[] eventsPerStream)
|
Object |
ExprAndNode.evaluate(EventBean[] eventsPerStream)
|
Object |
ExprAggregateNode.evaluate(EventBean[] events)
|
Uses of EventBean in net.esper.eql.join |
---|
Methods in net.esper.eql.join that return types with arguments of type EventBean | |
---|---|
UniformPair<Set<MultiKey<EventBean>>> |
JoinSetComposerImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream)
|
UniformPair<Set<MultiKey<EventBean>>> |
JoinSetComposer.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream)
Return join tuple result set from new data and old data for each stream. |
Methods in net.esper.eql.join with parameters of type EventBean | |
---|---|
UniformPair<Set<MultiKey<EventBean>>> |
JoinSetComposerImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream)
|
UniformPair<Set<MultiKey<EventBean>>> |
JoinSetComposerImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream)
|
UniformPair<Set<MultiKey<EventBean>>> |
JoinSetComposer.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream)
Return join tuple result set from new data and old data for each stream. |
UniformPair<Set<MultiKey<EventBean>>> |
JoinSetComposer.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream)
Return join tuple result set from new data and old data for each stream. |
void |
JoinExecutionStrategyImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream)
|
void |
JoinExecutionStrategyImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream)
|
void |
JoinExecutionStrategy.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream)
Execute join. |
void |
JoinExecutionStrategy.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream)
Execute join. |
void |
QueryStrategy.lookup(EventBean[] lookupEvents,
Set<MultiKey<EventBean>> joinSet)
Look up events return tuples of joined events. |
void |
ExecNodeQueryStrategy.lookup(EventBean[] lookupEvents,
Set<MultiKey<EventBean>> joinSet)
|
Method parameters in net.esper.eql.join with type arguments of type EventBean | |
---|---|
protected static void |
JoinSetFilter.filter(ExprNode filterExprNode,
Set<MultiKey<EventBean>> events)
Filter event by applying the filter nodes evaluation method. |
void |
QueryStrategy.lookup(EventBean[] lookupEvents,
Set<MultiKey<EventBean>> joinSet)
Look up events return tuples of joined events. |
void |
ExecNodeQueryStrategy.lookup(EventBean[] lookupEvents,
Set<MultiKey<EventBean>> joinSet)
|
void |
JoinSetProcessor.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
Process join result set. |
void |
JoinSetProcessor.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
Process join result set. |
void |
JoinSetFilter.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
void |
JoinSetFilter.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
|
Uses of EventBean in net.esper.eql.join.assemble |
---|
Methods in net.esper.eql.join.assemble with parameters of type EventBean | |
---|---|
void |
CartesianProdAssemblyNode.ChildStreamResults.add(int fromStreamIndex,
EventBean[] row)
Add result from stream. |
void |
RootRequiredAssemblyNode.result(EventBean[] row,
int fromStreamNum,
EventBean myEvent,
Node myNode)
|
void |
RootRequiredAssemblyNode.result(EventBean[] row,
int fromStreamNum,
EventBean myEvent,
Node myNode)
|
void |
RootOptionalAssemblyNode.result(EventBean[] row,
int fromStreamNum,
EventBean myEvent,
Node myNode)
|
void |
RootOptionalAssemblyNode.result(EventBean[] row,
int fromStreamNum,
EventBean myEvent,
Node myNode)
|
void |
RootCartProdAssemblyNode.result(EventBean[] row,
int fromStreamNum,
EventBean myEvent,
Node myNode)
|
void |
RootCartProdAssemblyNode.result(EventBean[] row,
int fromStreamNum,
EventBean myEvent,
Node myNode)
|
void |
ResultAssembler.result(EventBean[] row,
int fromStreamNum,
EventBean myEvent,
Node myNode)
Publish a result row. |
void |
ResultAssembler.result(EventBean[] row,
int fromStreamNum,
EventBean myEvent,
Node myNode)
Publish a result row. |
void |
LeafAssemblyNode.result(EventBean[] row,
int streamNum,
EventBean myEvent,
Node myNode)
|
void |
LeafAssemblyNode.result(EventBean[] row,
int streamNum,
EventBean myEvent,
Node myNode)
|
void |
CartesianProdAssemblyNode.result(EventBean[] row,
int fromStreamNum,
EventBean myEvent,
Node myNode)
|
void |
CartesianProdAssemblyNode.result(EventBean[] row,
int fromStreamNum,
EventBean myEvent,
Node myNode)
|
void |
BranchRequiredAssemblyNode.result(EventBean[] row,
int fromStreamNum,
EventBean myEvent,
Node myNode)
|
void |
BranchRequiredAssemblyNode.result(EventBean[] row,
int fromStreamNum,
EventBean myEvent,
Node myNode)
|
void |
BranchOptionalAssemblyNode.result(EventBean[] row,
int fromStreamNum,
EventBean myEvent,
Node myNode)
|
void |
BranchOptionalAssemblyNode.result(EventBean[] row,
int fromStreamNum,
EventBean myEvent,
Node myNode)
|
Uses of EventBean in net.esper.eql.join.exec |
---|
Methods in net.esper.eql.join.exec that return types with arguments of type EventBean | |
---|---|
Set<EventBean> |
TableLookupStrategy.lookup(EventBean event)
Returns matched events for a event to look up for. |
Set<EventBean> |
IndexedTableLookupStrategy.lookup(EventBean event)
|
Set<EventBean> |
FullTableScanLookupStrategy.lookup(EventBean event)
|
Methods in net.esper.eql.join.exec with parameters of type EventBean | |
---|---|
Set<EventBean> |
TableLookupStrategy.lookup(EventBean event)
Returns matched events for a event to look up for. |
Set<EventBean> |
IndexedTableLookupStrategy.lookup(EventBean event)
|
Set<EventBean> |
FullTableScanLookupStrategy.lookup(EventBean event)
|
void |
TableOuterLookupExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
List<EventBean[]> result)
|
void |
TableOuterLookupExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
List<EventBean[]> result)
|
void |
TableLookupExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
List<EventBean[]> result)
|
void |
TableLookupExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
List<EventBean[]> result)
|
void |
NestedIterationExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
List<EventBean[]> result)
|
void |
NestedIterationExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
List<EventBean[]> result)
|
void |
LookupInstructionExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
List<EventBean[]> result)
|
void |
LookupInstructionExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
List<EventBean[]> result)
|
abstract void |
ExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
List<EventBean[]> result)
Process single event using the prefill events to compile lookup results. |
abstract void |
ExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
List<EventBean[]> result)
Process single event using the prefill events to compile lookup results. |
protected void |
NestedIterationExecNode.recursiveNestedJoin(EventBean lookupEvent,
int nestingOrderIndex,
EventBean[] currentPath,
List<EventBean[]> result)
Recursive method to run through all child nodes and, for each result set tuple returned by a child node, execute the inner child of the child node until there are no inner child nodes. |
protected void |
NestedIterationExecNode.recursiveNestedJoin(EventBean lookupEvent,
int nestingOrderIndex,
EventBean[] currentPath,
List<EventBean[]> result)
Recursive method to run through all child nodes and, for each result set tuple returned by a child node, execute the inner child of the child node until there are no inner child nodes. |
void |
LookupInstructionExecNode.MyResultAssembler.result(EventBean[] row,
int fromStreamNum,
EventBean myEvent,
Node myNode)
|
void |
LookupInstructionExecNode.MyResultAssembler.result(EventBean[] row,
int fromStreamNum,
EventBean myEvent,
Node myNode)
|
void |
LookupInstructionExecNode.MyResultAssembler.setResult(List<EventBean[]> result,
EventBean rootEvent)
Supplies the result list to which to add result rows. |
Uses of EventBean in net.esper.eql.join.rep |
---|
Methods in net.esper.eql.join.rep that return EventBean | |
---|---|
EventBean |
Cursor.getEvent()
Supplies current event. |
EventBean |
Node.getParentEvent()
Returns lookup event. |
Methods in net.esper.eql.join.rep that return types with arguments of type EventBean | |
---|---|
Set<EventBean> |
Node.getEvents()
Returns the results of the lookup. |
Methods in net.esper.eql.join.rep with parameters of type EventBean | |
---|---|
void |
Node.setParentEvent(EventBean parentEvent)
Set the parent lookup (from stream) event whose results (to stream) are stored. |
Method parameters in net.esper.eql.join.rep with type arguments of type EventBean | |
---|---|
void |
RepositoryImpl.addResult(Cursor cursor,
Set<EventBean> lookupResults,
int resultStream)
|
void |
Repository.addResult(Cursor cursor,
Set<EventBean> lookupResults,
int resultStream)
Add a lookup result. |
void |
Node.setEvents(Set<EventBean> events)
Store lookup results. |
Constructors in net.esper.eql.join.rep with parameters of type EventBean | |
---|---|
Cursor(EventBean event,
int stream,
Node node)
Ctor. |
|
RepositoryImpl(int rootStream,
EventBean rootEvent,
int numStreams)
Ctor. |
Uses of EventBean in net.esper.eql.join.table |
---|
Methods in net.esper.eql.join.table that return types with arguments of type EventBean | |
---|---|
Set<EventBean> |
UnindexedEventTable.getEventSet()
Returns events in table. |
Set<EventBean> |
PropertyIndexedEventTable.lookup(Object[] keys)
Returns the set of events that have the same property value as the given event. |
Methods in net.esper.eql.join.table with parameters of type EventBean | |
---|---|
void |
UnindexedEventTable.add(EventBean[] addEvents)
|
void |
PropertyIndexedEventTable.add(EventBean[] events)
Add an array of events. |
void |
EventTable.add(EventBean[] events)
Add events to table. |
void |
UnindexedEventTable.remove(EventBean[] removeEvents)
|
void |
PropertyIndexedEventTable.remove(EventBean[] events)
Remove events. |
void |
EventTable.remove(EventBean[] events)
Remove events from table. |
Uses of EventBean in net.esper.eql.view |
---|
Methods in net.esper.eql.view that return EventBean | |
---|---|
protected static EventBean[] |
FilterExprView.filterEvents(ExprEvaluator exprEvaluator,
EventBean[] events)
Filters events using the supplied evaluator. |
Methods in net.esper.eql.view that return types with arguments of type EventBean | |
---|---|
Iterator<EventBean> |
OutputProcessView.iterator()
|
Iterator<EventBean> |
IStreamRStreamSelectorView.iterator()
|
Iterator<EventBean> |
InternalRouteView.iterator()
|
Iterator<EventBean> |
FilterExprView.iterator()
|
Methods in net.esper.eql.view with parameters of type EventBean | |
---|---|
protected static EventBean[] |
FilterExprView.filterEvents(ExprEvaluator exprEvaluator,
EventBean[] events)
Filters events using the supplied evaluator. |
void |
OutputProcessView.update(EventBean[] newData,
EventBean[] oldData)
The update method is called if the view does not participate in a join. |
void |
OutputProcessView.update(EventBean[] newData,
EventBean[] oldData)
The update method is called if the view does not participate in a join. |
void |
IStreamRStreamSelectorView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
IStreamRStreamSelectorView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
InternalRouteView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
InternalRouteView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
FilterExprView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
FilterExprView.update(EventBean[] newData,
EventBean[] oldData)
|
Method parameters in net.esper.eql.view with type arguments of type EventBean | |
---|---|
void |
OutputProcessView.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
This process (update) method is for participation in a join. |
void |
OutputProcessView.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents)
This process (update) method is for participation in a join. |
Uses of EventBean in net.esper.event |
---|
Classes in net.esper.event that implement EventBean | |
---|---|
class |
CompositeEventBean
Event bean wrapper for events that consists of a Map of name tags as key values and event bean wrappers as value objects, for use by pattern expressions. |
Methods in net.esper.event that return EventBean | |
---|---|
EventBean |
EventAdapterServiceImpl.adapterForBean(Object event)
|
EventBean |
EventAdapterService.adapterForBean(Object event)
Wrap the native event returning an EventBean . |
EventBean |
BeanEventAdapter.adapterForBean(Object event)
Returns an adapter for the given Java Bean. |
EventBean |
EventAdapterServiceImpl.adapterForCompositeEvent(EventType eventType,
Map<String,EventBean> taggedEvents)
|
EventBean |
EventAdapterService.adapterForCompositeEvent(EventType eventType,
Map<String,EventBean> taggedEvents)
Creates a wrapper for a composite event type. |
EventBean |
EventAdapterServiceImpl.adapterForDOM(Node node)
|
EventBean |
EventAdapterService.adapterForDOM(Node node)
Returns an adapter for the XML DOM document that exposes it's data as event properties for use in statements. |
EventBean |
EventAdapterServiceImpl.adapterForMap(Map event,
String eventTypeAlias)
|
EventBean |
EventAdapterService.adapterForMap(Map event,
String eventTypeAlias)
Wrap the Map-type event returning an EventBean using the event type alias name
to identify the EventType that the event should carry. |
protected static EventBean[] |
EventBeanUtility.append(EventBean[] source,
EventBean[] append)
Append arrays. |
EventBean |
EventAdapterServiceImpl.createMapFromUnderlying(Map<String,EventBean> events,
EventType eventType)
|
EventBean |
EventAdapterService.createMapFromUnderlying(Map<String,EventBean> events,
EventType eventType)
Create an aggregate event wrapper bean from a set of named events stored in a Map. |
EventBean |
EventAdapterServiceImpl.createMapFromValues(Map<String,Object> properties,
EventType eventType)
|
EventBean |
EventAdapterService.createMapFromValues(Map<String,Object> properties,
EventType eventType)
Create an event wrapper bean from a set of event properties (name and value objectes) stored in a Map. |
static EventBean[] |
EventBeanUtility.flatten(Vector<EventBean[]> eventVector)
Flatten the vector of arrays to an array. |
static EventBean[] |
EventBeanUtility.toArray(List<EventBean> eventList)
Convert list of events to array, returning null for empty or null lists. |
Methods in net.esper.event with parameters of type EventBean | |
---|---|
protected static EventBean[] |
EventBeanUtility.append(EventBean[] source,
EventBean[] append)
Append arrays. |
protected static EventBean[] |
EventBeanUtility.append(EventBean[] source,
EventBean[] append)
Append arrays. |
Object |
ReflectionPropMethodGetter.get(EventBean obj)
|
Object |
ReflectionPropFieldGetter.get(EventBean obj)
|
Object |
EventPropertyGetter.get(EventBean eventBean)
Return the value for the property in the event object specified when the instance was obtained. |
Object |
CGLibPropertyGetter.get(EventBean obj)
|
static MultiKeyUntyped |
EventBeanUtility.getMultiKey(EventBean event,
EventPropertyGetter[] propertyGetters)
Returns Multikey instance for given event and getters. |
static Object[] |
EventBeanUtility.getPropertyArray(EventBean event,
EventPropertyGetter[] propertyGetters)
Returns object array containing property values of given properties, retrieved via EventPropertyGetter instances. |
static String |
EventBeanUtility.printEvent(EventBean event)
Format the event and return a string representation. |
Method parameters in net.esper.event with type arguments of type EventBean | |
---|---|
EventBean |
EventAdapterServiceImpl.adapterForCompositeEvent(EventType eventType,
Map<String,EventBean> taggedEvents)
|
EventBean |
EventAdapterService.adapterForCompositeEvent(EventType eventType,
Map<String,EventBean> taggedEvents)
Creates a wrapper for a composite event type. |
EventBean |
EventAdapterServiceImpl.createMapFromUnderlying(Map<String,EventBean> events,
EventType eventType)
|
EventBean |
EventAdapterService.createMapFromUnderlying(Map<String,EventBean> events,
EventType eventType)
Create an aggregate event wrapper bean from a set of named events stored in a Map. |
static EventBean[] |
EventBeanUtility.toArray(List<EventBean> eventList)
Convert list of events to array, returning null for empty or null lists. |
Constructor parameters in net.esper.event with type arguments of type EventBean | |
---|---|
CompositeEventBean(Map<String,EventBean> wrappedEvents,
EventType eventType)
Ctor. |
Uses of EventBean in net.esper.event.property |
---|
Methods in net.esper.event.property with parameters of type EventBean | |
---|---|
Object |
NestedPropertyGetter.get(EventBean eventBean)
|
Object |
KeyedMethodPropertyGetter.get(EventBean obj)
|
Object |
KeyedFastPropertyGetter.get(EventBean obj)
|
Object |
ArrayMethodPropertyGetter.get(EventBean obj)
|
Object |
ArrayFieldPropertyGetter.get(EventBean obj)
|
Object |
ArrayFastPropertyGetter.get(EventBean obj)
|
Uses of EventBean in net.esper.event.xml |
---|
Classes in net.esper.event.xml that implement EventBean | |
---|---|
class |
XMLEventBean
EventBean wrapper for XML documents. |
Methods in net.esper.event.xml with parameters of type EventBean | |
---|---|
Object |
XPathPropertyGetter.get(EventBean eventBean)
|
Uses of EventBean in net.esper.filter |
---|
Methods in net.esper.filter with parameters of type EventBean | |
---|---|
void |
FilterServiceImpl.evaluate(EventBean eventBean)
|
void |
FilterService.evaluate(EventBean event)
Finds matching filters to the event passed in and invokes their associated callback method. |
void |
FilterParamIndexRange.matchEvent(EventBean eventBean,
List<FilterCallback> matches)
|
void |
FilterParamIndexNotEquals.matchEvent(EventBean eventBean,
List<FilterCallback> matches)
|
void |
FilterParamIndexEquals.matchEvent(EventBean eventBean,
List<FilterCallback> matches)
|
void |
FilterParamIndexCompare.matchEvent(EventBean eventBean,
List<FilterCallback> matches)
|
void |
FilterCallbackSetNode.matchEvent(EventBean eventBean,
List<FilterCallback> matches)
Evaluate an event by asking each index to match the event. |
void |
EventTypeIndex.matchEvent(EventBean event,
List<FilterCallback> matches)
|
void |
EventEvaluator.matchEvent(EventBean event,
List<FilterCallback> matches)
Perform the matching of an event based on the event property values, adding any callbacks for matches found to the matches list. |
void |
FilterCallback.matchFound(EventBean event)
Indicate that an event was evaluated by the FilterService
which matches the filter specification FilterSpec associated with this callback. |
Uses of EventBean in net.esper.indicator.jmx |
---|
Methods in net.esper.indicator.jmx with parameters of type EventBean | |
---|---|
void |
JMXLastElementObserver.setLastValue(EventBean element)
Update JMX last element view with a new value. |
void |
JMXLastElementDynamicMBean.setLastValue(EventBean lastValue)
|
void |
JMXLastCubeElementDynamicMBean.setLastValue(EventBean element)
Set last element containing the cube information to render. |
void |
JMXLastEventIndicator.update(EventBean[] newData,
EventBean[] oldData)
|
void |
JMXLastEventIndicator.update(EventBean[] newData,
EventBean[] oldData)
|
Uses of EventBean in net.esper.pattern |
---|
Methods in net.esper.pattern that return EventBean | |
---|---|
EventBean |
MatchedEventMap.getMatchingEvent(String tag)
Returns a single event instance given the tag identifier, or null if the tag could not be located. |
Methods in net.esper.pattern that return types with arguments of type EventBean | |
---|---|
Hashtable<String,EventBean> |
MatchedEventMap.getMatchingEvents()
Returns a Hashtable containing the events where the key is the event tag string and the value is the event instance. |
Methods in net.esper.pattern with parameters of type EventBean | |
---|---|
void |
MatchedEventMap.add(String tag,
EventBean event)
Add an event to the collection identified by the given tag. |
void |
EvalFilterStateNode.matchFound(EventBean event)
|
Method parameters in net.esper.pattern with type arguments of type EventBean | |
---|---|
void |
PatternMatchCallback.matchFound(Map<String,EventBean> matchEvent)
Indicate matching events. |
Uses of EventBean in net.esper.view |
---|
Methods in net.esper.view that return types with arguments of type EventBean | |
---|---|
Iterator<EventBean> |
ZeroDepthStream.iterator()
|
Iterator<EventBean> |
EventCollection.iterator()
Allows iteration through all elements in this event collection. |
Methods in net.esper.view with parameters of type EventBean | |
---|---|
void |
ZeroDepthStream.insert(EventBean event)
|
void |
EventStream.insert(EventBean event)
Insert a new event onto the stream. |
void |
View.update(EventBean[] newData,
EventBean[] oldData)
Notify that data has been added or removed from the Viewable parent. |
void |
View.update(EventBean[] newData,
EventBean[] oldData)
Notify that data has been added or removed from the Viewable parent. |
void |
ViewSupport.updateChildren(EventBean[] newData,
EventBean[] oldData)
Updates all the children with new data. |
void |
ViewSupport.updateChildren(EventBean[] newData,
EventBean[] oldData)
Updates all the children with new data. |
protected static void |
ViewSupport.updateChildren(List<View> childViews,
EventBean[] newData,
EventBean[] oldData)
Updates all the children with new data. |
protected static void |
ViewSupport.updateChildren(List<View> childViews,
EventBean[] newData,
EventBean[] oldData)
Updates all the children with new data. |
Uses of EventBean in net.esper.view.ext |
---|
Methods in net.esper.view.ext that return EventBean | |
---|---|
EventBean |
SortWindowIterator.next()
|
Methods in net.esper.view.ext that return types with arguments of type EventBean | |
---|---|
Iterator<EventBean> |
SortWindowView.iterator()
|
Methods in net.esper.view.ext with parameters of type EventBean | |
---|---|
void |
SortWindowView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
SortWindowView.update(EventBean[] newData,
EventBean[] oldData)
|
Constructor parameters in net.esper.view.ext with type arguments of type EventBean | |
---|---|
SortWindowIterator(SortedMap<MultiKey,LinkedList<EventBean>> window)
Ctor. |
Uses of EventBean in net.esper.view.internal |
---|
Methods in net.esper.view.internal that return types with arguments of type EventBean | |
---|---|
Iterator<EventBean> |
BufferView.iterator()
|
Methods in net.esper.view.internal with parameters of type EventBean | |
---|---|
void |
BufferView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
BufferView.update(EventBean[] newData,
EventBean[] oldData)
|
Uses of EventBean in net.esper.view.stat |
---|
Methods in net.esper.view.stat that return types with arguments of type EventBean | |
---|---|
Iterator<EventBean> |
WeightedAverageView.iterator()
|
Iterator<EventBean> |
UnivariateStatisticsView.iterator()
|
Iterator<EventBean> |
MultiDimStatsView.iterator()
|
Iterator<EventBean> |
BaseBivariateStatisticsView.iterator()
|
Methods in net.esper.view.stat with parameters of type EventBean | |
---|---|
void |
WeightedAverageView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
WeightedAverageView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
UnivariateStatisticsView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
UnivariateStatisticsView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
MultiDimStatsView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
MultiDimStatsView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
BaseBivariateStatisticsView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
BaseBivariateStatisticsView.update(EventBean[] newData,
EventBean[] oldData)
|
Uses of EventBean in net.esper.view.std |
---|
Fields in net.esper.view.std declared as EventBean | |
---|---|
protected EventBean |
LastElementView.lastEvent
The last new element posted from a parent view. |
Methods in net.esper.view.std that return EventBean | |
---|---|
protected static EventBean |
AddPropertyValueView.addProperty(EventBean originalEvent,
String[] propertyNames,
Object[] propertyValues,
EventType targetEventType,
EventAdapterService eventAdapterService)
Add a property to the event passed in. |
Methods in net.esper.view.std that return types with arguments of type EventBean | |
---|---|
Iterator<EventBean> |
UniqueByPropertyView.iterator()
|
Iterator<EventBean> |
SizeView.iterator()
|
Iterator<EventBean> |
MergeView.iterator()
|
Iterator<EventBean> |
LastElementView.iterator()
|
Iterator<EventBean> |
GroupByView.iterator()
|
Iterator<EventBean> |
AddPropertyValueView.iterator()
|
Methods in net.esper.view.std with parameters of type EventBean | |
---|---|
protected static EventBean |
AddPropertyValueView.addProperty(EventBean originalEvent,
String[] propertyNames,
Object[] propertyValues,
EventType targetEventType,
EventAdapterService eventAdapterService)
Add a property to the event passed in. |
void |
UniqueByPropertyView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
UniqueByPropertyView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
SizeView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
SizeView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
MergeView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
MergeView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
LastElementView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
LastElementView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
GroupByView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
GroupByView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
AddPropertyValueView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
AddPropertyValueView.update(EventBean[] newData,
EventBean[] oldData)
|
Uses of EventBean in net.esper.view.window |
---|
Methods in net.esper.view.window that return types with arguments of type EventBean | |
---|---|
Iterator<EventBean> |
TimeWindowView.iterator()
|
Iterator<EventBean> |
TimeBatchView.iterator()
|
Iterator<EventBean> |
LengthWindowView.iterator()
|
Iterator<EventBean> |
ExternallyTimedWindowView.iterator()
|
Methods in net.esper.view.window with parameters of type EventBean | |
---|---|
void |
TimeWindowView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
TimeWindowView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
TimeBatchView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
TimeBatchView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
LengthWindowView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
LengthWindowView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
ExternallyTimedWindowView.update(EventBean[] newData,
EventBean[] oldData)
|
void |
ExternallyTimedWindowView.update(EventBean[] newData,
EventBean[] oldData)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |