public class IndexOperator extends Object implements Operator
Constructor and Description |
---|
IndexOperator(CollectionExecutor collectionExecutor,
String queryName) |
Modifier and Type | Method and Description |
---|---|
boolean |
contains(StateEvent matchingEvent,
Object storeEvents) |
void |
delete(ComplexEventChunk<StateEvent> deletingEventChunk,
Object storeEvents) |
StreamEvent |
find(StateEvent matchingEvent,
Object storeEvents,
StreamEventCloner storeEventCloner) |
CollectionExecutor |
getCollectionExecutor() |
protected void |
handleCachePolicyAttributeUpdate(StreamEvent streamEvent) |
ComplexEventChunk<StateEvent> |
tryUpdate(ComplexEventChunk<StateEvent> updatingOrAddingEventChunk,
Object storeEvents,
InMemoryCompiledUpdateSet compiledUpdateSet,
AddingStreamEventExtractor addingStreamEventExtractor) |
void |
update(ComplexEventChunk<StateEvent> updatingEventChunk,
Object storeEvents,
InMemoryCompiledUpdateSet compiledUpdateSet) |
protected String queryName
public IndexOperator(CollectionExecutor collectionExecutor, String queryName)
public CollectionExecutor getCollectionExecutor()
public StreamEvent find(StateEvent matchingEvent, Object storeEvents, StreamEventCloner storeEventCloner)
public boolean contains(StateEvent matchingEvent, Object storeEvents)
public void delete(ComplexEventChunk<StateEvent> deletingEventChunk, Object storeEvents)
public void update(ComplexEventChunk<StateEvent> updatingEventChunk, Object storeEvents, InMemoryCompiledUpdateSet compiledUpdateSet)
public ComplexEventChunk<StateEvent> tryUpdate(ComplexEventChunk<StateEvent> updatingOrAddingEventChunk, Object storeEvents, InMemoryCompiledUpdateSet compiledUpdateSet, AddingStreamEventExtractor addingStreamEventExtractor)
protected void handleCachePolicyAttributeUpdate(StreamEvent streamEvent)
Copyright © 2021. All rights reserved.