feat: add contains filter [FluxDSL]

CHANGELOG.md

@@ -1,5 +1,7 @@
 ## 6.2.0 [unreleased]
 
+1. [#353](https://github.com/influxdata/influxdb-client-java/pull/353): Supports `contains` filter [FluxDSL]
+
 ## 6.1.0 [2022-05-20]
 
 ### Breaking Changes

flux-dsl/README.md

@@ -263,6 +263,7 @@ Supported Record restrictions:
 - `exists`
 - `lessOrEqual`
 - `greaterOrEqual`
+- `contains`
 - `custom` - the custom restriction by `Restrictions.value().custom(15L, "=~")`
 
 ```java

flux-dsl/src/main/java/com/influxdb/query/dsl/functions/restriction/ColumnRestriction.java

@@ -21,6 +21,8 @@
  */
 package com.influxdb.query.dsl.functions.restriction;
 
+import java.util.Arrays;
+import java.util.stream.Collectors;
 import javax.annotation.Nonnull;
 
 import com.influxdb.query.dsl.functions.properties.FunctionsParameters;
@@ -143,6 +145,32 @@ public String toString() {
         }
     }
 
+    /**
+     * Check if an record contains a key or if that key’s value is null.
+     *
+     * @return restriction
+     */
+    @Nonnull
+    public Restrictions contains(@Nonnull final String[] set) {
+        return new ContainsRestrictions(fieldName, set);
+    }
+
+    private final class ContainsRestrictions extends Restrictions {
+        private final String fieldName;
+        private final String[] set;
+
+        public ContainsRestrictions(@Nonnull final String fieldName, @Nonnull final String[] set) {
+            this.fieldName = fieldName;
+            this.set = set;
+        }
+
+        @Override
+        public String toString() {
+            return "contains(value: r[\"" + fieldName + "\"], set:["
+                    + Arrays.stream(set).collect(Collectors.joining("\", \"", "\"", "\"")) + "])";
+        }
+    }
+
     private final class OperatorRestrictions extends Restrictions {
         private final String fieldName;
         private final Object fieldValue;

flux-dsl/src/test/java/com/influxdb/query/dsl/functions/restriction/RestrictionsTest.java

@@ -64,6 +64,14 @@ void exists() {
         Assertions.assertThat(restrictions.toString()).isEqualTo("exists r[\"_value\"]");
     }
 
+    @Test
+    void contains() {
+
+        Restrictions restrictions = Restrictions.value().contains(new String[]{"value1", "value2"});
+
+        Assertions.assertThat(restrictions.toString()).isEqualTo("contains(value: r[\"_value\"], set:[\"value1\", \"value2\"])");
+    }
+
     @Test
     void not() {
 
@@ -87,4 +95,4 @@ void emptyLogical() {
         restrictions = Restrictions.or(Restrictions.or());
         Assertions.assertThat(restrictions.toString()).isEqualTo("");
     }
-}
+}