Package com.influxdb.v3.client.internal

Class InfluxDBClientImpl

java.lang.Object
com.influxdb.v3.client.internal.InfluxDBClientImpl
All Implemented Interfaces:
InfluxDBClient, AutoCloseable
public final class InfluxDBClientImpl extends Object implements InfluxDBClient
Implementation of the InfluxDBClient. It is thread-safe and can be safely shared between threads.

Please use InfluxDBClient to create an instance.

  • Constructor Details

    • InfluxDBClientImpl

      public InfluxDBClientImpl(@Nonnull ClientConfig config)
      Creates an instance using the specified config.

      Please use InfluxDBClient to create an instance.

      Parameters:
      config - the client config.

  • Method Details

    • writeRecord

      public void writeRecord(@Nullable String record)
      Description copied from interface: InfluxDBClient
      Write a record specified in the InfluxDB Line Protocol to the InfluxDB server.
      Specified by:
      writeRecord in interface InfluxDBClient
      Parameters:
      record - the record specified in the InfluxDB Line Protocol, can be null

    • writeRecord

      public void writeRecord(@Nullable String record, @Nonnull WriteOptions options)
      Description copied from interface: InfluxDBClient
      Write a record specified in the InfluxDB Line Protocol to the InfluxDB server.
      Specified by:
      writeRecord in interface InfluxDBClient
      Parameters:
      record - the record specified in the InfluxDB Line Protocol, can be null
      options - the options for writing data to InfluxDB

    • writeRecords

      public void writeRecords(@Nonnull List<String> records)
      Description copied from interface: InfluxDBClient
      Write records specified in the InfluxDB Line Protocol to the InfluxDB server.
      Specified by:
      writeRecords in interface InfluxDBClient
      Parameters:
      records - the records specified in the InfluxDB Line Protocol, cannot be null

    • writeRecords

      public void writeRecords(@Nonnull List<String> records, @Nonnull WriteOptions options)
      Description copied from interface: InfluxDBClient
      Write records specified in the InfluxDB Line Protocol to the InfluxDB server.
      Specified by:
      writeRecords in interface InfluxDBClient
      Parameters:
      records - the records specified in the InfluxDB Line Protocol, cannot be null
      options - the options for writing data to InfluxDB

    • writePoint

      public void writePoint(@Nullable Point point)
      Description copied from interface: InfluxDBClient
      Write a Point to the InfluxDB server.
      Specified by:
      writePoint in interface InfluxDBClient
      Parameters:
      point - the Point to write, can be null

      Note: the timestamp passed will be converted to nanoseconds since the Unix epoch by NanosecondConverter helper class

    • writePoint

      public void writePoint(@Nullable Point point, @Nonnull WriteOptions options)
      Description copied from interface: InfluxDBClient
      Write a Point to the InfluxDB server.
      Specified by:
      writePoint in interface InfluxDBClient
      Parameters:
      point - the Point to write, can be null
      options - the options for writing data to InfluxDB

      Note: the timestamp passed will be converted to nanoseconds since the Unix epoch by NanosecondConverter helper class

    • writePoints

      public void writePoints(@Nonnull List<Point> points)
      Description copied from interface: InfluxDBClient
      Write a list of Point to the InfluxDB server.
      Specified by:
      writePoints in interface InfluxDBClient
      Parameters:
      points - the list of Point to write, cannot be null

      Note: the timestamp passed will be converted to nanoseconds since the Unix epoch by NanosecondConverter helper class

    • writePoints

      public void writePoints(@Nonnull List<Point> points, @Nonnull WriteOptions options)
      Description copied from interface: InfluxDBClient
      Write a list of Point to the InfluxDB server.
      Specified by:
      writePoints in interface InfluxDBClient
      Parameters:
      points - the list of Point to write, cannot be null
      options - the options for writing data to InfluxDB

      Note: the timestamp passed will be converted to nanoseconds since the Unix epoch by NanosecondConverter helper class

    • query

      @Nonnull public Stream<Object[]> query(@Nonnull String query)
      Description copied from interface: InfluxDBClient
      Query data from InfluxDB IOx using FlightSQL.

      The result stream should be closed after use, you can use try-resource pattern to close it automatically: 

       try (Stream<Object[]> rows = client.query("select * from cpu")) {
      rows.forEach(row -> {
          // process row
      }
 });
      Specified by:
      query in interface InfluxDBClient
      Parameters:
      query - the SQL query string to execute, cannot be null
      Returns:
      Batches of rows returned by the query

      Note: the timestamp will be returned as a number of nanoseconds since the Unix epoch

    • query

      @Nonnull public Stream<Object[]> query(@Nonnull String query, @Nonnull QueryOptions options)
      Description copied from interface: InfluxDBClient
      Query data from InfluxDB IOx using FlightSQL.

      The result stream should be closed after use, you can use try-resource pattern to close it automatically: 

       try (Stream<Object[]> rows = client.query("select * from cpu", options)) {
      rows.forEach(row -> {
          // process row
      }
 });
      Specified by:
      query in interface InfluxDBClient
      Parameters:
      query - the query string to execute, cannot be null
      options - the options for querying data from InfluxDB
      Returns:
      Batches of rows returned by the query

      Note: the timestamp will be returned as a number of nanoseconds since the Unix epoch

    • query

      @Nonnull public Stream<Object[]> query(@Nonnull String query, @Nonnull Map<String,Object> parameters)
      Description copied from interface: InfluxDBClient
      Query data from InfluxDB IOx using FlightSQL.

      The result stream should be closed after use, you can use try-resource pattern to close it automatically: 

       try (Stream<Object[]> rows = client.query("select * from cpu where host=$host",
                                                 Map.of("host", "server-a")) {
      rows.forEach(row -> {
          // process row
      }
 });
      Specified by:
      query in interface InfluxDBClient
      Parameters:
      query - the SQL query string to execute, cannot be null
      parameters - query named parameters
      Returns:
      Batches of rows returned by the query

      Note: the timestamp will be returned as a number of nanoseconds since the Unix epoch

    • query

      @Nonnull public Stream<Object[]> query(@Nonnull String query, @Nonnull Map<String,Object> parameters, @Nonnull QueryOptions options)
      Description copied from interface: InfluxDBClient
      Query data from InfluxDB IOx using FlightSQL.

      The result stream should be closed after use, you can use try-resource pattern to close it automatically: 

       try (Stream<Object[]> rows = client.query("select * from cpu where host=$host",
                                                 Map.of("host", "server-a"), options)) {
      rows.forEach(row -> {
          // process row
      }
 });
      Specified by:
      query in interface InfluxDBClient
      Parameters:
      query - the query string to execute, cannot be null
      parameters - query named parameters
      options - the options for querying data from InfluxDB
      Returns:
      Batches of rows returned by the query

      Note: the timestamp will be returned as a number of nanoseconds since the Unix epoch

    • queryRows

      @Nonnull public Stream<Map<String,Object>> queryRows(@Nonnull String query)
      Description copied from interface: InfluxDBClient
      Query data from InfluxDB IOx using FlightSQL.

      The result stream should be closed after use, you can use try-resource pattern to close it automatically: 

       try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=intel")) {
      rows.forEach(row -> {
          // process row
      });
 };
      Specified by:
      queryRows in interface InfluxDBClient
      Parameters:
      query - the query string to execute, cannot be null
      Returns:
      Batches of rows returned by the query

    • queryRows

      @Nonnull public Stream<Map<String,Object>> queryRows(@Nonnull String query, @Nonnull Map<String,Object> parameters)
      Description copied from interface: InfluxDBClient
      Query data from InfluxDB IOx using FlightSQL.

      The result stream should be closed after use, you can use try-resource pattern to close it automatically: 

       try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=$host",
                                                                      Map.of("host", "server-a"))) {
      rows.forEach(row -> {
          // process row
      })
 };
      Specified by:
      queryRows in interface InfluxDBClient
      Parameters:
      query - the query string to execute, cannot be null
      parameters - query named parameters
      Returns:
      Batches of rows returned by the query

    • queryRows

      @Nonnull public Stream<Map<String,Object>> queryRows(@Nonnull String query, @Nonnull QueryOptions options)
      Description copied from interface: InfluxDBClient
      Query data from InfluxDB IOx using FlightSQL.

      The result stream should be closed after use, you can use try-resource pattern to close it automatically: 

       try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=intel",
                                                                      options)) {
      rows.forEach(row -> {
          // process row
      })
 };
      Specified by:
      queryRows in interface InfluxDBClient
      Parameters:
      query - the query string to execute, cannot be null
      options - the options for querying data from InfluxDB
      Returns:
      Batches of rows returned by the query

    • queryRows

      @Nonnull public Stream<Map<String,Object>> queryRows(@Nonnull String query, @Nonnull Map<String,Object> parameters, @Nonnull QueryOptions options)
      Description copied from interface: InfluxDBClient
      Query data from InfluxDB IOx using FlightSQL.

      The result stream should be closed after use, you can use try-resource pattern to close it automatically: 

       try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=$host",
                                                                      Map.of("host", "server-a"), options)) {
      rows.forEach(row -> {
          // process row
      })
 };
      Specified by:
      queryRows in interface InfluxDBClient
      Parameters:
      query - the query string to execute, cannot be null
      parameters - query named parameters
      options - the options for querying data from InfluxDB
      Returns:
      Batches of rows returned by the query

    • queryPoints

      @Nonnull public Stream<PointValues> queryPoints(@Nonnull String query)
      Description copied from interface: InfluxDBClient
      Query data from InfluxDB IOx into Point structure using FlightSQL.

      The result stream should be closed after use, you can use try-resource pattern to close it automatically: 

       try (Stream<PointValues> rows = client.queryPoints("select * from cpu", options)) {
      rows.forEach(row -> {
          // process row
      }
 });
      Specified by:
      queryPoints in interface InfluxDBClient
      Parameters:
      query - the SQL query string to execute, cannot be null
      Returns:
      Batches of PointValues returned by the query

      Note: the timestamp will be returned as a number of nanoseconds since the Unix epoch

    • queryPoints

      @Nonnull public Stream<PointValues> queryPoints(@Nonnull String query, @Nonnull QueryOptions options)
      Description copied from interface: InfluxDBClient
      Query data from InfluxDB IOx into Point structure using FlightSQL.

      The result stream should be closed after use, you can use try-resource pattern to close it automatically: 

       try (Stream<PointValues> rows = client.queryPoints("select * from cpu", options)) {
      rows.forEach(row -> {
          // process row
      }
 });
      Specified by:
      queryPoints in interface InfluxDBClient
      Parameters:
      query - the query string to execute, cannot be null
      options - the options for querying data from InfluxDB
      Returns:
      Batches of PointValues returned by the query

      Note: the timestamp will be returned as a number of nanoseconds since the Unix epoch

    • queryPoints

      @Nonnull public Stream<PointValues> queryPoints(@Nonnull String query, @Nonnull Map<String,Object> parameters)
      Description copied from interface: InfluxDBClient
      Query data from InfluxDB IOx into Point structure using FlightSQL.

      The result stream should be closed after use, you can use try-resource pattern to close it automatically: 

       try (Stream<PointValues> rows = client.queryPoints("select * from cpu where host=$host",
                                                          Map.of("host", "server-a"))) {
      rows.forEach(row -> {
          // process row
      }
 });
      Specified by:
      queryPoints in interface InfluxDBClient
      Parameters:
      query - the SQL query string to execute, cannot be null
      parameters - query named parameters
      Returns:
      Batches of PointValues returned by the query

      Note: the timestamp will be returned as a number of nanoseconds since the Unix epoch

    • queryPoints

      @Nonnull public Stream<PointValues> queryPoints(@Nonnull String query, @Nonnull Map<String,Object> parameters, @Nonnull QueryOptions options)
      Description copied from interface: InfluxDBClient
      Query data from InfluxDB IOx into Point structure using FlightSQL.

      The result stream should be closed after use, you can use try-resource pattern to close it automatically: 

       try (Stream<PointValues> rows = client.queryPoints("select * from cpu where host=$host",
                                                          Map.of("host", "server-a"),
                                                          options)) {
      rows.forEach(row -> {
          // process row
      }
 });
      Specified by:
      queryPoints in interface InfluxDBClient
      Parameters:
      query - the query string to execute, cannot be null
      parameters - query named parameters
      options - the options for querying data from InfluxDB
      Returns:
      Batches of PointValues returned by the query

      Note: the timestamp will be returned as a number of nanoseconds since the Unix epoch

    • queryBatches

      @Nonnull public Stream<org.apache.arrow.vector.VectorSchemaRoot> queryBatches(@Nonnull String query)
      Description copied from interface: InfluxDBClient
      Query data from InfluxDB IOx using FlightSQL.

      The result stream should be closed after use, you can use try-resource pattern to close it automatically: 

       try (Stream<VectorSchemaRoot> batches = client.queryBatches("select * from cpu")) {
      batches.forEach(batch -> {
          // process batch
      }
 });
      Specified by:
      queryBatches in interface InfluxDBClient
      Parameters:
      query - the SQL query string to execute, cannot be null
      Returns:
      Batches of rows returned by the query

    • queryBatches

      @Nonnull public Stream<org.apache.arrow.vector.VectorSchemaRoot> queryBatches(@Nonnull String query, @Nonnull QueryOptions options)
      Description copied from interface: InfluxDBClient
      Query data from InfluxDB IOx using FlightSQL. 
       try (Stream<VectorSchemaRoot> batches = client.queryBatches("select * from cpu", options)) {
      batches.forEach(batch -> {
          // process batch
      }
 });
      Specified by:
      queryBatches in interface InfluxDBClient
      Parameters:
      query - the query string to execute, cannot be null
      options - the options for querying data from InfluxDB
      Returns:
      Batches of rows returned by the query

    • queryBatches

      @Nonnull public Stream<org.apache.arrow.vector.VectorSchemaRoot> queryBatches(@Nonnull String query, @Nonnull Map<String,Object> parameters)
      Description copied from interface: InfluxDBClient
      Query data from InfluxDB IOx using FlightSQL.

      The result stream should be closed after use, you can use try-resource pattern to close it automatically: 

       try (Stream<VectorSchemaRoot> batches = client.queryBatches("select * from cpu where host=$host",
                                                                   Map.of("host", "server-a"))) {
      batches.forEach(batch -> {
          // process batch
      }
 });
      Specified by:
      queryBatches in interface InfluxDBClient
      Parameters:
      query - the SQL query string to execute, cannot be null
      parameters - query named parameters
      Returns:
      Batches of rows returned by the query

    • queryBatches

      @Nonnull public Stream<org.apache.arrow.vector.VectorSchemaRoot> queryBatches(@Nonnull String query, @Nonnull Map<String,Object> parameters, @Nonnull QueryOptions options)
      Description copied from interface: InfluxDBClient
      Query data from InfluxDB IOx using FlightSQL. 
       try (Stream<VectorSchemaRoot> batches = client.queryBatches("select * from cpu where host=$host",
                                                                   Map.of("host", "server-a"),
                                                                   options)) {
      batches.forEach(batch -> {
          // process batch
      }
 });
      Specified by:
      queryBatches in interface InfluxDBClient
      Parameters:
      query - the query string to execute, cannot be null
      parameters - query named parameters
      options - the options for querying data from InfluxDB
      Returns:
      Batches of rows returned by the query

    • getServerVersion

      public String getServerVersion()
      Description copied from interface: InfluxDBClient
      Get InfluxDB server version.
      Specified by:
      getServerVersion in interface InfluxDBClient
      Returns:
      a string representing the server version. Returns null if the server version can't be determined.

    • close

      public void close() throws Exception
      Specified by:
      close in interface AutoCloseable
      Throws:
      Exception