You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2022/09/12 10:02:31 UTC
[incubator-streampipes] branch dev updated: [hotfix] Add update method to data lake storage API
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
The following commit(s) were added to refs/heads/dev by this push:
new f3f5265cc [hotfix] Add update method to data lake storage API
f3f5265cc is described below
commit f3f5265ccb0921b7dfe3db48ee3c51c40998264e
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Mon Sep 12 12:02:22 2022 +0200
[hotfix] Add update method to data lake storage API
---
.../java/org/apache/streampipes/storage/api/IDataLakeStorage.java | 3 +++
.../apache/streampipes/storage/couchdb/impl/DataLakeStorageImpl.java | 5 +++++
2 files changed, 8 insertions(+)
diff --git a/streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IDataLakeStorage.java b/streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IDataLakeStorage.java
index 213e73780..25159f01a 100644
--- a/streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IDataLakeStorage.java
+++ b/streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IDataLakeStorage.java
@@ -18,6 +18,7 @@
package org.apache.streampipes.storage.api;
+import org.apache.streampipes.model.datalake.DataExplorerWidgetModel;
import org.apache.streampipes.model.datalake.DataLakeMeasure;
import java.util.List;
@@ -29,4 +30,6 @@ public interface IDataLakeStorage {
List<DataLakeMeasure> getAllDataLakeMeasures();
DataLakeMeasure findOne(String id);
+
+ void updateDataLakeMeasure(DataLakeMeasure measure);
}
diff --git a/streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/DataLakeStorageImpl.java b/streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/DataLakeStorageImpl.java
index 992654478..943638af9 100644
--- a/streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/DataLakeStorageImpl.java
+++ b/streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/DataLakeStorageImpl.java
@@ -46,4 +46,9 @@ public class DataLakeStorageImpl extends AbstractDao<DataLakeMeasure> implements
public DataLakeMeasure findOne(String id) {
return find(id).orElse(null);
}
+
+ @Override
+ public void updateDataLakeMeasure(DataLakeMeasure measure) {
+ update(measure);
+ }
}