THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
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
Extractor Method in onEvent
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
Extractor in onEvent
nested properties
still up to date?