com.influxdb.client.reactive

Interface QueryReactiveApi

@ThreadSafe
public interface QueryReactiveApi

The client that allow perform Flux query against theInfluxDB 2.0by a reactive way.

Author:

Jakub Bednar (bednar@github) (21/11/2018 07:19)

Method Summary

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

Method Detail

query

@Nonnull
io.reactivex.Flowable<com.influxdb.query.FluxRecord> query(@Nonnull
                                                                    String query)

Returns Flowable emitting FluxRecords which are matched the query. If none found than return Flowable.empty().

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

Parameters:

query - the Flux query to execute

Returns:

Flowable of FluxRecords

query

@Nonnull
io.reactivex.Flowable<com.influxdb.query.FluxRecord> query(@Nonnull
                                                                    String query,
                                                                    @Nonnull
                                                                    String org)

Returns Flowable emitting FluxRecords which are matched the query. If none found than return Flowable.empty().

Parameters:

query - the Flux query to execute

org - specifies the source organization

Returns:

Flowable of FluxRecords

query

<M> io.reactivex.Flowable<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:

Flowable emitting a POJO mapped to measurementType which are matched the query or Flowable.empty() if none found.

query

<M> io.reactivex.Flowable<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:

Flowable emitting a POJO mapped to measurementType which are matched the query or Flowable.empty() if none found.

query

@Nonnull
io.reactivex.Flowable<com.influxdb.query.FluxRecord> query(@Nonnull
                                                                    org.reactivestreams.Publisher<String> queryStream)

Returns Flowable emitting FluxRecords which are matched the query. If none found than return Flowable.empty().

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

Parameters:

queryStream - the Flux query publisher

Returns:

Flowable of FluxRecords

query

@Nonnull
io.reactivex.Flowable<com.influxdb.query.FluxRecord> query(@Nonnull
                                                                    org.reactivestreams.Publisher<String> queryStream,
                                                                    @Nonnull
                                                                    String org)

Returns Flowable emitting FluxRecords which are matched the query. If none found than return Flowable.empty().

Parameters:

queryStream - the Flux query publisher

org - specifies the source organization

Returns:

Flowable of FluxRecords

query

@Nonnull
<M> io.reactivex.Flowable<M> query(@Nonnull
                                            org.reactivestreams.Publisher<String> queryStream,
                                            @Nonnull
                                            Class<M> measurementType)

Returns the Flowable emitting POJO stream.

If none found than return Flowable.empty().

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

Type Parameters:

M - the type of the measurement (POJO)

Parameters:

measurementType - the measurement class (POJO)

queryStream - the Flux query publisher

Returns:

Flowable of FluxRecords

query

@Nonnull
<M> io.reactivex.Flowable<M> query(@Nonnull
                                            org.reactivestreams.Publisher<String> queryStream,
                                            @Nonnull
                                            String org,
                                            @Nonnull
                                            Class<M> measurementType)

Returns the Flowable emitting POJO stream.

If none found than return Flowable.empty().

Type Parameters:

M - the type of the measurement (POJO)

Parameters:

measurementType - the measurement class (POJO)

org - specifies the source organization

queryStream - the Flux query publisher

Returns:

Flowable of FluxRecords

queryRaw

@Nonnull
io.reactivex.Flowable<String> queryRaw(@Nonnull
                                                String query)

Returns Flowable emitting raw response fromInfluxDB 2.0server line by line.

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

Parameters:

query - the Flux query to execute

Returns:

Flowable of response lines

queryRaw

@Nonnull
io.reactivex.Flowable<String> queryRaw(@Nonnull
                                                String query,
                                                @Nonnull
                                                String org)

Returns Flowable emitting raw response fromInfluxDB 2.0server line by line.

Parameters:

query - the Flux query to execute

org - specifies the source organization

Returns:

Flowable of response lines

queryRaw

@Nonnull
io.reactivex.Flowable<String> queryRaw(@Nonnull
                                                org.reactivestreams.Publisher<String> queryStream)

Returns Flowable 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:

Flowable of response lines

queryRaw

@Nonnull
io.reactivex.Flowable<String> queryRaw(@Nonnull
                                                org.reactivestreams.Publisher<String> queryStream,
                                                @Nonnull
                                                String org)

Returns Flowable emitting queryRaw response from InfluxDB server line by line.

Parameters:

queryStream - the Flux query publisher

org - specifies the source organization

Returns:

Flowable of response lines

queryRaw

@Nonnull
io.reactivex.Flowable<String> queryRaw(@Nonnull
                                                String query,
                                                @Nullable
                                                Dialect dialect)

Returns Flowable emitting queryRaw response fromInfluxDB 2.0server line by line.

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

Parameters:

dialect - Dialect is an object defining the options to use when encoding the response. See dialect SPEC..

query - the Flux query to execute

Returns:

Flowable of response lines

queryRaw

@Nonnull
io.reactivex.Flowable<String> queryRaw(@Nonnull
                                                String query,
                                                @Nullable
                                                Dialect dialect,
                                                @Nonnull
                                                String org)

Returns Flowable emitting queryRaw response fromInfluxDB 2.0server line by line.

Parameters:

dialect - Dialect is an object defining the options to use when encoding the response. See dialect SPEC..

query - the Flux query to execute

org - specifies the source organization

Returns:

Flowable of response lines

queryRaw

@Nonnull
io.reactivex.Flowable<String> queryRaw(@Nonnull
                                                org.reactivestreams.Publisher<String> queryStream,
                                                @Nullable
                                                Dialect dialect)

Returns Flowable emitting queryRaw response fromInfluxDB 2.0server line by line.

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

Parameters:

dialect - Dialect is an object defining the options to use when encoding the response. See dialect SPEC..

queryStream - the Flux query publisher

Returns:

Flowable of response lines

queryRaw

@Nonnull
io.reactivex.Flowable<String> queryRaw(@Nonnull
                                                org.reactivestreams.Publisher<String> queryStream,
                                                @Nullable
                                                Dialect dialect,
                                                @Nonnull
                                                String org)

Returns Flowable emitting queryRaw response fromInfluxDB 2.0server line by line.

Parameters:

dialect - Dialect is an object defining the options to use when encoding the response. See dialect SPEC..

queryStream - the Flux query publisher

org - specifies the source organization

Returns:

Flowable of response lines