Package com.influxdb.client.reactive.internal

Class WriteReactiveApiImpl

java.lang.Object

com.influxdb.internal.AbstractRestClient

com.influxdb.client.reactive.internal.WriteReactiveApiImpl

All Implemented Interfaces:

WriteReactiveApi

public class WriteReactiveApiImpl
extends AbstractRestClient
implements WriteReactiveApi

Author:

Jakub Bednar (bednar@github) (22/11/2018 06:50)

Nested Class Summary

Nested classes/interfaces inherited from interface com.influxdb.client.reactive.WriteReactiveApi

WriteReactiveApi.Success

Method Summary

Modifier and Type	Method	Description
<M> org.reactivestreams.Publisher<WriteReactiveApi.Success>	writeMeasurement(WritePrecision precision, M measurement)	Write Measurement into specified bucket.
<M> org.reactivestreams.Publisher<WriteReactiveApi.Success>	writeMeasurement(String bucket, String org, WritePrecision precision, M measurement)	Write Measurement into specified bucket.
<M> org.reactivestreams.Publisher<WriteReactiveApi.Success>	writeMeasurements(WritePrecision precision, org.reactivestreams.Publisher<M> measurements)	Write Measurements into specified bucket.
<M> org.reactivestreams.Publisher<WriteReactiveApi.Success>	writeMeasurements(String bucket, String org, WritePrecision precision, org.reactivestreams.Publisher<M> measurements)	Write Measurements into specified bucket.
<M> org.reactivestreams.Publisher<WriteReactiveApi.Success>	writeMeasurements(org.reactivestreams.Publisher<M> measurements, WriteParameters parameters)	Write Measurements into specified bucket.
org.reactivestreams.Publisher<WriteReactiveApi.Success>	writePoint(WritePrecision precision, Point point)	Write Data point into specified bucket.
org.reactivestreams.Publisher<WriteReactiveApi.Success>	writePoint(String bucket, String org, WritePrecision precision, Point point)	Write Data point into specified bucket.
org.reactivestreams.Publisher<WriteReactiveApi.Success>	writePoints(WritePrecision precision, org.reactivestreams.Publisher<Point> points)	Write Data points into specified bucket.
org.reactivestreams.Publisher<WriteReactiveApi.Success>	writePoints(String bucket, String org, WritePrecision precision, org.reactivestreams.Publisher<Point> points)	Write Data points into specified bucket.
org.reactivestreams.Publisher<WriteReactiveApi.Success>	writePoints(org.reactivestreams.Publisher<Point> points, WriteParameters parameters)	Write Data points into specified bucket.
org.reactivestreams.Publisher<WriteReactiveApi.Success>	writeRecord(WritePrecision precision, String record)	Write Line Protocol record into specified bucket.
org.reactivestreams.Publisher<WriteReactiveApi.Success>	writeRecord(String bucket, String org, WritePrecision precision, String record)	Write Line Protocol record into specified bucket.
org.reactivestreams.Publisher<WriteReactiveApi.Success>	writeRecords(WritePrecision precision, org.reactivestreams.Publisher<String> records)	Write Line Protocol records into specified bucket.
org.reactivestreams.Publisher<WriteReactiveApi.Success>	writeRecords(String bucket, String org, WritePrecision precision, org.reactivestreams.Publisher<String> records)	Write Line Protocol records into specified bucket.
org.reactivestreams.Publisher<WriteReactiveApi.Success>	writeRecords(org.reactivestreams.Publisher<String> records, WriteParameters parameters)	Write Line Protocol records into specified bucket.

Methods inherited from class com.influxdb.internal.AbstractRestClient

execute, getLogLevel, ping, responseToError, setLogLevel, toInfluxException, version

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

writeRecord

public org.reactivestreams.Publisher<WriteReactiveApi.Success> writeRecord(@Nonnull
 WritePrecision precision,
 @Nullable
 String record)

Description copied from interface: WriteReactiveApi

Write Line Protocol record into specified bucket.

The InfluxDBClientOptions.getBucket() will be use as destination bucket and InfluxDBClientOptions.getOrg() will be used as destination organization.

Specified by:

writeRecord in interface WriteReactiveApi

Parameters:

precision - specifies the precision for the unix timestamps within the body line-protocol

record - specifies the record in InfluxDB Line Protocol.

Returns:

Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

writeRecord

