(streampipes) branch 3733-create-api-endpoint-to-upload-time-series-data updated: Change endpoint id to measure name

[oehler]

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

oehler pushed a commit to branch 
3733-create-api-endpoint-to-upload-time-series-data
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to 
refs/heads/3733-create-api-endpoint-to-upload-time-series-data by this push:
     new 33c17b0a8e Change endpoint id to measure name
33c17b0a8e is described below

commit 33c17b0a8ef34f68cf1b9cf1ecc63af37b43ccca
Author: Sven Oehler <oehler.s...@web.de>
AuthorDate: Tue Aug 19 11:02:36 2025 +0200

    Change endpoint id to measure name
---
 .../streampipes/rest/impl/datalake/DataLakeDataWriter.java   | 12 +++---------
 .../streampipes/rest/impl/datalake/DataLakeResource.java     |  2 +-
 2 files changed, 4 insertions(+), 10 deletions(-)

diff --git 
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/DataLakeDataWriter.java
 
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/DataLakeDataWriter.java
index c658d723e8..c4faeee687 100644
--- 
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/DataLakeDataWriter.java
+++ 
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/DataLakeDataWriter.java
@@ -21,13 +21,13 @@ package org.apache.streampipes.rest.impl.datalake;
 import org.apache.streampipes.commons.environment.Environments;
 import org.apache.streampipes.commons.exceptions.SpRuntimeException;
 import org.apache.streampipes.dataexplorer.TimeSeriesStore;
-import org.apache.streampipes.dataexplorer.api.IDataExplorerSchemaManagement;
 import org.apache.streampipes.dataexplorer.management.DataExplorerDispatcher;
 import org.apache.streampipes.model.datalake.DataLakeMeasure;
 import org.apache.streampipes.model.datalake.DataSeries;
 import org.apache.streampipes.model.datalake.SpQueryResult;
 import org.apache.streampipes.model.runtime.Event;
 import org.apache.streampipes.model.runtime.EventFactory;
+import org.apache.streampipes.storage.couchdb.CouchDbStorageManager;
 
 import java.util.List;
 import java.util.Map;
@@ -36,14 +36,8 @@ import java.util.stream.IntStream;
 
 public class DataLakeDataWriter {
 
-  private final IDataExplorerSchemaManagement dataExplorerSchemaManagement;
-
-  public DataLakeDataWriter(IDataExplorerSchemaManagement 
dataExplorerSchemaManagement) {
-    this.dataExplorerSchemaManagement = dataExplorerSchemaManagement;
-  }
-
-  public void writeData(String measurementID, SpQueryResult queryResult) {
-    var measure = dataExplorerSchemaManagement.getById(measurementID);
+  public void writeData(String measureName, SpQueryResult queryResult) {
+    var measure = 
CouchDbStorageManager.INSTANCE.getDataLakeStorage().getByMeasureName(measureName);
     var dataSeries = getDataSeries(queryResult);
     getTimeSeriesStoreAndPersistQueryResult(dataSeries, measure);
   }
diff --git 
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/DataLakeResource.java
 
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/DataLakeResource.java
index 78b4469018..e63e1c5789 100644
--- 
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/DataLakeResource.java
+++ 
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/DataLakeResource.java
@@ -381,7 +381,7 @@ public class DataLakeResource extends AbstractRestResource {
               description = "Successfully stored data")})
   public ResponseEntity<?> storeDataToMeasurement(@PathVariable String 
measurementID,
                                                   @RequestBody SpQueryResult 
queryResult) {
-    var dataWriter = new DataLakeDataWriter(dataExplorerSchemaManagement);
+    var dataWriter = new DataLakeDataWriter();
     try {
       dataWriter.writeData(measurementID, queryResult);
     } catch (SpRuntimeException e) {