You can use the IEP Operator Palette and Design View to graphically establish the operator flow when using the IEP. The IEP enables you to compose event processors by dragging operators from the operator palette, configuring each operator using the NetBeans' property sheet or its custom property editor, and connecting operators through their input/output ports.
The Palette is made up of the following sections.
IEP Operator | Use |
Aggregator | |
Relation Aggregator | Enables grouping of events by a specifed relation for statistical purposes. |
Time Based Aggregator | Enables grouping of events by time slots for statistical purposes. |
Tuple Based | Enables grouping of events by sequential index for statistical purposes. |
Correlation and Filter |
|
Relation Map | Enables joining of multiple relations. |
Stream Projection and Filter | Enables filtering events or modifying selected event attributes. |
Tuple Serial Correlation | Enabling correlation of sequential events. |
Input | |
Steam Input | Enables event collection. |
Table Input | Enables provisioning of extra event information using a relational table. |
Output | |
Relation Output | Enables you to define notification of changes to a relation. |
Steam Output | Enables to define event notification. |
Table Output | Enables definition of relational tables for extra output data. |
Relation Converter | |
Delete Stream | Enables definition of monitoring of event deletion from a relation. |
Insert Stream | Enables monitoring of event insertion to a relation. |
Relation Stream | Enables monitoring of event deletion from or insertion to a relation. |
Table | Enables a snapshot of the current state of a relation. |
Relation Operator | |
Distinct | Enables removal of duplicate events in a relation. |
Intersect | Enables definition of relation intersection. |
Minus | Enables definition of difference between two relations. |
Tuple Based | Enables definition of relations based on a specified number of events. |
Union | Enables definition of the union of unique events from multiple relations |
Union All | Joins the sets of the various incoming relations into one set. |
Stream Converter | |
Attribute Based Window | Enables definition of relations based on an increasing attribute and a specified size. |
Partitioned Window | Enables definition of relations. Retains a specified number of records per attribute or attributes based on the size value you specify. |
Time Based Window | Enables definition of relations based on a specified duration. |