Package com.influxdb.client.reactive

Interface QueryReactiveApi

@ThreadSafe public interface QueryReactiveApi
The client that allow perform Flux query against the InfluxDB 2.x by a reactive way. For parametrized queries use Query object, see com.influxdb.client.QueryApi in Java module for more details.
Author:
Jakub Bednar (bednar@github) (21/11/2018 07:19)

  • Method Summary

    Modifier and Type
    Method
    Description
    org.reactivestreams.Publisher<FluxRecord>
    query(Query query)
    Returns Publisher emitting FluxRecords which are matched the query.
    org.reactivestreams.Publisher<FluxRecord>
    query(Query query, String org)
    Returns Publisher emitting FluxRecords which are matched the query.
    <M> org.reactivestreams.Publisher<M>
    query(Query query, String org, Class<M> measurementType)
    Execute a Flux against the Flux service.
    org.reactivestreams.Publisher<FluxRecord>
    query(String query)
    Returns Publisher emitting FluxRecords which are matched the query.
    <M> org.reactivestreams.Publisher<M>
    query(String query, Class<M> measurementType)
    Execute a Flux against the Flux service.
    org.reactivestreams.Publisher<FluxRecord>
    query(String query, String org)
    Returns Publisher emitting FluxRecords which are matched the query.
    <M> org.reactivestreams.Publisher<M>
    query(String query, String org, Class<M> measurementType)
    Execute a Flux against the Flux service.
    org.reactivestreams.Publisher<FluxRecord>
    query(org.reactivestreams.Publisher<String> queryStream)
    Returns Publisher emitting FluxRecords which are matched the query.
    <M> org.reactivestreams.Publisher<M>
    query(org.reactivestreams.Publisher<String> queryStream, Class<M> measurementType)
    Returns the Publisher emitting POJO stream.
    org.reactivestreams.Publisher<FluxRecord>
    query(org.reactivestreams.Publisher<String> queryStream, String org)
    Returns Publisher emitting FluxRecords which are matched the query.
    <M> org.reactivestreams.Publisher<M>
    query(org.reactivestreams.Publisher<String> queryStream, String org, Class<M> measurementType)
    Returns the Publisher emitting POJO stream.
    org.reactivestreams.Publisher<FluxRecord>
    queryQuery(org.reactivestreams.Publisher<Query> queryStream, String org)
    Returns Publisher emitting FluxRecords which are matched the query.
    org.reactivestreams.Publisher<String>
    queryRaw(Query query)
    Returns Publisher emitting raw response fromInfluxDB 2.x server line by line.
    org.reactivestreams.Publisher<String>
    queryRaw(Query query, Dialect dialect, String org)
    Returns Publisher emitting queryRaw response fromInfluxDB 2.x server line by line.
    org.reactivestreams.Publisher<String>
    queryRaw(String query)
    Returns Publisher emitting raw response fromInfluxDB 2.x server line by line.
    org.reactivestreams.Publisher<String>
    queryRaw(String query, Dialect dialect)
    Returns Publisher emitting queryRaw response fromInfluxDB 2.x server line by line.
    org.reactivestreams.Publisher<String>
    queryRaw(String query, Dialect dialect, String org)
    Returns Publisher emitting queryRaw response fromInfluxDB 2.x server line by line.
    org.reactivestreams.Publisher<String>
    queryRaw(String query, String org)
    Returns Publisher emitting raw response fromInfluxDB 2.x server line by line.
    org.reactivestreams.Publisher<String>
    queryRaw(org.reactivestreams.Publisher<String> queryStream)
    Returns Publisher emitting queryRaw response from InfluxDB server line by line.
    org.reactivestreams.Publisher<String>
    queryRaw(org.reactivestreams.Publisher<String> queryStream, Dialect dialect)
    Returns Publisher emitting queryRaw response fromInfluxDB 2.x server line by line.
    org.reactivestreams.Publisher<String>
    queryRaw(org.reactivestreams.Publisher<String> queryStream, Dialect dialect, String org)
    Returns Publisher emitting queryRaw response fromInfluxDB 2.x server line by line.
    org.reactivestreams.Publisher<String>
    queryRaw(org.reactivestreams.Publisher<String> queryStream, String org)
    Returns Publisher emitting queryRaw response from InfluxDB server line by line.
    org.reactivestreams.Publisher<String>
    queryRawQuery(org.reactivestreams.Publisher<Query> queryStream, Dialect dialect, String org)
    Returns Publisher emitting queryRaw response fromInfluxDB 2.x server line by line.

  • Method Details

    • query

      @Nonnull org.reactivestreams.Publisher<FluxRecord> query(@Nonnull String query)
      Returns Publisher emitting FluxRecords which are matched the query. If none found than return empty sequence.

      The InfluxDBClientOptions.getOrg() will be used as source organization.

      Parameters:
      query - the Flux query to execute
      Returns:
      Publisher of FluxRecords

    • query

      @Nonnull org.reactivestreams.Publisher<FluxRecord> query(@Nonnull Query query)
      Returns Publisher emitting FluxRecords which are matched the query. If none found than return empty sequence.

      The InfluxDBClientOptions.getOrg() will be used as source organization.

      Parameters:
      query - the Flux query to execute
      Returns:
      Publisher of FluxRecords

    • query

      @Nonnull org.reactivestreams.Publisher<FluxRecord> query(@Nonnull String query, @Nonnull String org)
      Returns Publisher emitting FluxRecords which are matched the query. If none found than return empty sequence.
      Parameters:
      query - the Flux query to execute
      org - specifies the source organization
      Returns:
      Publisher of FluxRecords

    • query

      @Nonnull org.reactivestreams.Publisher<FluxRecord> query(@Nonnull Query query, @Nonnull String org)
      Returns Publisher emitting FluxRecords which are matched the query. If none found than return empty sequence.
      Parameters:
      query - the Flux query to execute
      org - specifies the source organization
      Returns:
      Publisher of FluxRecords

    • query

      <M> org.reactivestreams.Publisher<M> query(@Nonnull String query, @Nonnull Class<M> measurementType)
      Execute a Flux against the Flux service.

      The InfluxDBClientOptions.getOrg() will be used as source organization.

      Type Parameters:
      M - the type of the measurement (POJO)
      Parameters:
      query - the flux query to execute
      measurementType - the class type used to which will be result mapped
      Returns:
      Publisher emitting a POJO mapped to measurementType which are matched the query or empty sequence if none found.

    • query

      <M> org.reactivestreams.Publisher<M> query(@Nonnull String query, @Nonnull String org, @Nonnull Class<M> measurementType)
      Execute a Flux against the Flux service.
      Type Parameters:
      M - the type of the measurement (POJO)
      Parameters:
      query - the flux query to execute
      org - specifies the source organization
      measurementType - the class type used to which will be result mapped
      Returns:
      Publisher emitting a POJO mapped to measurementType which are matched the query or empty sequence if none found.

    • query

      <M> org.reactivestreams.Publisher<M> query(@Nonnull Query query, @Nonnull String org, @Nonnull Class<M> measurementType)
      Execute a Flux against the Flux service.
      Type Parameters:
      M - the type of the measurement (POJO)
      Parameters:
      query - the flux query to execute
      org - specifies the source organization
      measurementType - the class type used to which will be result mapped
      Returns:
      Publisher emitting a POJO mapped to measurementType which are matched the query or empty sequence if none found.

    • query

      @Nonnull org.reactivestreams.Publisher<FluxRecord> query(@Nonnull org.reactivestreams.Publisher<String> queryStream)
      Returns Publisher emitting FluxRecords which are matched the query. If none found than return empty sequence.

      The InfluxDBClientOptions.getOrg() will be used as source organization.

      Parameters:
      queryStream - the Flux query publisher
      Returns:
      Publisher of FluxRecords

    • query

      @Nonnull org.reactivestreams.Publisher<FluxRecord> query(@Nonnull org.reactivestreams.Publisher<String> queryStream, @Nonnull String org)
      Returns Publisher emitting FluxRecords which are matched the query. If none found than return empty sequence.
      Parameters:
      queryStream - the Flux query publisher
      org - specifies the source organization
      Returns:
      Publisher of FluxRecords

    • queryQuery

      @Nonnull org.reactivestreams.Publisher<FluxRecord> queryQuery(@Nonnull org.reactivestreams.Publisher<Query> queryStream, @Nonnull String org)
      Returns Publisher emitting FluxRecords which are matched the query. If none found than return empty sequence.
      Parameters:
      queryStream - the Flux query publisher
      org - specifies the source organization
      Returns:
      Publisher of FluxRecords

    • query

      @Nonnull <M> org.reactivestreams.Publisher<M> query(@Nonnull org.reactivestreams.Publisher<String> queryStream, @Nonnull Class<M> measurementType)
      Returns the Publisher emitting POJO stream.

      If none found than return empty sequence.

      The InfluxDBClientOptions.getOrg() will be used as source organization.

      Type Parameters:
      M - the type of the measurement (POJO)
      Parameters:
      queryStream - the Flux query publisher
      measurementType - the measurement class (POJO)
      Returns:
      Publisher of FluxRecords

    • query

      @Nonnull <M> org.reactivestreams.Publisher<M> query(@Nonnull org.reactivestreams.Publisher<String> queryStream, @Nonnull String org, @Nonnull Class<M> measurementType)
      Returns the Publisher emitting POJO stream.

      If none found than return empty sequence.

      Type Parameters:
      M - the type of the measurement (POJO)
      Parameters:
      queryStream - the Flux query publisher
      org - specifies the source organization
      measurementType - the measurement class (POJO)
      Returns:
      Publisher of FluxRecords

    • queryRaw

      @Nonnull org.reactivestreams.Publisher<String> queryRaw(@Nonnull String query)
      Returns Publisher emitting raw response fromInfluxDB 2.x server line by line.

      The InfluxDBClientOptions.getOrg() will be used as source organization.

      Parameters:
      query - the Flux query to execute
      Returns:
      Publisher of response lines

    • queryRaw

      @Nonnull org.reactivestreams.Publisher<String> queryRaw(@Nonnull Query query)
      Returns Publisher emitting raw response fromInfluxDB 2.x server line by line.

      The InfluxDBClientOptions.getOrg() will be used as source organization.

      Parameters:
      query - the Flux query to execute
      Returns:
      Publisher of response lines

    • queryRaw

      @Nonnull org.reactivestreams.Publisher<String> queryRaw(@Nonnull String query, @Nonnull String org)
      Returns Publisher emitting raw response fromInfluxDB 2.x server line by line.
      Parameters:
      query - the Flux query to execute
      org - specifies the source organization
      Returns:
      Publisher of response lines

    • queryRaw

      @Nonnull org.reactivestreams.Publisher<String> queryRaw(@Nonnull org.reactivestreams.Publisher<String> queryStream)
      Returns Publisher emitting queryRaw response from InfluxDB server line by line.

      The InfluxDBClientOptions.getOrg() will be used as source organization.

      Parameters:
      queryStream - the Flux query publisher
      Returns:
      Publisher of response lines

    • queryRaw

      @Nonnull org.reactivestreams.Publisher<String> queryRaw(@Nonnull org.reactivestreams.Publisher<String> queryStream, @Nonnull String org)
      Returns Publisher emitting queryRaw response from InfluxDB server line by line.
      Parameters:
      queryStream - the Flux query publisher
      org - specifies the source organization
      Returns:
      Publisher of response lines

    • queryRaw

      @Nonnull org.reactivestreams.Publisher<String> queryRaw(@Nonnull String query, @Nullable Dialect dialect)
      Returns Publisher emitting queryRaw response fromInfluxDB 2.x server line by line.

      The InfluxDBClientOptions.getOrg() will be used as source organization.

      Parameters:
      query - the Flux query to execute
      dialect - Dialect is an object defining the options to use when encoding the response. See dialect SPEC..
      Returns:
      Publisher of response lines

    • queryRaw

      @Nonnull org.reactivestreams.Publisher<String> queryRaw(@Nonnull String query, @Nullable Dialect dialect, @Nonnull String org)
      Returns Publisher emitting queryRaw response fromInfluxDB 2.x server line by line.
      Parameters:
      query - the Flux query to execute
      dialect - Dialect is an object defining the options to use when encoding the response. See dialect SPEC..
      org - specifies the source organization
      Returns:
      Publisher of response lines

    • queryRaw

      @Nonnull org.reactivestreams.Publisher<String> queryRaw(@Nonnull Query query, @Nullable Dialect dialect, @Nonnull String org)
      Returns Publisher emitting queryRaw response fromInfluxDB 2.x server line by line.
      Parameters:
      query - the Flux query to execute
      dialect - Dialect is an object defining the options to use when encoding the response. See dialect SPEC..
      org - specifies the source organization
      Returns:
      Publisher of response lines

    • queryRaw

      @Nonnull org.reactivestreams.Publisher<String> queryRaw(@Nonnull org.reactivestreams.Publisher<String> queryStream, @Nullable Dialect dialect)
      Returns Publisher emitting queryRaw response fromInfluxDB 2.x server line by line.

      The InfluxDBClientOptions.getOrg() will be used as source organization.

      Parameters:
      queryStream - the Flux query publisher
      dialect - Dialect is an object defining the options to use when encoding the response. See dialect SPEC..
      Returns:
      Publisher of response lines

    • queryRaw

      @Nonnull org.reactivestreams.Publisher<String> queryRaw(@Nonnull org.reactivestreams.Publisher<String> queryStream, @Nullable Dialect dialect, @Nonnull String org)
      Returns Publisher emitting queryRaw response fromInfluxDB 2.x server line by line.
      Parameters:
      queryStream - the Flux query publisher
      dialect - Dialect is an object defining the options to use when encoding the response. See dialect SPEC..
      org - specifies the source organization
      Returns:
      Publisher of response lines

    • queryRawQuery

      org.reactivestreams.Publisher<String> queryRawQuery(@Nonnull org.reactivestreams.Publisher<Query> queryStream, @Nullable Dialect dialect, @Nonnull String org)
      Returns Publisher emitting queryRaw response fromInfluxDB 2.x server line by line.
      Parameters:
      queryStream - the Flux query publisher
      dialect - Dialect is an object defining the options to use when encoding the response. See dialect SPEC..
      org - specifies the source organization
      Returns:
      Publisher of response lines