Uses of Class
com.influxdb.query.FluxRecord

Packages that use FluxRecord

Package	Description
com.influxdb.client
com.influxdb.client.flux
com.influxdb.client.flux.internal
com.influxdb.client.reactive
com.influxdb.internal
com.influxdb.query
com.influxdb.query.internal

Uses of FluxRecord in com.influxdb.client

Method parameters in com.influxdb.client with type arguments of type FluxRecord

Modifier and Type	Method	Description
void	InvokableScriptsApi.invokeScript(String scriptId, Map<String,Object> params, BiConsumer<Cancellable,FluxRecord> onNext)	Executes the script and asynchronously stream FluxRecords to onNext consumer.
void	InvokableScriptsApi.invokeScript(String scriptId, Map<String,Object> params, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the script and asynchronously stream FluxRecords to onNext consumer.
void	QueryApi.query(Query query, String org, BiConsumer<Cancellable,FluxRecord> onNext)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext 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 stream FluxRecords to onNext 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 stream FluxRecords to onNext consumer.
void	QueryApi.query(Query query, BiConsumer<Cancellable,FluxRecord> onNext)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext 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 stream FluxRecords to onNext 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 stream FluxRecords to onNext consumer.
void	QueryApi.query(String query, String org, BiConsumer<Cancellable,FluxRecord> onNext)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.
void	QueryApi.query(String query, String org, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.
void	QueryApi.query(String query, String org, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.
void	QueryApi.query(String query, String org, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError, Runnable onComplete, Map<String,Object> params)	Executes the Parameterized Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.
void	QueryApi.query(String query, BiConsumer<Cancellable,FluxRecord> onNext)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.
void	QueryApi.query(String query, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.
void	QueryApi.query(String query, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query against the InfluxDB 2.x and asynchronously stream FluxRecords to onNext consumer.

Uses of FluxRecord in com.influxdb.client.flux

Method parameters in com.influxdb.client.flux with type arguments of type FluxRecord

Modifier and Type	Method	Description
void	FluxClient.query(String query, BiConsumer<Cancellable,FluxRecord> onNext)	Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to onNext consumer.
void	FluxClient.query(String query, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to onNext consumer.
void	FluxClient.query(String query, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to onNext consumer.

Uses of FluxRecord in com.influxdb.client.flux.internal

Method parameters in com.influxdb.client.flux.internal with type arguments of type FluxRecord

Modifier and Type	Method	Description
void	FluxApiImpl.query(String query, BiConsumer<Cancellable,FluxRecord> onNext)
void	FluxApiImpl.query(String query, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError)
void	FluxApiImpl.query(String query, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError, Runnable onComplete)

Uses of FluxRecord in com.influxdb.client.reactive

Methods in com.influxdb.client.reactive that return types with arguments of type FluxRecord

Modifier and Type	Method	Description
org.reactivestreams.Publisher<FluxRecord>	QueryReactiveApi.query(Query query)	Returns Publisher emitting FluxRecords which are matched the query.
org.reactivestreams.Publisher<FluxRecord>	QueryReactiveApi.query(Query query, String org)	Returns Publisher emitting FluxRecords which are matched the query.
org.reactivestreams.Publisher<FluxRecord>	QueryReactiveApi.query(String query)	Returns Publisher emitting FluxRecords which are matched the query.
org.reactivestreams.Publisher<FluxRecord>	QueryReactiveApi.query(String query, String org)	Returns Publisher emitting FluxRecords which are matched the query.
org.reactivestreams.Publisher<FluxRecord>	QueryReactiveApi.query(org.reactivestreams.Publisher<String> queryStream)	Returns Publisher emitting FluxRecords which are matched the query.
org.reactivestreams.Publisher<FluxRecord>	QueryReactiveApi.query(org.reactivestreams.Publisher<String> queryStream, String org)	Returns Publisher emitting FluxRecords which are matched the query.
org.reactivestreams.Publisher<FluxRecord>	QueryReactiveApi.queryQuery(org.reactivestreams.Publisher<Query> queryStream, String org)	Returns Publisher emitting FluxRecords which are matched the query.

Uses of FluxRecord in com.influxdb.internal

Methods in com.influxdb.internal that return FluxRecord

Modifier and Type	Method	Description
FluxRecord	AbstractQueryApi.FluxRecordIterator.next()

Uses of FluxRecord in com.influxdb.query

Methods in com.influxdb.query that return types with arguments of type FluxRecord

Modifier and Type	Method	Description
List<FluxRecord>	FluxTable.getRecords()

Uses of FluxRecord in com.influxdb.query.internal

Fields in com.influxdb.query.internal declared as FluxRecord

Modifier and Type	Field	Description
FluxRecord	FluxCsvParser.FluxRecordOrTable.record

Methods in com.influxdb.query.internal with parameters of type FluxRecord

Modifier and Type	Method	Description
void	FluxCsvParser.FluxResponseConsumer.accept(int index, Cancellable cancellable, FluxRecord record)	Add new FluxRecord to consumer.
void	FluxCsvParser.FluxResponseConsumerTable.accept(int index, Cancellable cancellable, FluxRecord record)
<T> T	FluxResultMapper.toPOJO(FluxRecord record, Class<T> clazz)	Maps FluxRecord into custom POJO class.