public org.reactivestreams.Publisher<WriteReactiveApi.Success> writeRecord(@Nonnull
 String bucket,
 @Nonnull
 String org,
 @Nonnull
 WritePrecision precision,
 @Nullable
 String record)

Description copied from interface: WriteReactiveApi

Write Line Protocol record into specified bucket.

Specified by:

writeRecord in interface WriteReactiveApi

Parameters:

bucket - specifies the destination bucket for writes

org - specifies the destination organization for writes

precision - specifies the precision for the unix timestamps within the body line-protocol

record - specifies the record in InfluxDB Line Protocol.

Returns:

Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

writeRecords

public org.reactivestreams.Publisher<WriteReactiveApi.Success> writeRecords(@Nonnull
 WritePrecision precision,
 @Nonnull
 org.reactivestreams.Publisher<String> records)

Description copied from interface: WriteReactiveApi

Write Line Protocol records into specified bucket.

The InfluxDBClientOptions.getBucket() will be use as destination bucket and InfluxDBClientOptions.getOrg() will be used as destination organization.

Specified by:

writeRecords in interface WriteReactiveApi

Parameters:

precision - specifies the precision for the unix timestamps within the body line-protocol

records - specifies the records in InfluxDB Line Protocol

Returns:

Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

writeRecords

public org.reactivestreams.Publisher<WriteReactiveApi.Success> writeRecords(@Nonnull
 String bucket,
 @Nonnull
 String org,
 @Nonnull
 WritePrecision precision,
 @Nonnull
 org.reactivestreams.Publisher<String> records)

Description copied from interface: WriteReactiveApi

Write Line Protocol records into specified bucket.

Specified by:

writeRecords in interface WriteReactiveApi

Parameters:

bucket - specifies the destination bucket for writes

org - specifies the destination organization for writes

precision - specifies the precision for the unix timestamps within the body line-protocol

records - specifies the records in InfluxDB Line Protocol

Returns:

Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

writeRecords

public org.reactivestreams.Publisher<WriteReactiveApi.Success> writeRecords(@Nonnull
 org.reactivestreams.Publisher<String> records,
 @Nonnull
 WriteParameters parameters)

Description copied from interface: WriteReactiveApi

Write Line Protocol records into specified bucket.

Specified by:

writeRecords in interface WriteReactiveApi

Parameters:

records - specifies the records in InfluxDB Line Protocol

parameters - specify InfluxDB Write endpoint parameters

Returns:

Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

writePoint

public org.reactivestreams.Publisher<WriteReactiveApi.Success> writePoint(@Nonnull
 WritePrecision precision,
 @Nonnull
 Point point)

Description copied from interface: WriteReactiveApi

Write Data point into specified bucket.

The InfluxDBClientOptions.getBucket() will be use as destination bucket and InfluxDBClientOptions.getOrg() will be used as destination organization.

Specified by:

writePoint in interface WriteReactiveApi

Parameters:

precision - specifies the precision for the unix timestamps within the body line-protocol

point - specifies the Data point to write into bucket

Returns:

Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

writePoint

public org.reactivestreams.Publisher<WriteReactiveApi.Success> writePoint(@Nonnull
 String bucket,
 @Nonnull
 String org,
 @Nonnull
 WritePrecision precision,
 @Nonnull
 Point point)

Description copied from interface: WriteReactiveApi

Write Data point into specified bucket.

Specified by:

writePoint in interface WriteReactiveApi

Parameters:

bucket - specifies the destination bucket for writes

org - specifies the destination organization for writes

precision - specifies the precision for the unix timestamps within the body line-protocol

point - specifies the Data point to write into bucket

Returns:

Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

writePoints

public org.reactivestreams.Publisher<WriteReactiveApi.Success> writePoints(@Nonnull
 WritePrecision precision,
 @Nonnull
 org.reactivestreams.Publisher<Point> points)

Description copied from interface: WriteReactiveApi

Write Data points into specified bucket.

The InfluxDBClientOptions.getBucket() will be use as destination bucket and InfluxDBClientOptions.getOrg() will be used as destination organization.

Specified by:

writePoints in interface WriteReactiveApi

Parameters:

precision - specifies the precision for the unix timestamps within the body line-protocol

points - specifies the Data points to write into bucket

Returns:

Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

writePoints

