Processor Configuration Values
Table 6.4. Aggregate
| Configuration Field | Description, requirements, tips for configuration |
| General Processor description | Performs aggregate operations on a stream of events within a window. |
| Select Keys | These are the keys to “group by” for computing the aggregate. |
| Window Interval Type |
Time, for time-based windows. Count, for count-based windows. |
| Window Interval | The length or duration of the window |
| Sliding Interval | The interval at which the window slides |
| Timestamp Field | A field in the event that represents the event timestamp as a long value. If specified, the time at which the event occurred is used for the window computations. |
| Output Fields -- Input | The field on which to apply the aggregate function |
| Output Fields -- Aggregate Function | The aggregate function to apply |
| Output Fields -- Output | The output field name |
Table 6.5. Branch
| Configuration Field | Description, requirements, tips for configuration |
| General processor description | Conditionally redirects tuples from one incoming stream to one or more outbound streams |
| Process all checkbox | If disabled, stops processing rules subsequent to a successfully evaluated rule |
| Rule Name | A rule name that must be unique within the branch processor |
| Rule Description | Description of rule |
| Field Name | Field name used in the condition for the rule |
| Rule Operation | The comparison operator for the condition |
Table 6.6. Join
| Configuration Field | Description, requirements, tips for configuration |
| General Processor Description | Joins one or more event streams into one output stream, based on user-defined join criteria |
| Select Stream | Name of stream to join |
| Select Field | Name of field to use for join |
| Window Interval Type | Determines the type of windowing (count-based or time-based) to use for buffering streams to be joined |
| Window Interval | The window size |
| Sliding Interval | The interval between the start of two consecutive windows |
| Output Fields | Select which of the fields to include in the resulting event |
Table 6.7. PMML
| Configuration Field | Description, requirements, tips for configuration |
| General Processor Description | Enables users to score tuples according to a choice of PMML model registered in the model registry. The scored results are put in the predicted fields as defined in the PMML XML descriptor file. Predicted fields are available to send downstream, as are input fields. |
| Model Name | Name of the PPML model in the model registry to use |
Table 6.8. Projection Bolt
| Configuration Field | Description, requirements, tips for configuration |
| General Processor Description | Enables users to choose specific fields from the input events to be passed to an output event, to apply a transformation using UDF on the chosen fields, and to add result as a field in the output event. |
| Projection Fields | Input event fields to be projected into an output event. |
| Function | UDF to be applied on the given input fields.Output is added as a new field in the output event. |
| Arguments | Field names to be passed as arguments to the chosen function |
| Fields Name | Name of the inu |
| Plus icon | Add a new transformation |
Table 6.9. Rule
| Configuration Field | Description, requirements, tips for configuration |
| General Processor Description | Design time definition of a rule whose scope is the input fields. The condition of the rule is defined in the Create Query section. Only runtime values whose rule condition evaluates to true are sent downstream. |
| Rule Name | Name of the rule. It must be unique only within a Rule processor. Can be reused across rule processors. |
| Description | Documentation detailing the purpose of the rule. For user reference only. |
| Create Query | The condition of the rule is a composition of Boolean expressions built with operators on input fields. These Boolean expressions are parsed as SQL-like queries. |