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.

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  9. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  10. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  11. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  13. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  14. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  15. def toString(): String
    Definition Classes
    AnyRef → Any
  16. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  17. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  18. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated @Deprecated
    Deprecated

Inherited from AnyRef

Inherited from Any

Ungrouped