WriteScalaApiImpl

class WriteScalaApiImpl extends AbstractWriteBlockingClient with WriteScalaApi

Linear Supertypes

WriteScalaApi, AbstractWriteBlockingClient, AbstractRestClient, AnyRef, Any

Ordering

Alphabetic
By Inheritance

Inherited

WriteScalaApiImpl
WriteScalaApi
AbstractWriteBlockingClient
AbstractRestClient
AnyRef
Any

Hide All
Show All

Visibility

Public
Protected

Instance Constructors

new WriteScalaApiImpl(service: WriteService, options: InfluxDBClientOptions)

Value Members

final def !=(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def ##: Int
Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0
Definition Classes
Any
def clone(): AnyRef
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
final def eq(arg0: AnyRef): Boolean
Definition Classes
AnyRef
def equals(arg0: AnyRef): Boolean
Definition Classes
AnyRef → Any
def execute[T <: AnyRef](arg0: Call[T]): T
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
Annotations
@throws(classOf[com.influxdb.exceptions.InfluxException])
final def getClass(): Class[_ <: AnyRef]
Definition Classes
AnyRef → Any
Annotations
@native() @IntrinsicCandidate()
def getLogLevel(arg0: HttpLoggingInterceptor): LogLevel
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
Annotations
@Nonnull()
def hashCode(): Int
Definition Classes
AnyRef → Any
Annotations
@native() @IntrinsicCandidate()
final def isInstanceOf[T0]: Boolean
Definition Classes
Any
final def ne(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def notify(): Unit
Definition Classes
AnyRef
Annotations
@native() @IntrinsicCandidate()
final def notifyAll(): Unit
Definition Classes
AnyRef
Annotations
@native() @IntrinsicCandidate()
def ping(arg0: Call[ResponseBody]): Boolean
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
Annotations
@Nonnull()
def responseToError(arg0: Response[_ <: AnyRef]): InfluxException
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
Annotations
@Nonnull()
def setLogLevel(arg0: HttpLoggingInterceptor, arg1: LogLevel): Unit
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
final def synchronized[T0](arg0: => T0): T0
Definition Classes
AnyRef
def toInfluxException(arg0: Throwable): InfluxException
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
Annotations
@Nonnull()
def toMeasurementBatch[M <: AnyRef](arg0: M, arg1: WritePrecision): BatchWriteDataMeasurement
Attributes
protected[client.internal]
Definition Classes
AbstractWriteBlockingClient
Annotations
@Nonnull()
def toString(): String
Definition Classes
AnyRef → Any
def version(arg0: Call[ResponseBody]): String
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
Annotations
@Nonnull()
final def wait(arg0: Long, arg1: Int): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
def write(arg0: WriteParameters, arg1: Stream[BatchWriteData]): Unit
Attributes
protected[client.internal]
Definition Classes
AbstractWriteBlockingClient
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
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
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
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
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
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
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
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
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

Inherited from AbstractWriteBlockingClient

Value Members

def toMeasurementBatch[M <: AnyRef](arg0: M, arg1: WritePrecision): BatchWriteDataMeasurement
Attributes
protected[client.internal]
Definition Classes
AbstractWriteBlockingClient
Annotations
@Nonnull()
def write(arg0: WriteParameters, arg1: Stream[BatchWriteData]): Unit
Attributes
protected[client.internal]
Definition Classes
AbstractWriteBlockingClient

Inherited from AbstractRestClient

Value Members

def execute[T <: AnyRef](arg0: Call[T]): T
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
Annotations
@throws(classOf[com.influxdb.exceptions.InfluxException])
def getLogLevel(arg0: HttpLoggingInterceptor): LogLevel
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
Annotations
@Nonnull()
def ping(arg0: Call[ResponseBody]): Boolean
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
Annotations
@Nonnull()
def responseToError(arg0: Response[_ <: AnyRef]): InfluxException
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
Annotations
@Nonnull()
def setLogLevel(arg0: HttpLoggingInterceptor, arg1: LogLevel): Unit
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
def toInfluxException(arg0: Throwable): InfluxException
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
Annotations
@Nonnull()
def version(arg0: Call[ResponseBody]): String
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
Annotations
@Nonnull()

Inherited from AnyRef

Value Members

final def !=(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def ##: Int
Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean
Definition Classes
AnyRef → Any
def clone(): AnyRef
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
final def eq(arg0: AnyRef): Boolean
Definition Classes
AnyRef
def equals(arg0: AnyRef): Boolean
Definition Classes
AnyRef → Any
final def getClass(): Class[_ <: AnyRef]
Definition Classes
AnyRef → Any
Annotations
@native() @IntrinsicCandidate()
def hashCode(): Int
Definition Classes
AnyRef → Any
Annotations
@native() @IntrinsicCandidate()
final def ne(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def notify(): Unit
Definition Classes
AnyRef
Annotations
@native() @IntrinsicCandidate()
final def notifyAll(): Unit
Definition Classes
AnyRef
Annotations
@native() @IntrinsicCandidate()
final def synchronized[T0](arg0: => T0): T0
Definition Classes
AnyRef
def toString(): String
Definition Classes
AnyRef → Any
final def wait(arg0: Long, arg1: Int): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
def finalize(): Unit
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.Throwable]) @Deprecated @Deprecated
Deprecated

Inherited from Any

Value Members

final def asInstanceOf[T0]: T0
Definition Classes
Any
final def isInstanceOf[T0]: Boolean
Definition Classes
Any

Ungrouped

final def !=(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def ##: Int
Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0
Definition Classes
Any
def clone(): AnyRef
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
final def eq(arg0: AnyRef): Boolean
Definition Classes
AnyRef
def equals(arg0: AnyRef): Boolean
Definition Classes
AnyRef → Any
def execute[T <: AnyRef](arg0: Call[T]): T
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
Annotations
@throws(classOf[com.influxdb.exceptions.InfluxException])
final def getClass(): Class[_ <: AnyRef]
Definition Classes
AnyRef → Any
Annotations
@native() @IntrinsicCandidate()
def getLogLevel(arg0: HttpLoggingInterceptor): LogLevel
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
Annotations
@Nonnull()
def hashCode(): Int
Definition Classes
AnyRef → Any
Annotations
@native() @IntrinsicCandidate()
final def isInstanceOf[T0]: Boolean
Definition Classes
Any
final def ne(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def notify(): Unit
Definition Classes
AnyRef
Annotations
@native() @IntrinsicCandidate()
final def notifyAll(): Unit
Definition Classes
AnyRef
Annotations
@native() @IntrinsicCandidate()
def ping(arg0: Call[ResponseBody]): Boolean
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
Annotations
@Nonnull()
def responseToError(arg0: Response[_ <: AnyRef]): InfluxException
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
Annotations
@Nonnull()
def setLogLevel(arg0: HttpLoggingInterceptor, arg1: LogLevel): Unit
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
final def synchronized[T0](arg0: => T0): T0
Definition Classes
AnyRef
def toInfluxException(arg0: Throwable): InfluxException
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
Annotations
@Nonnull()
def toMeasurementBatch[M <: AnyRef](arg0: M, arg1: WritePrecision): BatchWriteDataMeasurement
Attributes
protected[client.internal]
Definition Classes
AbstractWriteBlockingClient
Annotations
@Nonnull()
def toString(): String
Definition Classes
AnyRef → Any
def version(arg0: Call[ResponseBody]): String
Attributes
protected[influxdb.internal]
Definition Classes
AbstractRestClient
Annotations
@Nonnull()
final def wait(arg0: Long, arg1: Int): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
def write(arg0: WriteParameters, arg1: Stream[BatchWriteData]): Unit
Attributes
protected[client.internal]
Definition Classes
AbstractWriteBlockingClient
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
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
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
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
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
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
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
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
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
def finalize(): Unit
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.Throwable]) @Deprecated @Deprecated
Deprecated

Packages

WriteScalaApiImpl

class WriteScalaApiImpl extends AbstractWriteBlockingClient with WriteScalaApi

Instance Constructors

Value Members

Deprecated Value Members

Inherited from AbstractWriteBlockingClient

Value Members

Inherited from AbstractRestClient

Value Members

Inherited from AnyRef

Value Members

Inherited from Any

Value Members

Ungrouped

Packages

WriteScalaApiImpl

class WriteScalaApiImpl extends AbstractWriteBlockingClient with WriteScalaApi

Instance Constructors

Value Members

Deprecated Value Members

Inherited from AbstractWriteBlockingClient

Value Members

Inherited from AbstractRestClient

Value Members

Inherited from AnyRef

Value Members

Inherited from Any

Value Members

Ungrouped

WriteScalaApiImpl