feat: added to function without org parameter (#172)

CHANGELOG.md

@@ -1,5 +1,8 @@
 ## 1.14.0 [unreleased]
 
+### Features
+1. [#172](https://github.com/influxdata/influxdb-client-java/pull/172): flux-dsl: added `to` function without `org` parameter
+
 ## 1.13.0 [2020-10-30]
 
 ### Features

flux-dsl/src/main/java/com/influxdb/query/dsl/Flux.java

@@ -1744,6 +1744,19 @@ public final ToFlux to() {
         return new ToFlux(this);
     }
 
+    /**
+     * To operation takes data from a stream and writes it to a bucket.
+     *
+     * @param bucket The bucket to which data will be written.
+     * @return {@link ToFlux}
+     */
+    @Nonnull
+    public final ToFlux to(@Nonnull final String bucket) {
+
+        return new ToFlux(this)
+                .withBucket(bucket);
+    }
+
     /**
      * To operation takes data from a stream and writes it to a bucket.
      *

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

@@ -44,7 +44,12 @@
  *     <li><b>fieldFn</b> - Function that takes a record from the input table and returns an object.</li>
  * </ul>
  *
- * <h3>Example</h3>
+ * <h3>Examples</h3>
+ * <pre>
+ * Flux flux = Flux
+ *     .from("telegraf")
+ *     .to("my-bucket");
+ * </pre>
  * <pre>
  * Flux flux = Flux
  *     .from("telegraf")

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

@@ -56,6 +56,17 @@ void to() {
         Assertions.assertThat(flux.toString()).isEqualToIgnoringWhitespace(expected);
     }
 
+    @Test
+    void toBucket() {
+
+        Flux flux = Flux
+                .from("telegraf")
+                .to("my-bucket");
+
+        Assertions.assertThat(flux.toString())
+                .isEqualToIgnoringWhitespace("from(bucket:\"telegraf\") |> to(bucket: \"my-bucket\")");
+    }
+
     @Test
     void toBucketOrg() {