Modifier and Type | Method and Description |
---|---|
StreamEventCloner |
StreamEventClonerHolder.getStreamEventCloner() |
Modifier and Type | Method and Description |
---|---|
void |
StreamEventClonerHolder.setStreamEventCloner(StreamEventCloner streamEventCloner) |
Constructor and Description |
---|
StreamEventClonerHolder(StreamEventCloner streamEventCloner) |
Modifier and Type | Field and Description |
---|---|
protected StreamEventCloner |
StreamPreStateProcessor.streamEventCloner |
Modifier and Type | Method and Description |
---|---|
void |
StreamPreStateProcessor.setStreamEventCloner(StreamEventCloner streamEventCloner) |
Modifier and Type | Field and Description |
---|---|
protected StreamEventCloner |
SnapshotOutputRateLimiter.streamEventCloner |
Modifier and Type | Method and Description |
---|---|
void |
SnapshotOutputRateLimiter.setStreamEventCloner(StreamEventCloner streamEventCloner) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
StreamProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
S state)
The main processing method that will be called upon event arrival
|
protected void |
LogStreamProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
State state) |
protected abstract void |
AbstractStreamProcessor.processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
S state)
The main processing method that will be called upon event arrival
|
protected void |
StreamProcessor.processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
S state) |
void |
AbstractStreamProcessor.setStreamEventCloner(StreamEventCloner streamEventCloner) |
Modifier and Type | Method and Description |
---|---|
protected void |
StreamFunctionProcessor.processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
S state) |
Modifier and Type | Method and Description |
---|---|
StreamEvent |
BatchWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.BatchWindowProcessor.WindowState state) |
StreamEvent |
ExternalTimeBatchWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.ExternalTimeBatchWindowProcessor.WindowState state) |
StreamEvent |
ExternalTimeWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.ExternalTimeWindowProcessor.WindowState state) |
StreamEvent |
FrequentWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.FrequentWindowProcessor.WindowState state)
Deprecated.
|
StreamEvent |
LengthBatchWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.LengthBatchWindowProcessor.WindowState state) |
StreamEvent |
LengthWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.LengthWindowProcessor.WindowState state) |
StreamEvent |
LossyFrequentWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.LossyFrequentWindowProcessor.WindowState state)
Deprecated.
|
abstract StreamEvent |
GroupingFindableWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
S state)
To find events from the processor event pool, that the matches the matchingEvent based on finder logic.
|
abstract StreamEvent |
SlidingFindableWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
S state)
To find events from the processor event pool, that the matches the matchingEvent based on finder logic.
|
abstract StreamEvent |
BatchingFindableWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
S state)
To find events from the processor event pool, that the matches the matchingEvent based on finder logic.
|
StreamEvent |
SessionWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.SessionWindowProcessor.WindowState state) |
StreamEvent |
SortWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.SortWindowProcessor.WindowState state) |
StreamEvent |
TimeBatchWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.TimeBatchWindowProcessor.WindowState state) |
StreamEvent |
TimeLengthWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.TimeLengthWindowProcessor.WindowState state) |
StreamEvent |
DelayWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.TimeWindowProcessor.WindowState state) |
StreamEvent |
TimeWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.TimeWindowProcessor.WindowState state) |
protected void |
BatchWindowProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.BatchWindowProcessor.WindowState state) |
protected void |
CronWindowProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.CronWindowProcessor.WindowState state) |
protected void |
ExternalTimeBatchWindowProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.ExternalTimeBatchWindowProcessor.WindowState state)
Here an assumption is taken:
Parameter: timestamp: The time which the window determines as current time and will act upon,
the value of this parameter should be monotonically increasing.
|
protected void |
ExternalTimeWindowProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.ExternalTimeWindowProcessor.WindowState state) |
protected void |
FrequentWindowProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.FrequentWindowProcessor.WindowState state)
Deprecated.
|
protected void |
LengthBatchWindowProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.LengthBatchWindowProcessor.WindowState state) |
protected void |
LengthWindowProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.LengthWindowProcessor.WindowState state) |
protected void |
LossyFrequentWindowProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.LossyFrequentWindowProcessor.WindowState state)
Deprecated.
|
protected abstract void |
BatchingWindowProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
S state)
The main processing method that will be called upon event arrival
|
protected abstract void |
SlidingWindowProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
S state)
The main processing method that will be called upon event arrival
|
protected void |
SortWindowProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.SortWindowProcessor.WindowState state) |
protected void |
TimeBatchWindowProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.TimeBatchWindowProcessor.WindowState state) |
protected void |
TimeLengthWindowProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.TimeLengthWindowProcessor.WindowState state) |
protected void |
DelayWindowProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.TimeWindowProcessor.WindowState windowState) |
protected void |
TimeWindowProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.TimeWindowProcessor.WindowState state) |
protected void |
TableWindowProcessor.process(ComplexEventChunk streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
State state) |
protected void |
AggregateWindowProcessor.process(ComplexEventChunk streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
State state) |
protected void |
BatchingWindowProcessor.processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
S state) |
protected void |
GroupingWindowProcessor.processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
S state) |
protected void |
SlidingWindowProcessor.processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
S state) |
protected void |
HopingWindowProcessor.processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
S state) |
protected abstract void |
GroupingWindowProcessor.processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
GroupingWindowProcessor.GroupingKeyPopulator groupingKeyPopulater,
S state)
The main processing method that will be called upon event arrival
|
protected void |
SessionWindowProcessor.processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
GroupingWindowProcessor.GroupingKeyPopulator groupingKeyPopulater,
io.siddhi.core.query.processor.stream.window.SessionWindowProcessor.WindowState state) |
protected abstract void |
HopingWindowProcessor.processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
HopingWindowProcessor.HopingTimestampPopulator hopingTimestampPopulator)
The main processing method that will be called upon event arrival
|
protected void |
WindowWindowProcessor.processEventChunk(ComplexEventChunk streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
State state) |
Modifier and Type | Method and Description |
---|---|
void |
InMemoryTable.init(io.siddhi.query.api.definition.TableDefinition tableDefinition,
StreamEventFactory storeEventPool,
StreamEventCloner storeEventCloner,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext,
RecordTableHandler recordTableHandler) |
protected abstract void |
Table.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) |
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 |
---|---|
StreamEvent |
CompareExhaustiveAndCollectionExecutor.find(StateEvent matchingEvent,
IndexedEventHolder indexedEventHolder,
StreamEventCloner storeEventCloner) |
StreamEvent |
NotCollectionExecutor.find(StateEvent matchingEvent,
IndexedEventHolder indexedEventHolder,
StreamEventCloner storeEventCloner) |
StreamEvent |
NonAndCollectionExecutor.find(StateEvent matchingEvent,
IndexedEventHolder indexedEventHolder,
StreamEventCloner storeEventCloner) |
StreamEvent |
AnyAndCollectionExecutor.find(StateEvent matchingEvent,
IndexedEventHolder indexedEventHolder,
StreamEventCloner storeEventCloner) |
StreamEvent |
OrCollectionExecutor.find(StateEvent matchingEvent,
IndexedEventHolder indexedEventHolder,
StreamEventCloner storeEventCloner) |
StreamEvent |
AndMultiPrimaryKeyCollectionExecutor.find(StateEvent matchingEvent,
IndexedEventHolder indexedEventHolder,
StreamEventCloner storeEventCloner) |
StreamEvent |
CollectionExecutor.find(StateEvent matchingEvent,
IndexedEventHolder indexedEventHolder,
StreamEventCloner storeEventCloner)
Find the Events matching to the condition, used on the primary call
|
StreamEvent |
ExhaustiveCollectionExecutor.find(StateEvent matchingEvent,
IndexedEventHolder indexedEventHolder,
StreamEventCloner storeEventCloner) |
StreamEvent |
CompareCollectionExecutor.find(StateEvent matchingEvent,
IndexedEventHolder indexedEventHolder,
StreamEventCloner storeEventCloner) |
StreamEvent |
NonCollectionExecutor.find(StateEvent matchingEvent,
IndexedEventHolder indexedEventHolder,
StreamEventCloner storeEventCloner) |
Modifier and Type | Method and Description |
---|---|
StreamEvent |
Operator.find(StateEvent matchingEvent,
Object storeEvents,
StreamEventCloner storeEventCloner) |
StreamEvent |
CollectionOperator.find(StateEvent matchingEvent,
Object storeEvents,
StreamEventCloner storeEventCloner) |
StreamEvent |
SnapshotableEventQueueOperator.find(StateEvent matchingEvent,
Object storeEvents,
StreamEventCloner storeEventCloner) |
StreamEvent |
EventChunkOperator.find(StateEvent matchingEvent,
Object storeEvents,
StreamEventCloner storeEventCloner) |
StreamEvent |
IndexOperator.find(StateEvent matchingEvent,
Object storeEvents,
StreamEventCloner storeEventCloner) |
StreamEvent |
MapOperator.find(StateEvent matchingEvent,
Object storeEvents,
StreamEventCloner storeEventCloner) |
Copyright © 2019. All rights reserved.