Modifier and Type | Method and Description |
---|---|
StreamEvent |
QueryableProcessor.query(StateEvent matchingEvent,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection)
Deprecated.
|
StreamEvent |
QueryableProcessor.query(StateEvent matchingEvent,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
io.siddhi.query.api.definition.Attribute[] outputAttributes)
To find events from the processor event pool, that the matches the matchingEvent based on finder logic and
return them based on the defined selection.
|
Modifier and Type | Method and Description |
---|---|
void |
Source.ConnectionCallback.onError(ConnectionUnavailableException e) |
Modifier and Type | Method and Description |
---|---|
abstract void |
Source.connect(Source.ConnectionCallback connectionCallback)
Called to connect to the source backend for receiving events
|
void |
InMemorySource.connect(Source.ConnectionCallback connectionCallback) |
Modifier and Type | Method and Description |
---|---|
abstract void |
Sink.connect()
Called to connect to the backend before events are published
|
void |
LogSink.connect() |
void |
InMemorySink.connect() |
abstract void |
Sink.publish(Object payload,
DynamicOptions transportOptions)
Sending events via output transport
|
void |
LogSink.publish(Object payload,
DynamicOptions transportOptions) |
void |
InMemorySink.publish(Object payload,
DynamicOptions dynamicOptions) |
Modifier and Type | Method and Description |
---|---|
void |
DistributedTransport.publish(Object payload,
DynamicOptions transportOptions) |
abstract void |
DistributedTransport.publish(Object payload,
DynamicOptions transportOptions,
Integer destinationId) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
Table.add(ComplexEventChunk<StreamEvent> addingEventChunk) |
protected abstract void |
Table.connect() |
protected void |
InMemoryTable.connect() |
protected abstract boolean |
Table.contains(StateEvent matchingEvent,
CompiledCondition compiledCondition) |
protected abstract void |
Table.delete(ComplexEventChunk<StateEvent> deletingEventChunk,
CompiledCondition compiledCondition) |
protected abstract StreamEvent |
Table.find(CompiledCondition compiledCondition,
StateEvent matchingEvent) |
protected abstract void |
Table.update(ComplexEventChunk<StateEvent> updatingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet) |
protected abstract void |
Table.updateOrAdd(ComplexEventChunk<StateEvent> updateOrAddingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
AddingStreamEventExtractor addingStreamEventExtractor) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractRecordTable.add(ComplexEventChunk<StreamEvent> addingEventChunk) |
protected abstract void |
AbstractRecordTable.add(List<Object[]> records)
Add records to the Table
|
void |
RecordTableHandlerCallback.add(List<Object[]> records) |
void |
RecordTableHandler.add(long timestamp,
List<Object[]> records) |
abstract void |
RecordTableHandler.add(long timestamp,
List<Object[]> records,
RecordTableHandlerCallback recordTableHandlerCallback,
S state) |
boolean |
RecordTableHandler.contains(long timestamp,
Map<String,Object> containsConditionParameterMap,
CompiledCondition compiledCondition) |
abstract boolean |
RecordTableHandler.contains(long timestamp,
Map<String,Object> containsConditionParameterMap,
CompiledCondition compiledCondition,
RecordTableHandlerCallback recordTableHandlerCallback,
S state) |
protected abstract boolean |
AbstractRecordTable.contains(Map<String,Object> containsConditionParameterMap,
CompiledCondition compiledCondition)
Check if matching record exist
|
boolean |
RecordTableHandlerCallback.contains(Map<String,Object> containsConditionParameterMap,
CompiledCondition compiledCondition) |
boolean |
AbstractRecordTable.contains(StateEvent matchingEvent,
CompiledCondition compiledCondition) |
void |
AbstractRecordTable.delete(ComplexEventChunk<StateEvent> deletingEventChunk,
CompiledCondition compiledCondition) |
protected abstract void |
AbstractRecordTable.delete(List<Map<String,Object>> deleteConditionParameterMaps,
CompiledCondition compiledCondition)
Delete all matching records
|
void |
RecordTableHandlerCallback.delete(List<Map<String,Object>> deleteConditionParameterMaps,
CompiledCondition compiledCondition) |
void |
RecordTableHandler.delete(long timestamp,
List<Map<String,Object>> deleteConditionParameterMaps,
CompiledCondition compiledCondition) |
abstract void |
RecordTableHandler.delete(long timestamp,
List<Map<String,Object>> deleteConditionParameterMaps,
CompiledCondition compiledCondition,
RecordTableHandlerCallback recordTableHandlerCallback,
S state) |
StreamEvent |
AbstractRecordTable.find(CompiledCondition compiledCondition,
StateEvent matchingEvent) |
Iterator<Object[]> |
RecordTableHandler.find(long timestamp,
Map<String,Object> findConditionParameterMap,
CompiledCondition compiledCondition) |
abstract Iterator<Object[]> |
RecordTableHandler.find(long timestamp,
Map<String,Object> findConditionParameterMap,
CompiledCondition compiledCondition,
RecordTableHandlerCallback recordTableHandlerCallback,
S state) |
protected abstract RecordIterator<Object[]> |
AbstractRecordTable.find(Map<String,Object> findConditionParameterMap,
CompiledCondition compiledCondition)
Find records matching the compiled condition
|
RecordIterator<Object[]> |
RecordTableHandlerCallback.find(Map<String,Object> findConditionParameterMap,
CompiledCondition compiledCondition) |
Iterator<Object[]> |
RecordTableHandler.query(long timestamp,
Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection)
Deprecated.
|
Iterator<Object[]> |
RecordTableHandler.query(long timestamp,
Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
io.siddhi.query.api.definition.Attribute[] outputAttributes) |
abstract Iterator<Object[]> |
RecordTableHandler.query(long timestamp,
Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
io.siddhi.query.api.definition.Attribute[] outputAttributes,
RecordTableHandlerCallback recordTableHandlerCallback,
S state) |
abstract Iterator<Object[]> |
RecordTableHandler.query(long timestamp,
Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
RecordTableHandlerCallback recordTableHandlerCallback,
S state)
Deprecated.
|
Iterator<Object[]> |
RecordTableHandlerCallback.query(Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection)
Deprecated.
|
protected abstract RecordIterator<Object[]> |
AbstractQueryableRecordTable.query(Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
io.siddhi.query.api.definition.Attribute[] outputAttributes)
Query records matching the compiled condition and selection
|
Iterator<Object[]> |
RecordTableHandlerCallback.query(Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
io.siddhi.query.api.definition.Attribute[] outputAttributes) |
StreamEvent |
AbstractQueryableRecordTable.query(StateEvent matchingEvent,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection) |
StreamEvent |
AbstractQueryableRecordTable.query(StateEvent matchingEvent,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
io.siddhi.query.api.definition.Attribute[] outputAttributes) |
protected abstract void |
AbstractRecordTable.update(CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
Map<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps)
Update all matching records
|
void |
RecordTableHandlerCallback.update(CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
Map<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps) |
void |
AbstractRecordTable.update(ComplexEventChunk<StateEvent> updatingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet) |
void |
RecordTableHandler.update(long timestamp,
CompiledCondition compiledCondition,
List<Map<String,Object>> updateConditionParameterMaps,
LinkedHashMap<String,CompiledExpression> updateSetMap,
List<Map<String,Object>> updateSetParameterMaps) |
abstract void |
RecordTableHandler.update(long timestamp,
CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
LinkedHashMap<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps,
RecordTableHandlerCallback recordTableHandlerCallback,
S state) |
protected abstract void |
AbstractRecordTable.updateOrAdd(CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
Map<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps,
List<Object[]> addingRecords)
Try updating the records if they exist else add the records
|
void |
RecordTableHandlerCallback.updateOrAdd(CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
Map<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps,
List<Object[]> addingRecords) |
void |
AbstractRecordTable.updateOrAdd(ComplexEventChunk<StateEvent> updateOrAddingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
AddingStreamEventExtractor addingStreamEventExtractor) |
void |
RecordTableHandler.updateOrAdd(long timestamp,
CompiledCondition compiledCondition,
List<Map<String,Object>> updateConditionParameterMaps,
LinkedHashMap<String,CompiledExpression> updateSetMap,
List<Map<String,Object>> updateSetParameterMaps,
List<Object[]> addingRecords) |
abstract void |
RecordTableHandler.updateOrAdd(long timestamp,
CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
LinkedHashMap<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps,
List<Object[]> addingRecords,
RecordTableHandlerCallback recordTableHandlerCallback) |
Modifier and Type | Method and Description |
---|---|
void |
MultiClientDistributedSink.connect()
Will be called to connect to the backend before events are published
|
void |
SingleClientDistributedSink.connect()
Will be called to connect to the backend before events are published
|
void |
MultiClientDistributedSink.publish(Object payload,
DynamicOptions transportOptions,
Integer destinationId) |
void |
SingleClientDistributedSink.publish(Object payload,
DynamicOptions transportOptions,
Integer destinationId) |
Copyright © 2019. All rights reserved.