![](/confluence/download/attachments/240882571/stream_requ.png?version=1&modificationDate=1675111404000&api=v2)
Basics
Builder
StreamRequirementsBuilder class provides methods to add stream requirements to a pipeline element.
Method | Parameters | Desciption |
---|
.create() | non |
|
.requiredPropertyWithUnaryMapping | EventProperty propertyRequirement, Label label, PropertyScope propertyScope | A unary mapping property maps a stream requirement to an actual field of an event stream. Therefore, the StreamRequirementsBuilder provides the opportunity to directly add a mapping property based along with a property requirement: |
.requiredPropertyWithNaryMapping | EventProperty propertyRequirement, Label label, PropertyScope propertyScope | N-ary mapping properties work similar to unary mapping properties, but allow the mapping of one requirement to multiple event properties matching the requirement: |
.requiredProperty() | EventProperty propertyRequirement | Sets a new property requirement, e.g., a property of a specific data type or with specific semantics a data stream that is connected to this pipeline element must provide. |
.build() | non |
|
Example
.requiredStream(StreamRequirementsBuilder.
create()
.requiredPropertyWithUnaryMapping(
...
)
.
build())
Types
The Class propertyRequirement
has static methods and returns an EventProperty of following types:
Event Property EpRequirements Classes | Description |
---|
EventPropertyPrimitive | primitive fields property |
EventPropertyList | list fields properties |
| nested properties? |
EventProperty |
|
Methods for EventPropertyPrimitive
Method | Input Parameters | Desciption | Example |
---|
anyProperty() | non |
|
|
|
|
|
|
booleanReq () | non |
|
|
booleanReq () | String domainProperty |
|
|
|
|
|
|
datatypeReq () | String datatype |
|
|
datatypeReq () | Datatypes datatype |
|
|
|
|
|
|
doubleReq () | non |
|
|
doubleReq() | String domainProperty |
|
|
|
|
|
|
intererReq() | non |
|
|
integerReq() | String domainProperty |
|
|
|
|
|
|
numberReq() | non |
|
|
numberReq() | String domainProperty |
|
|
|
|
|
|
stringReq() | non |
|
|
stringReq() | String domainProperty |
|
|
|
|
|
|
timestampReq() | non |
|
|
Example
Mapping in onInvocation
EventPropertyList
Methods for EventPropertyList
Uses | Method | Input Parameters | Desciption | Example |
---|
yes | listRequirement() | non | Similarly to primitive requirements, you can define processors that require data streams with list fields |
|
yes | listRequirement() | Datatypes datatype | Similarly to primitive requirements, you can define processors that require data streams with list fields |
|
non | nestedListRequirement() | EventProperty... requiredProperties |
|
|
non | nestedListRequirement() | non |
|
|
non | nestedListRequirement() | EventPropertyNested nestedRequirement |
|
|
? | domainPropertyReq() | String domainProperty |
|
|
Datatypes datatype
Datatypes.Number
Datatypes.Boolean
Datatypes.Double
Datatypes.Float
Datatypes.Integer
Datatypes.Long
Datatypes.Sequense
Datatypes.String
listRequirement
Example
.requiredProperty(EpRequirements.listRequirement(Datatypes.Integer))
.requiredProperty(EpRequirements.listRequirement(Datatypes.Double))
.requiredProperty(EpRequirements.listRequirement(Datatypes.Boolean))
.requiredProperty(EpRequirements.listRequirement(Datatypes.String))
nestedListRequirement
Example
domainPropertyReq
Example
EventProperty
Methods for EventProperty
Method | Input Parameters | Desciption | Example |
---|
nestedListRequirement | EventProperty... requiredProperties |
|
|
withMappingPropertyID | String internalId EventProperty requirement |
|
|
Example
Mapping in onInvocation
nested properties