public class SnapshotableEventQueueOperator extends Object implements Operator
Modifier and Type | Field and Description |
---|---|
protected ExpressionExecutor |
expressionExecutor |
protected int |
storeEventPosition |
Constructor and Description |
---|
SnapshotableEventQueueOperator(ExpressionExecutor expressionExecutor,
int storeEventPosition) |
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) |
ExpressionExecutor |
getExpressionExecutor() |
int |
getStoreEventPosition() |
ComplexEventChunk<StreamEvent> |
tryUpdate(ComplexEventChunk<StateEvent> updatingOrAddingEventChunk,
Object storeEvents,
InMemoryCompiledUpdateSet compiledUpdateSet,
AddingStreamEventExtractor addingStreamEventExtractor) |
void |
update(ComplexEventChunk<StateEvent> updatingEventChunk,
Object storeEvents,
InMemoryCompiledUpdateSet compiledUpdateSet) |
protected ExpressionExecutor expressionExecutor
protected int storeEventPosition
public SnapshotableEventQueueOperator(ExpressionExecutor expressionExecutor, int storeEventPosition)
public ExpressionExecutor getExpressionExecutor()
public int getStoreEventPosition()
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<StreamEvent> tryUpdate(ComplexEventChunk<StateEvent> updatingOrAddingEventChunk, Object storeEvents, InMemoryCompiledUpdateSet compiledUpdateSet, AddingStreamEventExtractor addingStreamEventExtractor)
Copyright © 2019. All rights reserved.