[incubator-streampipes] branch STREAMPIPES-545 updated: [hotfix] Update query builder

[ri...@apache.org]

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


The following commit(s) were added to refs/heads/STREAMPIPES-545 by this push:
     new 237029992 [hotfix] Update query builder
237029992 is described below

commit 237029992dcf10c06282997f674321f08a8fc900
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Fri Jul 22 13:06:58 2022 +0200

    [hotfix] Update query builder
---
 .../apache/streampipes/dataexplorer/sdk/DataLakeQueryBuilder.java   | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/sdk/DataLakeQueryBuilder.java b/streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/sdk/DataLakeQueryBuilder.java
index 4c890843e..ef1d50544 100644
--- a/streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/sdk/DataLakeQueryBuilder.java
+++ b/streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/sdk/DataLakeQueryBuilder.java
@@ -114,6 +114,12 @@ public class DataLakeQueryBuilder {
     return this;
   }
 
+  public DataLakeQueryBuilder withFilter(NestedClause clause) {
+    this.whereClauses.add(clause);
+
+    return this;
+  }
+
   public DataLakeQueryBuilder withGroupByTime(String timeInterval) {
 
     this.groupByClauses.add(new RawTextClause("time(" + timeInterval + ")"));