influxdb-client-kotlin/com.influxdb.client.kotlin/QueryKotlinApi/query

query

abstract fun query(query: String): Channel<FluxRecord>(source)
abstract fun query(query: Query): Channel<FluxRecord>(source)

Executes the Flux query against the InfluxDB and asynchronously stream com.influxdb.query.FluxRecords to kotlinx.coroutines.channels.Channel.

The com.influxdb.client.InfluxDBClientOptions.getOrg will be used as source organization.

Return

the stream of com.influxdb.query.FluxRecords

Parameters

query

the flux query to execute

abstract fun query(query: String, org: String): Channel<FluxRecord>(source)
abstract fun query(query: Query, org: String): Channel<FluxRecord>(source)

Executes the Flux query against the InfluxDB and asynchronously stream com.influxdb.query.FluxRecords to kotlinx.coroutines.channels.Channel.

Return

the stream of com.influxdb.query.FluxRecords

Parameters

query

the flux query to execute

org

specifies the source organization

abstract fun <M> query(query: String, measurementType: Class<M>): Channel<M>(source)
abstract fun <M> query(query: Query, measurementType: Class<M>): Channel<M>(source)

Executes the Flux query against the InfluxDB and asynchronously stream measurements to kotlinx.coroutines.channels.Channel.

The com.influxdb.client.InfluxDBClientOptions.getOrg will be used as source organization.

Return

the stream of measurements

Parameters

query

the flux query to execute

the type of the measurement (POJO)
abstract fun <M> query(query: String, org: String, measurementType: Class<M>): Channel<M>(source)
abstract fun <M> query(query: Query, org: String, measurementType: Class<M>): Channel<M>(source)

Executes the Flux query against the InfluxDB and asynchronously stream measurements to kotlinx.coroutines.channels.Channel.

Return

the stream of measurements

Parameters

query

the flux query to execute

org

specifies the source organization

the type of the measurement (POJO)