You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by eb...@apache.org on 2020/05/13 19:44:51 UTC
[incubator-streampipes-extensions] branch timeseries-labeling
created (now 2b2f16a)
This is an automated email from the ASF dual-hosted git repository.
ebi pushed a change to branch timeseries-labeling
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git.
at 2b2f16a Add field for label to event schema of Random Data Simulator (Stream)
This branch includes the following new commits:
new 2b2f16a Add field for label to event schema of Random Data Simulator (Stream)
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[incubator-streampipes-extensions] 01/01: Add field for label to
event schema of Random Data Simulator (Stream)
Posted by 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();
}
}