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
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() {