Uses of Class
com.influxdb.client.domain.Query
Package
Description
-
Uses of Query in com.influxdb.client
Modifier and TypeMethodDescriptionExecutes the Flux query against the InfluxDB 2.x and synchronously map whole response toList<FluxTable>
.<M> List
<M> Executes the Flux query against the InfluxDB 2.x and synchronously map whole response to list of object with given type.<M> void
QueryApi.query
(Query query, Class<M> measurementType, BiConsumer<Cancellable, M> onNext) Executes the Flux query against the InfluxDB 2.x and asynchronously stream POJO classes toonNext
consumer.<M> void
QueryApi.query
(Query query, Class<M> measurementType, BiConsumer<Cancellable, M> onNext, Consumer<? super Throwable> onError) Executes the Flux query against the InfluxDB 2.x and asynchronously stream POJO classes toonNext
consumer.<M> void
QueryApi.query
(Query query, Class<M> measurementType, BiConsumer<Cancellable, M> onNext, Consumer<? super Throwable> onError, Runnable onComplete) Executes the Flux query and asynchronously stream result as POJO.Executes the Flux query against the InfluxDB 2.x and synchronously map whole response toList<FluxTable>
.<M> List
<M> Executes the Flux query against the InfluxDB 2.x and synchronously map whole response to list of object with given type.<M> void
QueryApi.query
(Query query, String org, Class<M> measurementType, BiConsumer<Cancellable, M> onNext) Executes the Flux query against the InfluxDB 2.x and asynchronously stream POJO classes toonNext
consumer.<M> void
QueryApi.query
(Query query, String org, Class<M> measurementType, BiConsumer<Cancellable, M> onNext, Consumer<? super Throwable> onError) Executes the Flux query against the InfluxDB 2.x and asynchronously stream POJO classes toonNext
consumer.<M> void
QueryApi.query
(Query query, String org, Class<M> measurementType, BiConsumer<Cancellable, M> onNext, Consumer<? super Throwable> onError, Runnable onComplete) Executes the Flux query and asynchronously stream result as POJO.void
QueryApi.query
(Query query, String org, BiConsumer<Cancellable, FluxRecord> onNext) Executes the Flux query against the InfluxDB 2.x and asynchronously streamFluxRecord
s toonNext
consumer.void
QueryApi.query
(Query query, String org, BiConsumer<Cancellable, FluxRecord> onNext, Consumer<? super Throwable> onError) Executes the Flux query against the InfluxDB 2.x and asynchronously streamFluxRecord
s toonNext
consumer.void
QueryApi.query
(Query query, String org, BiConsumer<Cancellable, FluxRecord> onNext, Consumer<? super Throwable> onError, Runnable onComplete) Executes the Flux query against the InfluxDB 2.x and asynchronously streamFluxRecord
s toonNext
consumer.void
QueryApi.query
(Query query, BiConsumer<Cancellable, FluxRecord> onNext) Executes the Flux query against the InfluxDB 2.x and asynchronously streamFluxRecord
s toonNext
consumer.void
QueryApi.query
(Query query, BiConsumer<Cancellable, FluxRecord> onNext, Consumer<? super Throwable> onError) Executes the Flux query against the InfluxDB 2.x and asynchronously streamFluxRecord
s toonNext
consumer.void
QueryApi.query
(Query query, BiConsumer<Cancellable, FluxRecord> onNext, Consumer<? super Throwable> onError, Runnable onComplete) Executes the Flux query against the InfluxDB 2.x and asynchronously streamFluxRecord
s toonNext
consumer.Executes the Flux query against the InfluxDB 2.x and synchronously map whole response toString
result.Executes the Flux query against the InfluxDB 2.x and synchronously map whole response toString
result.void
QueryApi.queryRaw
(Query query, String org, BiConsumer<Cancellable, String> onResponse) Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) toonResponse
.void
QueryApi.queryRaw
(Query query, String org, BiConsumer<Cancellable, String> onResponse, Consumer<? super Throwable> onError) Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) toonResponse
.void
QueryApi.queryRaw
(Query query, String org, BiConsumer<Cancellable, String> onResponse, Consumer<? super Throwable> onError, Runnable onComplete) Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) toonResponse
.void
QueryApi.queryRaw
(Query query, BiConsumer<Cancellable, String> onResponse) Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) toonResponse
.void
QueryApi.queryRaw
(Query query, BiConsumer<Cancellable, String> onResponse, Consumer<? super Throwable> onError) Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) toonResponse
.void
QueryApi.queryRaw
(Query query, BiConsumer<Cancellable, String> onResponse, Consumer<? super Throwable> onError, Runnable onComplete) Executes the Flux query against the InfluxDB 2.x and asynchronously stream response (line by line) toonResponse
. -
Uses of Query in com.influxdb.client.domain
-
Uses of Query in com.influxdb.client.reactive
Modifier and TypeMethodDescriptionorg.reactivestreams.Publisher
<FluxRecord> ReturnsPublisher
emittingFluxRecord
s which are matched the query.org.reactivestreams.Publisher
<FluxRecord> ReturnsPublisher
emittingFluxRecord
s which are matched the query.<M> org.reactivestreams.Publisher
<M> Execute a Flux against the Flux service.org.reactivestreams.Publisher
<String> ReturnsPublisher
emitting raw response fromInfluxDB 2.x server line by line.org.reactivestreams.Publisher
<String> ReturnsPublisher
emitting queryRaw response fromInfluxDB 2.x server line by line.Modifier and TypeMethodDescriptionorg.reactivestreams.Publisher
<FluxRecord> QueryReactiveApi.queryQuery
(org.reactivestreams.Publisher<Query> queryStream, String org) ReturnsPublisher
emittingFluxRecord
s which are matched the query.org.reactivestreams.Publisher
<String> QueryReactiveApi.queryRawQuery
(org.reactivestreams.Publisher<Query> queryStream, Dialect dialect, String org) ReturnsPublisher
emitting queryRaw response fromInfluxDB 2.x server line by line. -
Uses of Query in com.influxdb.client.service
Modifier and TypeMethodDescriptionretrofit2.Call
<String> QueryService.postQuery
(String zapTraceSpan, String acceptEncoding, String contentType, String org, String orgID, Query query) Query data Retrieves data from InfluxDB buckets.retrofit2.Call
<AnalyzeQueryResponse> QueryService.postQueryAnalyze
(String zapTraceSpan, String contentType, Query query) Analyze a Flux queryretrofit2.Call
<okhttp3.ResponseBody> QueryService.postQueryResponseBody
(String zapTraceSpan, String acceptEncoding, String contentType, String org, String orgID, Query query) Query data Retrieves data from InfluxDB buckets.