Packages

c

com.influxdb.client.scala.internal

WriteScalaApiImpl

class WriteScalaApiImpl extends AbstractWriteBlockingClient with WriteScalaApi

Linear Supertypes
WriteScalaApi, AbstractWriteBlockingClient, AbstractRestClient, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. WriteScalaApiImpl
  2. WriteScalaApi
  3. AbstractWriteBlockingClient
  4. AbstractRestClient
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new WriteScalaApiImpl(service: WriteService, options: InfluxDBClientOptions)

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. def execute[T <: AnyRef](arg0: Call[T]): T
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractRestClient
    Annotations
    @throws(classOf[com.influxdb.exceptions.InfluxException])
  9. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  10. def getLogLevel(arg0: HttpLoggingInterceptor): LogLevel
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractRestClient
    Annotations
    @Nonnull()
  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  15. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  16. def ping(arg0: Call[ResponseBody]): Boolean
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractRestClient
    Annotations
    @Nonnull()
  17. def responseToError(arg0: Response[_ <: AnyRef]): InfluxException
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractRestClient
    Annotations
    @Nonnull()
  18. def setLogLevel(arg0: HttpLoggingInterceptor, arg1: LogLevel): Unit
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractRestClient
  19. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  20. def toInfluxException(arg0: Throwable): InfluxException
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractRestClient
    Annotations
    @Nonnull()
  21. def toMeasurementBatch[M <: AnyRef](arg0: M, arg1: WritePrecision): BatchWriteDataMeasurement
    Attributes
    protected[client.internal]
    Definition Classes
    AbstractWriteBlockingClient
    Annotations
    @Nonnull()
  22. def toString(): String
    Definition Classes
    AnyRef → Any
  23. def version(arg0: Call[ResponseBody]): String
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractRestClient
    Annotations
    @Nonnull()
  24. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  25. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  26. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  27. def write(arg0: WriteParameters, arg1: Stream[BatchWriteData]): Unit
    Attributes
    protected[client.internal]
    Definition Classes
    AbstractWriteBlockingClient
  28. def writeMeasurement[M](precision: Option[WritePrecision], bucket: Option[String], org: Option[String]): 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.

    Definition Classes
    WriteScalaApiImpl → WriteScalaApi
  29. 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.

    Definition Classes
    WriteScalaApiImpl → WriteScalaApi
  30. def writeMeasurements[M](precision: Option[WritePrecision], bucket: Option[String], org: Option[String]): 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.

    Definition Classes
    WriteScalaApiImpl → WriteScalaApi
  31. def writePoint(bucket: Option[String], org: Option[String]): 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.

    Definition Classes
    WriteScalaApiImpl → WriteScalaApi
  32. 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.

    Definition Classes
    WriteScalaApiImpl → WriteScalaApi
  33. def writePoints(bucket: Option[String], org: Option[String]): 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.

    Definition Classes
    WriteScalaApiImpl → WriteScalaApi
  34. def writeRecord(precision: Option[WritePrecision], bucket: Option[String], org: Option[String]): 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.

    Definition Classes
    WriteScalaApiImpl → WriteScalaApi
  35. 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.

    Definition Classes
    WriteScalaApiImpl → WriteScalaApi
  36. def writeRecords(precision: Option[WritePrecision], bucket: Option[String], org: Option[String]): 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.

    Definition Classes
    WriteScalaApiImpl → WriteScalaApi

Deprecated Value Members

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

Inherited from WriteScalaApi

Inherited from AbstractWriteBlockingClient

Inherited from AbstractRestClient

Inherited from AnyRef

Inherited from Any

Ungrouped