InfluxDB Client Examples

This directory contains Java, Kotlin and Scala examples.

Java

WriteDataEverySecond.java - Write data every second
ParameterizedQuery.java - How to use Parameterized Queries
InfluxQLExample.java - How to use queries with the old influxQL dialect

The InfluxQL can be used with /query compatibility endpoint which uses the database and retention policy specified in the query request to map the request to an InfluxDB bucket. For more information, see:
- /query 1.x compatibility API
- Database and retention policy mapping

Others

InvokableScripts.java - How to use Invokable scripts Cloud API to create custom endpoints that query data
InfluxDBEnterpriseExample.java - How to use consistency parameter for InfluxDB Enterprise

Kotlin

Query

KotlinQuery.kt - How to query data into a stream of FluxRecord and filter them by Flow operators
KotlinQueryRaw.kt - How to query data into a stream of String
KotlinQueryDSL.kt - How to use the FluxDSL to query data

Writes

KotlinWriteApi.kt - How to ingest data by DataPoint, LineProtocol or Data class
KotlinWriteBatchingByFlow.kt - How to use Flow operators to prepare batches for synchronous write into InfluxDB

Scala

Query

ScalaQuery.scala - How to query data into a stream of FluxRecord and filter them by Flow operators
ScalaQueryRaw.scala - How to query data into a stream of String
ScalaQueryDSL.scala - How to use the FluxDSL to query data

Writes

ScalaWriteApi.scala - How to ingest data by DataPoint, LineProtocol or POJO