[incubator-streampipes-extensions] 01/01: Add field for label to event schema of Random Data Simulator (Stream)

[eb...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

ebi pushed a commit to branch timeseries-labeling
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git

commit 2b2f16a7a45b3081ec0e8ae347321a7417e614af
Author: Daniel Ebi <eb...@fzi.de>
AuthorDate: Wed May 13 21:45:25 2020 +0200

    Add field for label to event schema of Random Data Simulator (Stream)
---
 .../streampipes/connect/adapters/simulator/RandomDataSimulator.java | 3 +++
 .../connect/adapters/simulator/RandomDataSimulatorUtils.java        | 6 ++++++
 2 files changed, 9 insertions(+)

diff --git a/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/simulator/RandomDataSimulator.java b/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/simulator/RandomDataSimulator.java
index bce4c60..14ea3d8 100644
--- a/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/simulator/RandomDataSimulator.java
+++ b/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/simulator/RandomDataSimulator.java
@@ -68,10 +68,13 @@ public class RandomDataSimulator implements Runnable {
   private Map<String, Object> buildEvent(long timestamp, int counter) {
     Map<String, Object> event = new HashMap<>();
 
+    String default_label = "";
+
     event.put("timestamp", timestamp);
     event.put("randomNumber", random.nextInt(100));
     event.put("randomText", randomString());
     event.put("count", counter);
+    event.put("sp_internal_label", default_label);
     return event;
   }
 
diff --git a/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/simulator/RandomDataSimulatorUtils.java b/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/simulator/RandomDataSimulatorUtils.java
index 98bce40..8d150d5 100644
--- a/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/simulator/RandomDataSimulatorUtils.java
+++ b/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/simulator/RandomDataSimulatorUtils.java
@@ -22,6 +22,8 @@ import org.apache.streampipes.sdk.builder.adapter.GuessSchemaBuilder;
 import org.apache.streampipes.sdk.helpers.Labels;
 import org.apache.streampipes.vocabulary.SO;
 
+import java.awt.*;
+
 import static org.apache.streampipes.sdk.helpers.EpProperties.*;
 
 public class RandomDataSimulatorUtils {
@@ -30,6 +32,7 @@ public class RandomDataSimulatorUtils {
   private static final String RANDOM_NUMBER = "randomNumber";
   private static final String RANDOM_TEXT = "randomText";
   private static final String COUNT = "count";
+  private static final String LABEL = "sp_internal_label";
 
   public static GuessSchema randomSchema() {
     return GuessSchemaBuilder.create()
@@ -41,6 +44,9 @@ public class RandomDataSimulatorUtils {
                     SO.Text))
             .property(integerEp(Labels.from(COUNT, "count", "Count value"),
                     COUNT, SO.Number))
+            .property(stringEp(Labels.from(LABEL, "Label", "Related class label"),
+                    LABEL,
+                    SO.Text))
             .build();
   }
 }