Join |
-
Joins two streams together based on a field from each stream.
-
Two join types are supported: inner and left.
-
Joins are based on a window that you can configure based on time or
count.
|
Rule |
-
Allows you to configure rule conditions that route events to
different streams.
-
Standard conditional operators are supported for rules.
-
Configuring a rule has two modes:
-
Rules are translated to SQL to be applied on the stream.
-
An event goes through all the conditions and if it matches multiple
rules the event is sent to all the matching output streams.
|
Aggregate |
-
Performs functions over windows of events.
-
Two types of windows are supported: tumbling and sliding.
-
You can create window criteria based on time interval and count.
-
Window functions supported out of the box include: stddev, stddevp,
variance, variancecep, avg, min, max, sum, count. The system is
extensible to add custom functions as well.
|
Projection |
|
Branch |
-
Performs a standard if-else construct for routing.
-
The even is routed to the first rule it matches. Once an event has
matched a rule, no further condition search is performed.
|
PMML |
|