Modifier and Type | Method and Description |
---|---|
void |
IncrementalDataPurger.init(io.siddhi.query.api.definition.AggregationDefinition aggregationDefinition,
StreamEventFactory streamEventFactory,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTables,
Boolean isProcessingOnExternalTime,
SiddhiQueryContext siddhiQueryContext) |
Constructor and Description |
---|
BaseIncrementalValueStore(String aggregatorName,
long initialTimestamp,
List<ExpressionExecutor> expressionExecutors,
ExpressionExecutor shouldUpdateTimestamp,
StreamEventFactory streamEventFactory,
SiddhiQueryContext siddhiQueryContext,
boolean groupBy,
boolean local) |
Constructor and Description |
---|
StreamEventCloner(MetaStreamEvent metaStreamEvent,
StreamEventFactory eventFactory) |
Constructor and Description |
---|
ConversionStreamEventChunk(MetaStreamEvent metaStreamEvent,
StreamEventFactory streamEventFactory) |
ConversionStreamEventChunk(StreamEventConverter streamEventConverter,
StreamEventFactory streamEventFactory) |
FaultStreamEventConverter(StreamEventFactory streamEventFactory) |
Modifier and Type | Method and Description |
---|---|
void |
ProcessStreamReceiver.setStreamEventFactory(StreamEventFactory streamEventFactory) |
void |
MultiProcessStreamReceiver.setStreamEventFactory(StreamEventFactory streamEventFactory) |
Modifier and Type | Field and Description |
---|---|
protected StreamEventFactory |
StreamPreStateProcessor.streamEventFactory |
Modifier and Type | Method and Description |
---|---|
void |
StreamPreStateProcessor.setStreamEventFactory(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) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
Table.init(io.siddhi.query.api.definition.TableDefinition tableDefinition,
StreamEventFactory storeEventPool,
StreamEventCloner storeEventCloner,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext,
RecordTableHandler recordTableHandler) |
void |
InMemoryTable.init(io.siddhi.query.api.definition.TableDefinition tableDefinition,
StreamEventFactory storeEventPool,
StreamEventCloner storeEventCloner,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext,
RecordTableHandler recordTableHandler) |
void |
CacheTable.init(io.siddhi.query.api.definition.TableDefinition tableDefinition,
StreamEventFactory storeEventPool,
StreamEventCloner storeEventCloner,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext,
RecordTableHandler recordTableHandler) |
void |
Table.initTable(io.siddhi.query.api.definition.TableDefinition tableDefinition,
StreamEventFactory storeEventPool,
StreamEventCloner storeEventCloner,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext,
RecordTableHandler recordTableHandler) |
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) |
Modifier and Type | Field and Description |
---|---|
protected StreamEventFactory |
AbstractRecordTable.storeEventPool |
Modifier and Type | Method and Description |
---|---|
void |
AbstractRecordTable.init(io.siddhi.query.api.definition.TableDefinition tableDefinition,
StreamEventFactory storeEventPool,
StreamEventCloner storeEventCloner,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext,
RecordTableHandler recordTableHandler) |
Modifier and Type | Method and Description |
---|---|
void |
Scheduler.setStreamEventFactory(StreamEventFactory streamEventFactory) |
Modifier and Type | Method and Description |
---|---|
static EventHolder |
EventHolderPasser.parse(io.siddhi.query.api.definition.AbstractDefinition tableDefinition,
StreamEventFactory tableStreamEventFactory,
SiddhiAppContext siddhiAppContext,
boolean isCacheTable) |
Copyright © 2019. All rights reserved.