Added pivot functions

influxdata · Oct 10, 2018 · 73b3fb8 · 73b3fb8
1 parent c5756c2
commit 73b3fb8
Show file tree

Hide file tree

Showing 50 changed files with 375 additions and 123 deletions.
diff --git a/flux-client-rxjava/src/main/java/org/influxdata/flux/FluxClientReactive.java b/flux-client-rxjava/src/main/java/org/influxdata/flux/FluxClientReactive.java
@@ -82,7 +82,7 @@ public interface FluxClientReactive {
      * Returns {@link Flowable} emitting raw response from InfluxDB server line by line.
      *
      * @param dialect Dialect is an object defining the options to use when encoding the response.
-     *                <a href="https://bit.ly/2PbCM8G">See dialect SPEC.</a>.
+     *                <a href="http://bit.ly/flux-dialect">See dialect SPEC.</a>.
      * @param query   the Flux query to execute
      * @return {@link Maybe} of a raw {@code Response<ResponseBody>}
      */
@@ -93,7 +93,7 @@ public interface FluxClientReactive {
      * Returns {@link Flowable} emitting raw response from InfluxDB server line by line.
      *
      * @param dialect     Dialect is an object defining the options to use when encoding the response.
-     *                    <a href="https://bit.ly/2PbCM8G">See dialect SPEC.</a>.
+     *                    <a href="http://bit.ly/flux-dialect">See dialect SPEC.</a>.
      * @param queryStream the Flux query publisher
      * @return {@link Maybe} of a raw {@code Response<ResponseBody>}
      */

diff --git a/flux-client/src/main/java/org/influxdata/flux/FluxClient.java b/flux-client/src/main/java/org/influxdata/flux/FluxClient.java
@@ -102,7 +102,7 @@ void query(@Nonnull final String query,
      *
      * @param query   the flux query to execute
      * @param dialect Dialect is an object defining the options to use when encoding the response.
-     *                <a href="https://bit.ly/2PbCM8G">See dialect SPEC.</a>.
+     *                <a href="http://bit.ly/flux-dialect">See dialect SPEC.</a>.
      * @return the raw response that matched the query
      */
     @Nonnull
@@ -125,7 +125,7 @@ void raw(@Nonnull final String query,
      *
      * @param query      the flux query to execute
      * @param dialect    Dialect is an object defining the options to use when encoding the response.
-     *                   <a href="https://bit.ly/2PbCM8G">See dialect SPEC.</a>.
+     *                   <a href="http://bit.ly/flux-dialect">See dialect SPEC.</a>.
      * @param onResponse callback to consume the raw response which are matched the query.
      *                   The callback call contains the one line of the response.
      */
@@ -152,7 +152,7 @@ void raw(@Nonnull final String query,
      *
      * @param query      the flux query to execute
      * @param dialect    Dialect is an object defining the options to use when encoding the response.
-     *                   <a href="https://bit.ly/2PbCM8G">See dialect SPEC.</a>.
+     *                   <a href="http://bit.ly/flux-dialect">See dialect SPEC.</a>.
      * @param onResponse callback to consume the raw response which are matched the query.
      *                   The callback call contains the one line of the response.
      * @param onError    callback to consume any error notification
@@ -184,7 +184,7 @@ void raw(@Nonnull final String query,
      *
      * @param query      the flux query to execute
      * @param dialect    Dialect is an object defining the options to use when encoding the response.
-     *                   <a href="https://bit.ly/2PbCM8G">See dialect SPEC.</a>.
+     *                   <a href="http://bit.ly/flux-dialect">See dialect SPEC.</a>.
      * @param onResponse callback to consume the raw response which are matched the query.
      *                   The callback call contains the one line of the response.
      * @param onError    callback to consume any error notification

diff --git a/flux-client/src/main/java/org/influxdata/flux/domain/FluxRecord.java b/flux-client/src/main/java/org/influxdata/flux/domain/FluxRecord.java
@@ -34,7 +34,7 @@
 /**
  * A record is a tuple of values. Each record in the table represents a single point in the series.
  *
- * <a href="https://github.com/influxdata/flux/blob/master/docs/SPEC.md#record">Specification</a>.
+ * <a href="http://bit.ly/flux-spec#record">Specification</a>.
  */
 public final class FluxRecord {
 

diff --git a/flux-client/src/main/java/org/influxdata/flux/domain/FluxTable.java b/flux-client/src/main/java/org/influxdata/flux/domain/FluxTable.java
@@ -30,7 +30,7 @@
 /**
  * This class represents table structure of Flux CSV Response.
  *
- * <a href="https://github.com/influxdata/flux/blob/master/docs/SPEC.md#table">Specification</a>.
+ * <a href="http://bit.ly/flux-spec#table">Specification</a>.
  */
 public final class FluxTable {
 

diff --git a/flux-client/src/main/java/org/influxdata/flux/option/FluxConnectionOptions.java b/flux-client/src/main/java/org/influxdata/flux/option/FluxConnectionOptions.java
@@ -52,7 +52,6 @@ private FluxConnectionOptions(@Nonnull final Builder builder) {
      * Creates a builder instance.
      *
      * @return a builder
-     * @since 1.0.0
      */
     @Nonnull
     public static FluxConnectionOptions.Builder builder() {
@@ -62,7 +61,6 @@ public static FluxConnectionOptions.Builder builder() {
     /**
      * @return the url to connect to Flux
      * @see FluxConnectionOptions.Builder#url(String)
-     * @since 1.0.0
      */
     @Nonnull
     public String getUrl() {
@@ -72,7 +70,6 @@ public String getUrl() {
     /**
      * @return HTTP client to use for communication with Flux
      * @see FluxConnectionOptions.Builder#okHttpClient(OkHttpClient.Builder)
-     * @since 1.0.0
      */
     @Nonnull
     public OkHttpClient.Builder getOkHttpClient() {
@@ -81,8 +78,6 @@ public OkHttpClient.Builder getOkHttpClient() {
 
     /**
      * A builder for {@code FluxConnectionOptions}.
-     *
-     * @since 1.0.0
      */
     @NotThreadSafe
     public static class Builder {
@@ -95,7 +90,6 @@ public static class Builder {
          *
          * @param url the url to connect to Flux. It must be defined.
          * @return {@code this}
-         * @since 1.0.0
          */
         @Nonnull
         public Builder url(@Nonnull final String url) {
@@ -109,7 +103,6 @@ public Builder url(@Nonnull final String url) {
          *
          * @param okHttpClient the HTTP client to use.
          * @return {@code this}
-         * @since 1.0.0
          */
         @Nonnull
         public Builder okHttpClient(@Nonnull final OkHttpClient.Builder okHttpClient) {