public interface CollectionExecutor
StateEvent
). These will be used
by in-memory table implementation.Modifier and Type | Interface and Description |
---|---|
static class |
CollectionExecutor.Cost
Enums to specify operation cost.
|
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,
IndexedEventHolder indexedEventHolder)
Find the Events matching to the condition, used for consecutive calls from parent CollectionExecutor
|
CollectionExecutor.Cost |
getDefaultCost() |
StreamEvent find(StateEvent matchingEvent, IndexedEventHolder indexedEventHolder, StreamEventCloner storeEventCloner)
matchingEvent
- matching input eventindexedEventHolder
- indexed EventHolder containing datastoreEventCloner
- store event clonerCollection<StreamEvent> findEvents(StateEvent matchingEvent, IndexedEventHolder indexedEventHolder)
matchingEvent
- matching input eventindexedEventHolder
- indexed EventHolder containing databoolean contains(StateEvent matchingEvent, IndexedEventHolder indexedEventHolder)
matchingEvent
- matching input eventindexedEventHolder
- indexed EventHolder containing datavoid delete(StateEvent deletingEvent, IndexedEventHolder indexedEventHolder)
deletingEvent
- matching input eventindexedEventHolder
- indexed EventHolder containing dataCollectionExecutor.Cost getDefaultCost()
Copyright © 2021. All rights reserved.