queryRaw

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

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

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

Return

the response stream

Parameters

query

the flux query to execute


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

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

Return

the response stream

Parameters

query

the flux query to execute

org

specifies the source organization


abstract fun queryRaw(query: String, dialect: Dialect): Channel<String>(source)

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

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

Return

the response stream

Parameters

query

the flux query to execute

dialect

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


abstract fun queryRaw(query: String, dialect: Dialect, org: String): Channel<String>(source)

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

Return

the response stream

Parameters

query

the flux query to execute

org

specifies the source organization

dialect

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