public class AndMultiPrimaryKeyCollectionExecutor extends Object implements CollectionExecutor
CollectionExecutor
CollectionExecutor.Cost
Constructor and Description |
---|
AndMultiPrimaryKeyCollectionExecutor(String compositePrimaryKey,
List<ExpressionExecutor> multiPrimaryKeyExpressionExecutors,
CacheTable cacheTable) |
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
|
String |
getCompositePrimaryKey() |
CollectionExecutor.Cost |
getDefaultCost() |
List<ExpressionExecutor> |
getMultiPrimaryKeyExpressionExecutors() |
public AndMultiPrimaryKeyCollectionExecutor(String compositePrimaryKey, List<ExpressionExecutor> multiPrimaryKeyExpressionExecutors, CacheTable cacheTable)
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 List<ExpressionExecutor> getMultiPrimaryKeyExpressionExecutors()
public Collection<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
public String getCompositePrimaryKey()
Copyright © 2021. All rights reserved.