Package | Description |
---|---|
io.siddhi.core.event.stream.converter | |
io.siddhi.core.query.output.callback | |
io.siddhi.core.table.holder |
Modifier and Type | Class and Description |
---|---|
class |
SelectiveStreamEventConverter
The converter class that converts the events into StreamEvent
|
class |
SimpleStreamEventConverter
The converter class that only converts the OutputData of the events to StreamEvent
|
class |
ZeroStreamEventConverter
The converter that does no conversion but only copy OutputData of the events into StreamEvents
|
Modifier and Type | Method and Description |
---|---|
static StreamEventConverter |
StreamEventConverterFactory.constructEventConverter(MetaStreamEvent metaStreamEvent) |
Constructor and Description |
---|
ConversionStreamEventChunk(StreamEventConverter streamEventConverter,
StreamEventFactory streamEventFactory) |
Modifier and Type | Method and Description |
---|---|
protected ComplexEventChunk<StateEvent> |
OutputCallback.constructMatchingStateEventChunk(ComplexEventChunk matchingComplexEventChunk,
boolean convertToStreamEvent,
StateEventFactory stateEventFactory,
int matchingStreamIndex,
StreamEventFactory streamEventFactory,
StreamEventConverter streamEventConverter) |
Constructor and Description |
---|
DeleteTableCallback(Table table,
CompiledCondition compiledCondition,
int matchingStreamIndex,
boolean convertToStreamEvent,
StateEventFactory stateEventFactory,
StreamEventFactory streamEventFactory,
StreamEventConverter streamEventConverter,
String queryName) |
InsertIntoTableCallback(Table table,
io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
boolean convertToStreamEvent,
StreamEventFactory streamEventFactory,
StreamEventConverter streamEventConverter,
String queryName) |
UpdateOrInsertTableCallback(Table table,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
int matchingStreamIndex,
boolean convertToStreamEvent,
StateEventFactory stateEventFactory,
StreamEventFactory streamEventFactory,
StreamEventConverter streamEventConverter,
String queryName) |
UpdateTableCallback(Table table,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
int matchingStreamIndex,
boolean convertToStreamEvent,
StateEventFactory stateEventFactory,
StreamEventFactory streamEventFactory,
StreamEventConverter streamEventConverter,
String queryName) |
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) |
IndexEventHolderForCache(StreamEventFactory tableStreamEventFactory,
StreamEventConverter eventConverter,
PrimaryKeyReferenceHolder[] primaryKeyReferenceHolders,
boolean isPrimaryNumeric,
Map<String,Integer> indexMetaData,
io.siddhi.query.api.definition.AbstractDefinition tableDefinition,
SiddhiAppContext siddhiAppContext) |
ListEventHolder(StreamEventFactory tableStreamEventFactory,
StreamEventConverter eventConverter,
StreamEventClonerHolder streamEventClonerHolder) |
Copyright © 2021. All rights reserved.