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 2021/06/11 18:20:34 UTC

[incubator-streampipes] 26/29: Add endpoint definition for dropping entire measurement series from data lake and removing related event property

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

ebi pushed a commit to branch STREAMPIPES-349
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git

commit f974f4d69d9b1121d2847cdd17392c2dbb0748be
Author: Daniel Ebi <eb...@fzi.de>
AuthorDate: Fri Jun 11 20:11:40 2021 +0200

    Add endpoint definition for dropping entire measurement series from data lake and removing related event property
---
 .../java/org/apache/streampipes/ps/DataLakeResourceV4.java | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git a/streampipes-platform-services/src/main/java/org/apache/streampipes/ps/DataLakeResourceV4.java b/streampipes-platform-services/src/main/java/org/apache/streampipes/ps/DataLakeResourceV4.java
index f2bd49b..53b3414 100644
--- a/streampipes-platform-services/src/main/java/org/apache/streampipes/ps/DataLakeResourceV4.java
+++ b/streampipes-platform-services/src/main/java/org/apache/streampipes/ps/DataLakeResourceV4.java
@@ -85,6 +85,20 @@ public class DataLakeResourceV4 extends AbstractRestResource {
         return ok();
     }
 
+    @DELETE
+    @Path("/measurements/{measurementID}/drop")
+    @Operation(summary = "Drop a single measurement series with given id from Data Lake and remove related event property", tags = {"Data Lake"},
+            responses = {
+                    @ApiResponse(responseCode = "200", description = "Measurement series successfully dropped from Data Lake"),
+                    @ApiResponse(responseCode = "400", description = "Measurement series with given id or related event property not found")})
+    public Response dropMeasurementSeries(@Parameter(in = ParameterIn.PATH, description = "username", required = true) @PathParam("username") String username
+            , @Parameter(in = ParameterIn.PATH, description = "the id of the measurement series", required = true) @PathParam("measurementID") String measurementID) {
+
+        /**
+         * TODO: implementation of method stump
+         */
+    }
+
     @GET
     @Path("/measurements")
     @Produces(MediaType.APPLICATION_JSON)