public class HazelcastPrimaryKeyOperator extends Object implements org.wso2.siddhi.core.util.collection.operator.Operator
Modifier and Type | Field and Description |
---|---|
protected int |
candidateEventPosition |
protected org.wso2.siddhi.core.executor.ExpressionExecutor |
expressionExecutor |
protected int |
indexPosition |
Constructor and Description |
---|
HazelcastPrimaryKeyOperator(org.wso2.siddhi.core.executor.ExpressionExecutor expressionExecutor,
int candidateEventPosition,
int indexPosition) |
Modifier and Type | Method and Description |
---|---|
org.wso2.siddhi.core.util.collection.operator.Finder |
cloneFinder(String key) |
boolean |
contains(org.wso2.siddhi.core.event.state.StateEvent matchingEvent,
Object candidateEvents) |
void |
delete(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.state.StateEvent> deletingEventChunk,
Object candidateEvents) |
org.wso2.siddhi.core.event.stream.StreamEvent |
find(org.wso2.siddhi.core.event.state.StateEvent matchingEvent,
Object candidateEvents,
org.wso2.siddhi.core.event.stream.StreamEventCloner candidateEventCloner) |
org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.stream.StreamEvent> |
overwriteOrAdd(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.state.StateEvent> overwritingOrAddingEventChunk,
Object candidateEvents,
org.wso2.siddhi.core.util.collection.UpdateAttributeMapper[] updateAttributeMappers,
org.wso2.siddhi.core.util.collection.OverwritingStreamEventExtractor overwritingStreamEventExtractor) |
void |
update(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.state.StateEvent> updatingEventChunk,
Object candidateEvents,
org.wso2.siddhi.core.util.collection.UpdateAttributeMapper[] updateAttributeMappers) |
protected final org.wso2.siddhi.core.executor.ExpressionExecutor expressionExecutor
protected final int candidateEventPosition
protected final int indexPosition
public HazelcastPrimaryKeyOperator(org.wso2.siddhi.core.executor.ExpressionExecutor expressionExecutor, int candidateEventPosition, int indexPosition)
public org.wso2.siddhi.core.util.collection.operator.Finder cloneFinder(String key)
cloneFinder
in interface org.wso2.siddhi.core.util.collection.operator.Finder
public org.wso2.siddhi.core.event.stream.StreamEvent find(org.wso2.siddhi.core.event.state.StateEvent matchingEvent, Object candidateEvents, org.wso2.siddhi.core.event.stream.StreamEventCloner candidateEventCloner)
find
in interface org.wso2.siddhi.core.util.collection.operator.Finder
public boolean contains(org.wso2.siddhi.core.event.state.StateEvent matchingEvent, Object candidateEvents)
contains
in interface org.wso2.siddhi.core.util.collection.operator.Finder
public void delete(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.state.StateEvent> deletingEventChunk, Object candidateEvents)
delete
in interface org.wso2.siddhi.core.util.collection.operator.Operator
public void update(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.state.StateEvent> updatingEventChunk, Object candidateEvents, org.wso2.siddhi.core.util.collection.UpdateAttributeMapper[] updateAttributeMappers)
update
in interface org.wso2.siddhi.core.util.collection.operator.Operator
public org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.stream.StreamEvent> overwriteOrAdd(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.state.StateEvent> overwritingOrAddingEventChunk, Object candidateEvents, org.wso2.siddhi.core.util.collection.UpdateAttributeMapper[] updateAttributeMappers, org.wso2.siddhi.core.util.collection.OverwritingStreamEventExtractor overwritingStreamEventExtractor)
overwriteOrAdd
in interface org.wso2.siddhi.core.util.collection.operator.Operator
Copyright © 2018 WSO2. All rights reserved.