Packages

t

com.influxdb.client.scala

WriteScalaApi

trait WriteScalaApi extends AnyRef

The Scala API to write time-series data into InfluxDB 2.x.

Linear Supertypes
AnyRef, Any
Known Subclasses
WriteScalaApiImpl
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. WriteScalaApi
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def writeMeasurement[M](precision: Option[WritePrecision] = None, bucket: Option[String] = None, org: Option[String] = None): Sink[M, Future[Done]]

    Write Measurement into specified bucket.

    Write Measurement into specified bucket.

    M

    the type of the measurement (POJO)

    precision

    Precision for the unix timestamps within the body line-protocol. The com.influxdb.client.domain.WritePrecision.NS will be used as the precision if not specified.

    bucket

    Specifies the destination bucket for writes. The com.influxdb.client.InfluxDBClientOptions#getBucket will be used as the destination bucket if the bucket is not specified.

    org

    Specifies the destination organization for writes. The com.influxdb.client.InfluxDBClientOptions#getOrg will be used as the destination organization if the org is not specified.

    returns

    the sink that accept the measurement. The measurement is considered as one batch unit.

  2. abstract def writeMeasurements[M](parameters: WriteParameters): Sink[Seq[M], Future[Done]]

    Write Measurements into specified bucket.

    Write Measurements into specified bucket.

    M

    the type of the measurement (POJO)

    parameters

    specify InfluxDB Write endpoint parameters

    returns

    the sink that accept the measurements. The measurements are considered as one batch unit.

  3. abstract def writeMeasurements[M](precision: Option[WritePrecision] = None, bucket: Option[String] = None, org: Option[String] = None): Sink[Seq[M], Future[Done]]

    Write Measurements into specified bucket.

    Write Measurements into specified bucket.

    M

    the type of the measurement (POJO)

    precision

    Precision for the unix timestamps within the body line-protocol. The com.influxdb.client.domain.WritePrecision.NS will be used as the precision if not specified.

    bucket

    Specifies the destination bucket for writes. The com.influxdb.client.InfluxDBClientOptions#getBucket will be used as the destination bucket if the bucket is not specified.

    org

    Specifies the destination organization for writes. The com.influxdb.client.InfluxDBClientOptions#getOrg will be used as the destination organization if the org is not specified.

    returns

    the sink that accept the measurements. The measurements are considered as one batch unit.

  4. abstract def writePoint(bucket: Option[String] = None, org: Option[String] = None): Sink[Point, Future[Done]]

    Write Data points into specified bucket.

    Write Data points into specified bucket.

    bucket

    Specifies the destination bucket for writes. The com.influxdb.client.InfluxDBClientOptions#getBucket will be used as the destination bucket if the bucket is not specified.

    org

    Specifies the destination organization for writes. The com.influxdb.client.InfluxDBClientOptions#getOrg will be used as the destination organization if the org is not specified.

    returns

    the sink that accept the Data points. The point is considered as one batch unit.

  5. abstract def writePoints(parameters: WriteParameters): Sink[Seq[Point], Future[Done]]

    Write Data points into specified bucket.

    Write Data points into specified bucket.

    parameters

    specify InfluxDB Write endpoint parameters

    returns

    the sink that accept the Data points. The points are considered as one batch unit.

  6. abstract def writePoints(bucket: Option[String] = None, org: Option[String] = None): Sink[Seq[Point], Future[Done]]

    Write Data points into specified bucket.

    Write Data points into specified bucket.

    bucket

    Specifies the destination bucket for writes. The com.influxdb.client.InfluxDBClientOptions#getBucket will be used as the destination bucket if the bucket is not specified.

    org

    Specifies the destination organization for writes. The com.influxdb.client.InfluxDBClientOptions#getOrg will be used as the destination organization if the org is not specified.

    returns

    the sink that accept the Data points. The points are considered as one batch unit.

  7. abstract def writeRecord(precision: Option[WritePrecision] = None, bucket: Option[String] = None, org: Option[String] = None): Sink[String, Future[Done]]

    Write Line Protocol record into specified bucket.

    Write Line Protocol record into specified bucket.

    precision

    Precision for the unix timestamps within the body line-protocol. The com.influxdb.client.domain.WritePrecision.NS will be used as the precision if not specified.

    bucket

    Specifies the destination bucket for writes. The com.influxdb.client.InfluxDBClientOptions#getBucket will be used as the destination bucket if the bucket is not specified.

    org

    Specifies the destination organization for writes. The com.influxdb.client.InfluxDBClientOptions#getOrg will be used as the destination organization if the org is not specified.

    returns

    the sink that accept the record specified in InfluxDB Line Protocol. The record is considered as one batch unit.

  8. abstract def writeRecords(parameters: WriteParameters): Sink[Seq[String], Future[Done]]

    Write Line Protocol records into specified bucket.

    Write Line Protocol records into specified bucket.

    parameters

    specify InfluxDB Write endpoint parameters

    returns

    the sink that accept the records specified in InfluxDB Line Protocol. The records are considered as one batch unit.

  9. abstract def writeRecords(precision: Option[WritePrecision] = None, bucket: Option[String] = None, org: Option[String] = None): Sink[Seq[String], Future[Done]]

    Write Line Protocol records into specified bucket.

    Write Line Protocol records into specified bucket.

    precision

    Precision for the unix timestamps within the body line-protocol. The com.influxdb.client.domain.WritePrecision.NS will be used as the precision if not specified.

    bucket

    Specifies the destination bucket for writes. The com.influxdb.client.InfluxDBClientOptions#getBucket will be used as the destination bucket if the bucket is not specified.

    org

    Specifies the destination organization for writes. The com.influxdb.client.InfluxDBClientOptions#getOrg will be used as the destination organization if the org is not specified.

    returns

    the sink that accept the records specified in InfluxDB Line Protocol. The records are considered as one batch unit.