public class HazelcastPrimaryKeyEventHolder extends Object implements org.wso2.siddhi.core.table.holder.EventHolder, Map<Object,org.wso2.siddhi.core.event.stream.StreamEvent>
Constructor and Description |
---|
HazelcastPrimaryKeyEventHolder(com.hazelcast.core.IMap candidateDataMap,
org.wso2.siddhi.core.event.stream.StreamEventPool tableStreamEventPool,
org.wso2.siddhi.core.event.stream.converter.StreamEventConverter eventConverter,
int indexPosition,
String indexAttribute) |
Modifier and Type | Method and Description |
---|---|
void |
add(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.stream.StreamEvent> addingEventChunk) |
void |
clear() |
boolean |
containsKey(Object key) |
boolean |
containsValue(Object value) |
Set<Map.Entry<Object,org.wso2.siddhi.core.event.stream.StreamEvent>> |
entrySet() |
org.wso2.siddhi.core.event.stream.StreamEvent |
get(Object key) |
String |
getIndexAttribute() |
int |
getIndexPosition() |
boolean |
isEmpty() |
Set<Object> |
keySet() |
org.wso2.siddhi.core.event.stream.StreamEvent |
put(Object key,
org.wso2.siddhi.core.event.stream.StreamEvent value) |
void |
putAll(Map<?,? extends org.wso2.siddhi.core.event.stream.StreamEvent> m) |
org.wso2.siddhi.core.event.stream.StreamEvent |
remove(Object key) |
org.wso2.siddhi.core.event.stream.StreamEvent |
replace(Object key,
org.wso2.siddhi.core.event.stream.StreamEvent value) |
int |
size() |
Collection<org.wso2.siddhi.core.event.stream.StreamEvent> |
values() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
compute, computeIfAbsent, computeIfPresent, equals, forEach, getOrDefault, hashCode, merge, putIfAbsent, remove, replace, replaceAll
public HazelcastPrimaryKeyEventHolder(com.hazelcast.core.IMap candidateDataMap, org.wso2.siddhi.core.event.stream.StreamEventPool tableStreamEventPool, org.wso2.siddhi.core.event.stream.converter.StreamEventConverter eventConverter, int indexPosition, String indexAttribute)
public void add(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.stream.StreamEvent> addingEventChunk)
add
in interface org.wso2.siddhi.core.table.holder.EventHolder
public String getIndexAttribute()
public int getIndexPosition()
public int size()
public boolean isEmpty()
public boolean containsKey(Object key)
containsKey
in interface Map<Object,org.wso2.siddhi.core.event.stream.StreamEvent>
public boolean containsValue(Object value)
containsValue
in interface Map<Object,org.wso2.siddhi.core.event.stream.StreamEvent>
public org.wso2.siddhi.core.event.stream.StreamEvent get(Object key)
public org.wso2.siddhi.core.event.stream.StreamEvent put(Object key, org.wso2.siddhi.core.event.stream.StreamEvent value)
public org.wso2.siddhi.core.event.stream.StreamEvent replace(Object key, org.wso2.siddhi.core.event.stream.StreamEvent value)
public org.wso2.siddhi.core.event.stream.StreamEvent remove(Object key)
public void putAll(Map<?,? extends org.wso2.siddhi.core.event.stream.StreamEvent> m)
public void clear()
public Collection<org.wso2.siddhi.core.event.stream.StreamEvent> values()
Copyright © 2018 WSO2. All rights reserved.