...
How Data is handled in StreamPipes
Real-time Example Primitive
Real-time Example List
Info |
---|
Example Missing for story telling Any Ideas? |
Data Layer
Stored as a LinkedTreeMap:
...
Code Block |
---|
key: s0::name value: value |
Warning |
---|
why s0::name? |
Time
Timestamp is always required → See Time in StreamPipes
...
What happens if YYY-MM-DD as data sourceo be converted internally to Unix timestamp?
Description Layer
Event schema; describes each individual attributes of an event. The three most important and required fields are:
...
Warning |
---|
Why runtimeType => not Part of Class EvbentProperty Class measurementUnit => not Part of Class EvbentProperty Class valuesSpecitication => not Part of Class EvbentProperty Class |
Event Property Types
Type | Description |
---|---|
EventPropertiyPrimitive | flat single value |
EventPropertyList | List of flat single values |
EventPropertyNested | Deprecated? |
Read Event Property
It can be called in the required Section via
Read Way | Description |
---|---|
EpRequirements |
Warning |
---|
How to read List? |
Write
Write Way | Description |
---|---|
EventPropertiyPrimitiveBuilder | |
EpProperty | |
Arrays.asList(EpProperties... , EpProperties... ) |
EventPropertiyPrimitiveBuilder
This is used to build a complex Event Schema with the runtimeName, runtimeType and domainProperty and also optional attributes.
...
Warning |
---|
Why is domainProperty not an Array List? |
EpProperty
this is used to build a basic Event Schema with
the method also defines the runtimeType
Time
Method | Description |
---|---|
timestampProperty(String runtimeName) |
String
Method | Description |
---|---|
stringEp(Label label, String runtimeName, String domainProperty, Enumeration enumeration) | |
stringEp(Label label, String runtimeName, String domainProperty, PropertyScope propertyScope) | |
stringEp(Label label, String runtimeName, String domainProperty) | |
stringEp(Label label, String runtimeName, List <Uri> domainProperties) |
Double
Method | Description |
---|---|
doubleEp(Label label, String runtimeName, String domainProperty) | |
doubleEp(Label label, String runtimeName, String domainProperty, Float minValue, Float maxValue, Float step) |
Integer
Method | Description |
---|---|
integerEp(Label label, String runtimeName, List < Uri> domainProperties) | |
integerEp(Label label, String runtimeName, String domainProperty, QuantitativeValue valueSpecification) | |
integerEp(Label label, String runtimeName, String domainProperty, Float minValue, Float maxValue, Float step) |
Number
Method | Description |
---|---|
numberEp(Label label, String runtimeName, String domainProperty) |
General
Method | Description |
---|---|
ep(Label label, String runtimeType, String runtimeName, String domainProperty) |
Boolean
Method | Description |
---|---|
booleanEp(Label label, String runtimeName, String domainProperty) |
Long
Method | Description |
---|---|
longEp(Label label, String runtimeName, String domainProperty) | |
longEp(Label label, String runtimeName, List< URI> domainProperty) |
Image
Method | Description |
---|---|
imageProperty(String runtimeName) |
List
General
Method | Description |
---|---|
listEp(Label label, String runtimeName, Datatypes runtimeType, String domainProperty) | |
listEp(Label label, String runtimeName, EventPropety eventProperty, String domainProperty) | |
listEp(Label label, String runtimeName, EventProperty eventProperty) |
String
Method | Description |
---|---|
ListStringEp(Label label, String runtimeName, String domainProperty) |
Double
Method | Description |
---|---|
listDoupleEp(Label label, String runtimeName, String domainProperty) |
Boolean
Method | Description |
---|---|
listBoolean(Label label, String runtimeName, String domainProperty)) |
Integer
Method | Description |
---|---|
listIntegerEp(Label label, String runtimeName, String domainProperty) |
Long
Method | Description |
---|---|
listLongEp(Label label, String runtimeName, String domainProperty) |
Nested
Method | Description |
---|---|
listNestedEp(Label label, String runtimeName, List<EventProperty... eventProperties) | |
listNestedEp(Label label, String runtimeName, String domainProperty, List<Eventproperty> listItemProperties) |
Scope
There are 4 types of scope
...
Type | Description |
---|---|
HEADER_PROPERTY | A property that defines meta-information about the event, for instance its occurrence time |
DIMENSION_PROPERTY | A property that describes the context of a measurement, e.g., the ID of a machine or a thing. |
MEASUREMENT_PROPERTY | A property that contains (often quantitative) measurement values |
NONE | The property scope is not further described. Use this scope for defining property requirements where the data processor's functionality does not require any specific property scope (e.g., a text filter that can filter any text-based property) |
Quality
DomainProperty
You can either use an own URI Link
or use a variety of StreamPipes implemented vocabularies.
A full list can be found under the vocabulary package:
...
Labels
Code Block |
---|
Labels.withID(String internalID) Labels.empty() |
...