public class HazelcastMapOperator
extends org.wso2.siddhi.core.util.collection.operator.MapOperator
Constructor and Description |
---|
HazelcastMapOperator(org.wso2.siddhi.core.executor.ExpressionExecutor expressionExecutor,
int candidateEventPosition) |
Modifier and Type | Method and Description |
---|---|
org.wso2.siddhi.core.util.collection.operator.Finder |
cloneFinder(String key) |
void |
delete(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.state.StateEvent> deletingEventChunk,
Object candidateEvents) |
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)
Called when updating the event table entries.
|
public HazelcastMapOperator(org.wso2.siddhi.core.executor.ExpressionExecutor expressionExecutor, int candidateEventPosition)
public org.wso2.siddhi.core.util.collection.operator.Finder cloneFinder(String key)
cloneFinder
in interface org.wso2.siddhi.core.util.collection.operator.Finder
cloneFinder
in class org.wso2.siddhi.core.util.collection.operator.MapOperator
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
delete
in class org.wso2.siddhi.core.util.collection.operator.MapOperator
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
update
in class org.wso2.siddhi.core.util.collection.operator.MapOperator
updatingEventChunk
- Event list that needs to be updated.candidateEvents
- Map of candidate events.updateAttributeMappers
- Mapping positions array.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
overwriteOrAdd
in class org.wso2.siddhi.core.util.collection.operator.MapOperator
Copyright © 2018 WSO2. All rights reserved.