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/07/22 08:58:17 UTC
[incubator-streampipes] 02/02: [hotfix] Extend data lake storage API
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch STREAMPIPES-545
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit 7e0c78f9bc74c2d5a486398ebc39ed5842af18c4
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Fri Jul 22 10:58:05 2022 +0200
[hotfix] Extend data lake storage API
---
.../java/org/apache/streampipes/storage/api/IDataLakeStorage.java | 2 ++
.../apache/streampipes/storage/couchdb/impl/DataLakeStorageImpl.java | 5 +++++
2 files changed, 7 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 d16cfc21a..213e73780 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
@@ -27,4 +27,6 @@ public interface IDataLakeStorage {
boolean storeDataLakeMeasure(DataLakeMeasure measure);
List<DataLakeMeasure> getAllDataLakeMeasures();
+
+ DataLakeMeasure findOne(String id);
}
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 60a75596f..992654478 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
@@ -41,4 +41,9 @@ public class DataLakeStorageImpl extends AbstractDao<DataLakeMeasure> implements
List<DataLakeMeasure> dataLakeMeasures = findAll();
return dataLakeMeasures;
}
+
+ @Override
+ public DataLakeMeasure findOne(String id) {
+ return find(id).orElse(null);
+ }
}