Interface | Description |
---|---|
FindableProcessor |
Interface for all processors which holds a collection of events and supports traversing and finding events from
that collection.
|
QueryableProcessor |
Interface for all processors which holds a collection of events and supports traversing and finding events from
that collection with different selection criteria.
|
Class | Description |
---|---|
AggregateWindowProcessor |
This is the
WindowProcessor intended to be used with aggregate join queries. |
BatchingFindableWindowProcessor<S extends State> |
Window to process events as batches while supporting event search
|
BatchingWindowProcessor<S extends State> |
Performs event processing in a tumbling manner
|
BatchWindowProcessor |
Implementation of
WindowProcessor which represent a Batch Window that aggregate batch of incoming events
together. |
CronWindowProcessor |
Implementation of
WindowProcessor which represent a Window operating based on a cron expression. |
DelayWindowProcessor |
Implementation of
WindowProcessor which represent a Window operating based on delay time. |
EmptyWindowProcessor |
Implementation of
WindowProcessor which represent a Batch Window operating based on pre-defined length 0. |
ExpressionBatchWindowProcessor |
Implementation of
WindowProcessor which represent a Window operating based on a expression. |
ExpressionWindowProcessor |
Implementation of
WindowProcessor which represent a Window operating based on a expression. |
ExternalTimeBatchWindowProcessor |
Implementation of
WindowProcessor which represent a Batch Window operating based on external time. |
ExternalTimeWindowProcessor |
Implementation of
WindowProcessor which represent a Window operating based on external time. |
FrequentWindowProcessor | Deprecated |
GroupingFindableWindowProcessor<S extends State> |
Window that process event processing as a group while supporting event search
|
GroupingWindowProcessor<S extends State> |
Performs event processing with key based event groups
|
HopingWindowProcessor<S extends State> |
Performs event processing in a hopping manner
|
LengthBatchWindowProcessor |
Implementation of
WindowProcessor which represent a Batch Window operating based on pre-defined length. |
LengthWindowProcessor |
Implementation of
WindowProcessor which represent a Window operating based on a pre-defined length. |
LossyFrequentWindowProcessor | Deprecated |
SessionWindowProcessor |
Implementation of
WindowProcessor which represent a Window operating based on a session. |
SessionWindowProcessor.SessionComplexEventChunk<E extends ComplexEvent> |
Collection used to manage session windows.
|
SlidingFindableWindowProcessor<S extends State> |
Performs event processing in a sliding manner while supporting event search
|
SlidingWindowProcessor<S extends State> |
Performs event processing in a sliding manner
|
SortWindowProcessor |
Sample Query:
from inputStream#window.sort(5, attribute1, "asc", attribute2, "desc")
select attribute1, attribute2
insert into outputStream;
|
TableWindowProcessor |
Implementation of
WindowProcessor which represent a Window operating based on Table . |
TimeBatchWindowProcessor |
Implementation of
WindowProcessor which represent a Batch Window operating based on time. |
TimeLengthWindowProcessor |
Implementation of
WindowProcessor which represent a Window operating based on pre-defined length. |
TimeWindowProcessor |
Implementation of
WindowProcessor which represent a Window operating based time. |
WindowProcessor<S extends State> |
Abstract parent implementation of Processor to represent Windows.
|
WindowWindowProcessor |
This is the
WindowProcessor intended to be used with window join queries. |
Copyright © 2021. All rights reserved.