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?