Package | Description |
---|---|
io.siddhi.core.query.input.stream.join | |
io.siddhi.core.query.processor.stream.window | |
io.siddhi.core.table | |
io.siddhi.core.table.record | |
io.siddhi.core.window |
Modifier and Type | Method and Description |
---|---|
void |
JoinProcessor.setFindableProcessor(FindableProcessor findableProcessor) |
Modifier and Type | Interface and Description |
---|---|
interface |
QueryableProcessor
Interface for all processors which holds a collection of events and supports traversing and finding events from
that collection with different selection criteria.
|
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 |
BatchWindowProcessor
Implementation of
WindowProcessor which represent a Batch Window that aggregate batch of incoming events
together. |
class |
DelayWindowProcessor
Implementation of
WindowProcessor which represent a Window operating based on delay time. |
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 |
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 |
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 |
WindowWindowProcessor
This is the
WindowProcessor intended to be used with window join queries. |
Modifier and Type | Class and Description |
---|---|
class |
InMemoryTable
In-memory event table implementation of SiddhiQL.
|
class |
Table
Interface class to represent Tables in Siddhi.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractQueryableRecordTable
An abstract implementation of table.
|
class |
AbstractRecordTable
An abstract implementation of table.
|
Modifier and Type | Class and Description |
---|---|
class |
Window
Window implementation of SiddhiQL.
|
Copyright © 2019. All rights reserved.