public class ExhaustiveCollectionExecutor extends Object implements CollectionExecutor
CollectionExecutor
CollectionExecutor.Cost
Constructor and Description |
---|
ExhaustiveCollectionExecutor(ExpressionExecutor expressionExecutor,
int storeEventIndex) |
Modifier and Type | Method and Description |
---|---|
boolean |
contains(StateEvent matchingEvent,
IndexedEventHolder indexedEventHolder)
Checks if a matching event exist in indexedEventHolder
|
void |
delete(StateEvent deletingEvent,
IndexedEventHolder indexedEventHolder)
Delete matching events exists from indexedEventHolder
|
StreamEvent |
find(StateEvent matchingEvent,
IndexedEventHolder indexedEventHolder,
StreamEventCloner storeEventCloner)
Find the Events matching to the condition, used on the primary call
|
Collection<StreamEvent> |
findEvents(StateEvent matchingEvent,
Collection<StreamEvent> preProcessedstoreEvents) |
Set<StreamEvent> |
findEvents(StateEvent matchingEvent,
IndexedEventHolder indexedEventHolder)
Find the Events matching to the condition, used for consecutive calls from parent CollectionExecutor
|
CollectionExecutor.Cost |
getDefaultCost() |
public ExhaustiveCollectionExecutor(ExpressionExecutor expressionExecutor, int storeEventIndex)
public StreamEvent find(StateEvent matchingEvent, IndexedEventHolder indexedEventHolder, StreamEventCloner storeEventCloner)
CollectionExecutor
find
in interface CollectionExecutor
matchingEvent
- matching input eventindexedEventHolder
- indexed EventHolder containing datastoreEventCloner
- store event clonerpublic Collection<StreamEvent> findEvents(StateEvent matchingEvent, Collection<StreamEvent> preProcessedstoreEvents)
public Set<StreamEvent> findEvents(StateEvent matchingEvent, IndexedEventHolder indexedEventHolder)
CollectionExecutor
findEvents
in interface CollectionExecutor
matchingEvent
- matching input eventindexedEventHolder
- indexed EventHolder containing datapublic boolean contains(StateEvent matchingEvent, IndexedEventHolder indexedEventHolder)
CollectionExecutor
contains
in interface CollectionExecutor
matchingEvent
- matching input eventindexedEventHolder
- indexed EventHolder containing datapublic void delete(StateEvent deletingEvent, IndexedEventHolder indexedEventHolder)
CollectionExecutor
delete
in interface CollectionExecutor
deletingEvent
- matching input eventindexedEventHolder
- indexed EventHolder containing datapublic CollectionExecutor.Cost getDefaultCost()
getDefaultCost
in interface CollectionExecutor
Copyright © 2021. All rights reserved.