Point Selector*¶
This stage selects the points that are required for stream data processing from the Kafka topics of the organization unit. The functions of this stage include:
- Selecting points based the specified point IDs.
- Supporting multiple entries of point IDs. If the input data matches with the specified point IDs, the data record will be the output of the stage.
- If the input data does not match with the specified point IDs, the stage will not have output.
- Incompatible with old data formats, i.e. cannot filter data by
ModelId::PointId.
This stage does not support streaming lineage.
Configuration¶
The configuration tabs for this stage are General, Basic, and Input/Output.
General¶
| Name | Required? | Description |
|---|---|---|
| Name | Yes | The name of the stage. |
| Description | No | The description of the stage. |
| Stage Library | Yes | The streaming operator library to which the stage belongs. |
| Required Fields | No | The fields that the data records must contain. If the specified fields are not included, the record will be filtered out. |
| Preconditions | No | The conditions that must be satisfied by the data records. Records that do not meet the conditions will be filtered out. For example, ${record:value('/value') > 0}. For the syntax of EL expressions, see Expression Language. |
| On Record Error | Yes | The processing method for error data.
|
Basic¶
| Name | Required? | Description |
|---|---|---|
| Quality Filter | No | Filter the data according to the data quality. Only records that meet the quality conditions will be processed by this stage. |
Input/Output¶
| Name | Required? | Description |
|---|---|---|
| Input Measurement | Yes | Enter the data entry point that the current pipeline needs to process. |
