Modifier and Type | Method and Description |
---|---|
List<ExternalReferencedHolder> |
SiddhiAppContext.getExternalReferencedHolders() |
Modifier and Type | Method and Description |
---|---|
void |
SiddhiAppContext.addEternalReferencedHolder(ExternalReferencedHolder externalReferencedHolder) |
Modifier and Type | Class and Description |
---|---|
class |
QueryRuntimeImpl
Query Runtime represent holder object for a single Siddhi query and holds all runtime objects related to that query.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractStreamProcessor<S extends State>
Abstract implementation of
Processor intended to be used by any Stream Processors. |
class |
LogStreamProcessor
Input attributes to log is (priority (String), log.message (String), is.event.logged (Bool))
|
class |
StreamProcessor<S extends State>
For Siddhi extensions, extend this class to use the functionality of
AbstractStreamProcessor.
|
Modifier and Type | Class and Description |
---|---|
class |
Pol2CartStreamFunctionProcessor
Created on 1/26/15.
|
class |
StreamFunctionProcessor<S extends State>
Stream Processor to handle Stream Functions.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregateWindowProcessor
This is the
WindowProcessor intended to be used with aggregate join queries. |
class |
BatchingFindableWindowProcessor<S extends State>
Window to process events as batches while supporting event search
|
class |
BatchingWindowProcessor<S extends State>
Performs event processing in a tumbling manner
|
class |
BatchWindowProcessor
Implementation of
WindowProcessor which represent a Batch Window that aggregate batch of incoming events
together. |
class |
CronWindowProcessor
Implementation of
WindowProcessor which represent a Window operating based on a cron expression. |
class |
DelayWindowProcessor
Implementation of
WindowProcessor which represent a Window operating based on delay time. |
class |
EmptyWindowProcessor
Implementation of
WindowProcessor which represent a Batch Window operating based on pre-defined length 0. |
class |
ExpressionBatchWindowProcessor
Implementation of
WindowProcessor which represent a Window operating based on a expression. |
class |
ExpressionWindowProcessor
Implementation of
WindowProcessor which represent a Window operating based on a expression. |
class |
ExternalTimeBatchWindowProcessor
Implementation of
WindowProcessor which represent a Batch Window operating based on external time. |
class |
ExternalTimeWindowProcessor
Implementation of
WindowProcessor which represent a Window operating based on external time. |
class |
FrequentWindowProcessor
Deprecated.
|
class |
GroupingFindableWindowProcessor<S extends State>
Window that process event processing as a group while supporting event search
|
class |
GroupingWindowProcessor<S extends State>
Performs event processing with key based event groups
|
class |
HopingWindowProcessor<S extends State>
Performs event processing in a hopping manner
|
class |
LengthBatchWindowProcessor
Implementation of
WindowProcessor which represent a Batch Window operating based on pre-defined length. |
class |
LengthWindowProcessor
Implementation of
WindowProcessor which represent a Window operating based on a pre-defined length. |
class |
LossyFrequentWindowProcessor
Deprecated.
|
class |
SessionWindowProcessor
Implementation of
WindowProcessor which represent a Window operating based on a session. |
class |
SlidingFindableWindowProcessor<S extends State>
Performs event processing in a sliding manner while supporting event search
|
class |
SlidingWindowProcessor<S extends State>
Performs event processing in a sliding manner
|
class |
SortWindowProcessor
Sample Query:
from inputStream#window.sort(5, attribute1, "asc", attribute2, "desc")
select attribute1, attribute2
insert into outputStream;
|
class |
TableWindowProcessor
Implementation of
WindowProcessor which represent a Window operating based on Table . |
class |
TimeBatchWindowProcessor
Implementation of
WindowProcessor which represent a Batch Window operating based on time. |
class |
TimeLengthWindowProcessor
Implementation of
WindowProcessor which represent a Window operating based on pre-defined length. |
class |
TimeWindowProcessor
Implementation of
WindowProcessor which represent a Window operating based time. |
class |
WindowProcessor<S extends State>
Abstract parent implementation of Processor to represent Windows.
|
class |
WindowWindowProcessor
This is the
WindowProcessor intended to be used with window join queries. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractTrigger
Base class for the internal Trigger implementation
|
class |
CronTrigger
Implementation of
Trigger which will trigger events based on a cron expression. |
class |
PeriodicTrigger
Implementation of
Trigger which will trigger events based on a pre-defined period. |
class |
StartTrigger
Implementation of
Trigger which will trigger events when siddhi app in started. |
Modifier and Type | Class and Description |
---|---|
class |
Scheduler
Scheduler implementation to take periodic snapshots
|
Copyright © 2021. All rights reserved.