public org.reactivestreams.Publisher<WriteReactiveApi.Success> writePoints(@Nonnull
 String bucket,
 @Nonnull
 String org,
 @Nonnull
 WritePrecision precision,
 @Nonnull
 org.reactivestreams.Publisher<Point> points)

Description copied from interface: WriteReactiveApi

Write Data points into specified bucket.

Specified by:

writePoints in interface WriteReactiveApi

Parameters:

bucket - specifies the destination bucket ID for writes

org - specifies the destination organization ID for writes

precision - specifies the precision for the unix timestamps within the body line-protocol

points - specifies the Data points to write into bucket

Returns:

Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

writePoints

public org.reactivestreams.Publisher<WriteReactiveApi.Success> writePoints(@Nonnull
 org.reactivestreams.Publisher<Point> points,
 @Nonnull
 WriteParameters parameters)

Description copied from interface: WriteReactiveApi

Write Data points into specified bucket.

Specified by:

writePoints in interface WriteReactiveApi

Parameters:

points - specifies the Data points to write into bucket

parameters - specify InfluxDB Write endpoint parameters

Returns:

Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

writeMeasurement

public <M>
org.reactivestreams.Publisher<WriteReactiveApi.Success> writeMeasurement(@Nonnull
 WritePrecision precision,
 @Nonnull
 M measurement)

Description copied from interface: WriteReactiveApi

Write Measurement into specified bucket.

The InfluxDBClientOptions.getBucket() will be use as destination bucket and InfluxDBClientOptions.getOrg() will be used as destination organization.

Specified by:

writeMeasurement in interface WriteReactiveApi

Type Parameters:

M - type of measurement

Parameters:

precision - specifies the precision for the unix timestamps within the body line-protocol

measurement - specifies the Measurement to write into bucket

Returns:

Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

writeMeasurement

public <M>
org.reactivestreams.Publisher<WriteReactiveApi.Success> writeMeasurement(@Nonnull
 String bucket,
 @Nonnull
 String org,
 @Nonnull
 WritePrecision precision,
 @Nonnull
 M measurement)

Description copied from interface: WriteReactiveApi

Write Measurement into specified bucket.

Specified by:

writeMeasurement in interface WriteReactiveApi

Type Parameters:

M - type of measurement

Parameters:

bucket - specifies the destination bucket for writes

org - specifies the destination organization for writes

precision - specifies the precision for the unix timestamps within the body line-protocol

measurement - specifies the Measurement to write into bucket

Returns:

Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

writeMeasurements

public <M>
org.reactivestreams.Publisher<WriteReactiveApi.Success> writeMeasurements(@Nonnull
 WritePrecision precision,
 @Nonnull
 org.reactivestreams.Publisher<M> measurements)

Description copied from interface: WriteReactiveApi

Write Measurements into specified bucket.

The InfluxDBClientOptions.getBucket() will be use as destination bucket and InfluxDBClientOptions.getOrg() will be used as destination organization.

Specified by:

writeMeasurements in interface WriteReactiveApi

Type Parameters:

M - type of measurement

Parameters:

precision - specifies the precision for the unix timestamps within the body line-protocol

measurements - specifies the Measurements to write into bucket

Returns:

Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

writeMeasurements

public <M>
org.reactivestreams.Publisher<WriteReactiveApi.Success> writeMeasurements(@Nonnull
 String bucket,
 @Nonnull
 String org,
 @Nonnull
 WritePrecision precision,
 @Nonnull
 org.reactivestreams.Publisher<M> measurements)

Description copied from interface: WriteReactiveApi

Write Measurements into specified bucket.

Specified by:

writeMeasurements in interface WriteReactiveApi

Type Parameters:

M - type of measurement

Parameters:

bucket - specifies the destination bucket for writes

org - specifies the destination organization for writes

precision - specifies the precision for the unix timestamps within the body line-protocol

measurements - specifies the Measurements to write into bucket

Returns:

Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

writeMeasurements

public <M>
org.reactivestreams.Publisher<WriteReactiveApi.Success> writeMeasurements(@Nonnull
 org.reactivestreams.Publisher<M> measurements,
 @Nonnull
 WriteParameters parameters)

Description copied from interface: WriteReactiveApi

Write Measurements into specified bucket.

Specified by:

writeMeasurements in interface WriteReactiveApi

Type Parameters:

M - type of measurement

Parameters:

measurements - specifies the Measurements to write into bucket

parameters - specify InfluxDB Write endpoint parameters

Returns:

Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)