You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2020/05/22 20:43:53 UTC
[incubator-streampipes-extensions] branch dev updated: Add a
default label field in data lake sink
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git
The following commit(s) were added to refs/heads/dev by this push:
new bfe593c Add a default label field in data lake sink
bfe593c is described below
commit bfe593cf6b5ef5830cfd04fee52065d31baf9e90
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Fri May 22 22:43:25 2020 +0200
Add a default label field in data lake sink
---
.../org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java | 2 ++
.../streampipes/sinks/internal/jvm/datalake/DataLakeInfluxDbClient.java | 1 -
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java b/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java
index fb730e2..dac48e1 100644
--- a/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java
+++ b/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java
@@ -108,6 +108,8 @@ public class DataLake implements EventSink<DataLakeParameters> {
event.updateFieldBySelector("s0::" + eventProperty.getRuntimeName(), fileRoute);
});
+ event.addField("sp_internal_label", "");
+
influxDbClient.save(event);
} catch (SpRuntimeException e) {
LOG.error(e.getMessage());
diff --git a/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLakeInfluxDbClient.java b/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLakeInfluxDbClient.java
index d8fe89b..b5767c3 100644
--- a/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLakeInfluxDbClient.java
+++ b/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLakeInfluxDbClient.java
@@ -120,7 +120,6 @@ public class DataLakeInfluxDbClient {
}
// Checking whether the database exists
- System.out.println(databaseExists(databaseName));
if(!databaseExists(databaseName)) {
logger.info("Database '" + databaseName + "' not found. Gets created ...");
createDatabase(databaseName);