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)