Source, Sink, and Processor Configuration Values
Also available as:
PDF

Processor Configuration Values

Table 1. 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 timestamp at which the event occurred will be used for the window computations.
Output Fields -- Input The field on which to apply aggregate function
Output Fields -- Aggregate Function The aggregate function to apply
Output Fields -- Output The output field name
Table 2. 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 further rules after a rule evaluates successfully.
Rule Name Rule name. 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 3. 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/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 4. PMML
Configuration Field Description, requirements, tips for configuration
General Processor Description Allows 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, in addition to input fields
Model Name Name of the PPML model in model registry to use
Table 5. Projection Bolt
Configuration Field Description, requirements, tips for configuration
General Processor Description This allows user to choose specific fields from the input events to be passed to output event and apply a transformation using UDF on chosen fields and add result as a field in the output event.
Projection Fields Input event fields to be projected into output event.
Function UDF to be applied on the given input fields and 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. 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 will be 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 query.