public class IndexEventHolder extends Object implements IndexedEventHolder, Serializable
Modifier and Type | Field and Description |
---|---|
protected Map<String,TreeMap<Object,Set<StreamEvent>>> |
indexData |
protected String |
primaryKeyAttributes |
protected Map<Object,StreamEvent> |
primaryKeyData |
Constructor and Description |
---|
IndexEventHolder(StreamEventFactory tableStreamEventFactory,
StreamEventConverter eventConverter,
PrimaryKeyReferenceHolder[] primaryKeyReferenceHolders,
boolean isPrimaryNumeric,
Map<String,Integer> indexMetaData,
io.siddhi.query.api.definition.AbstractDefinition tableDefinition,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
void |
add(ComplexEventChunk<StreamEvent> addingEventChunk) |
boolean |
containsEventSet(String attribute,
io.siddhi.query.api.expression.condition.Compare.Operator operator,
Object value) |
void |
delete(String attribute,
io.siddhi.query.api.expression.condition.Compare.Operator operator,
Object value) |
void |
deleteAll() |
void |
deleteAll(Collection<StreamEvent> storeEventSet) |
void |
deleteEvent(Object key) |
Collection<StreamEvent> |
findEvents(String attribute,
io.siddhi.query.api.expression.condition.Compare.Operator operator,
Object value) |
Collection<StreamEvent> |
getAllEvents() |
Set<Object> |
getAllPrimaryKeyValues() |
StreamEvent |
getEvent(Object key) |
PrimaryKeyReferenceHolder[] |
getPrimaryKeyReferenceHolders() |
Snapshot |
getSnapshot() |
protected void |
handleCachePolicyAttributeUpdate(StreamEvent streamEvent) |
boolean |
isAttributeIndexed(int position) |
boolean |
isAttributeIndexed(String attribute) |
boolean |
isMultiPrimaryKeyAttribute(String attributeName) |
void |
overwrite(StreamEvent streamEvent) |
void |
replace(Object key,
StreamEvent streamEvent) |
void |
restore(SnapshotStateList snapshotStatelist) |
int |
size() |
protected final Map<Object,StreamEvent> primaryKeyData
protected String primaryKeyAttributes
public IndexEventHolder(StreamEventFactory tableStreamEventFactory, StreamEventConverter eventConverter, PrimaryKeyReferenceHolder[] primaryKeyReferenceHolders, boolean isPrimaryNumeric, Map<String,Integer> indexMetaData, io.siddhi.query.api.definition.AbstractDefinition tableDefinition, SiddhiAppContext siddhiAppContext)
public void replace(Object key, StreamEvent streamEvent)
public Set<Object> getAllPrimaryKeyValues()
getAllPrimaryKeyValues
in interface IndexedEventHolder
public PrimaryKeyReferenceHolder[] getPrimaryKeyReferenceHolders()
getPrimaryKeyReferenceHolders
in interface IndexedEventHolder
public boolean isMultiPrimaryKeyAttribute(String attributeName)
isMultiPrimaryKeyAttribute
in interface IndexedEventHolder
public boolean isAttributeIndexed(String attribute)
isAttributeIndexed
in interface IndexedEventHolder
public boolean isAttributeIndexed(int position)
isAttributeIndexed
in interface IndexedEventHolder
public void add(ComplexEventChunk<StreamEvent> addingEventChunk)
add
in interface EventHolder
protected void handleCachePolicyAttributeUpdate(StreamEvent streamEvent)
public void overwrite(StreamEvent streamEvent)
overwrite
in interface IndexedEventHolder
public Collection<StreamEvent> getAllEvents()
getAllEvents
in interface IndexedEventHolder
public StreamEvent getEvent(Object key)
public void deleteEvent(Object key)
public Collection<StreamEvent> findEvents(String attribute, io.siddhi.query.api.expression.condition.Compare.Operator operator, Object value)
findEvents
in interface IndexedEventHolder
public void deleteAll()
deleteAll
in interface EventHolder
deleteAll
in interface IndexedEventHolder
public void deleteAll(Collection<StreamEvent> storeEventSet)
deleteAll
in interface IndexedEventHolder
public void delete(String attribute, io.siddhi.query.api.expression.condition.Compare.Operator operator, Object value)
delete
in interface IndexedEventHolder
public boolean containsEventSet(String attribute, io.siddhi.query.api.expression.condition.Compare.Operator operator, Object value)
containsEventSet
in interface IndexedEventHolder
public Snapshot getSnapshot()
getSnapshot
in interface EventHolder
public void restore(SnapshotStateList snapshotStatelist)
restore
in interface EventHolder
public int size()
size
in interface EventHolder
Copyright © 2019. All rights reserved.