From 509a73e340b9537c326afd81da0066ce50c32c84 Mon Sep 17 00:00:00 2001
From: Jakub Bednar <jakub.bednar@gmail.com>
Date: Mon, 9 Nov 2020 08:36:15 +0100
Subject: [PATCH 1/2] feat: added `to` function without `org` parameter

---
 .../src/main/java/com/influxdb/query/dsl/Flux.java  | 13 +++++++++++++
 .../com/influxdb/query/dsl/functions/ToFlux.java    |  7 ++++++-
 .../influxdb/query/dsl/functions/ToFluxTest.java    | 11 +++++++++++
 3 files changed, 30 insertions(+), 1 deletion(-)

diff --git a/flux-dsl/src/main/java/com/influxdb/query/dsl/Flux.java b/flux-dsl/src/main/java/com/influxdb/query/dsl/Flux.java
index a4eabff050d..bb826dbcb66 100644
--- a/flux-dsl/src/main/java/com/influxdb/query/dsl/Flux.java
+++ b/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.
      *
diff --git a/flux-dsl/src/main/java/com/influxdb/query/dsl/functions/ToFlux.java b/flux-dsl/src/main/java/com/influxdb/query/dsl/functions/ToFlux.java
index 316c4fa1f47..c60ff75fa1b 100644
--- a/flux-dsl/src/main/java/com/influxdb/query/dsl/functions/ToFlux.java
+++ b/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")
diff --git a/flux-dsl/src/test/java/com/influxdb/query/dsl/functions/ToFluxTest.java b/flux-dsl/src/test/java/com/influxdb/query/dsl/functions/ToFluxTest.java
index 31702355160..2bc8c74c415 100644
--- a/flux-dsl/src/test/java/com/influxdb/query/dsl/functions/ToFluxTest.java
+++ b/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() {
 

From f487dc4a22ba7ba186d337d69c85a482b9f9b3be Mon Sep 17 00:00:00 2001
From: Jakub Bednar <jakub.bednar@gmail.com>
Date: Mon, 9 Nov 2020 08:43:42 +0100
Subject: [PATCH 2/2] docs: updated CHANGELOG.md

---
 CHANGELOG.md | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/CHANGELOG.md b/CHANGELOG.md
index 6572fc4b504..467ae8ad25c 100644
--- a/CHANGELOG.md
+++ b/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