com.influxdb.client.reactive.internal

Class WriteReactiveApiImpl

java.lang.Object

com.influxdb.internal.AbstractRestClient

com.influxdb.client.internal.AbstractWriteClient

com.influxdb.client.reactive.internal.WriteReactiveApiImpl

All Implemented Interfaces:

WriteReactiveApi, AutoCloseable

public class WriteReactiveApiImpl
extends AbstractWriteClient
implements WriteReactiveApi

Author:

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

Nested Class Summary

Nested classes/interfaces inherited from class com.influxdb.client.internal.AbstractWriteClient

AbstractWriteClient.BatchWriteData, AbstractWriteClient.BatchWriteDataMeasurement, AbstractWriteClient.BatchWriteDataPoint, AbstractWriteClient.BatchWriteDataRecord

Field Summary

Fields inherited from class com.influxdb.client.internal.AbstractWriteClient

measurementMapper, options

Method Summary

Modifier and Type	Method and Description
void	close() Close threads for asynchronous batch writing.
<T extends AbstractWriteEvent> io.reactivex.Observable<T>	listenEvents(Class<T> eventType) Listen the events produced by WriteApi.
<M> void	writeMeasurement(String bucket, String org, WritePrecision precision, io.reactivex.Maybe<M> measurement) Write Measurement into specified bucket.
<M> void	writeMeasurement(WritePrecision precision, io.reactivex.Maybe<M> measurement) Write Measurement into specified bucket.
<M> void	writeMeasurements(String bucket, String org, WritePrecision precision, io.reactivex.Flowable<M> measurements) Write Measurements into specified bucket.
<M> void	writeMeasurements(String bucket, String org, WritePrecision precision, org.reactivestreams.Publisher<M> measurements) Write Measurements into specified bucket.
<M> void	writeMeasurements(WritePrecision precision, io.reactivex.Flowable<M> measurements) Write Measurements into specified bucket.
<M> void	writeMeasurements(WritePrecision precision, org.reactivestreams.Publisher<M> measurements) Write Measurements into specified bucket.
void	writePoint(io.reactivex.Maybe<Point> point) Write Data point into specified bucket.
void	writePoint(String bucket, String org, io.reactivex.Maybe<Point> point) Write Data point into specified bucket.
void	writePoints(io.reactivex.Flowable<Point> points) Write Data points into specified bucket.
void	writePoints(org.reactivestreams.Publisher<Point> points) Write Data points into specified bucket.
void	writePoints(String bucket, String org, io.reactivex.Flowable<Point> points) Write Data points into specified bucket.
void	writePoints(String bucket, String org, org.reactivestreams.Publisher<Point> points) Write Data points into specified bucket.
void	writeRecord(String bucket, String org, WritePrecision precision, io.reactivex.Maybe<String> record) Write Line Protocol record into specified bucket.
void	writeRecord(WritePrecision precision, io.reactivex.Maybe<String> record) Write Line Protocol record into specified bucket.
void	writeRecords(String bucket, String org, WritePrecision precision, io.reactivex.Flowable<String> records) Write Line Protocol records into specified bucket.
void	writeRecords(String bucket, String org, WritePrecision precision, org.reactivestreams.Publisher<String> records) Write Line Protocol records into specified bucket.
void	writeRecords(WritePrecision precision, io.reactivex.Flowable<String> records) Write Line Protocol records into specified bucket.
void	writeRecords(WritePrecision precision, org.reactivestreams.Publisher<String> records) Write Line Protocol records into specified bucket.

Methods inherited from class com.influxdb.client.internal.AbstractWriteClient

addEventListener, flush, write, write

Methods inherited from class com.influxdb.internal.AbstractRestClient

execute, getLogLevel, responseToError, setLogLevel

Methods inherited from class java.lang.Object

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

Method Detail

writeRecord

public void writeRecord(@Nonnull
                        WritePrecision precision,
                        @Nonnull
                        io.reactivex.Maybe<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 (optional)

record - specifies the record in InfluxDB Line Protocol. The record is considered as one batch unit.

writeRecord

public void writeRecord(@Nonnull
                        String bucket,
                        @Nonnull
                        String org,
                        @Nonnull
                        WritePrecision precision,
                        @Nonnull
                        io.reactivex.Maybe<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 (optional)

record - specifies the record in InfluxDB Line Protocol. The record is considered as one batch unit.

writeRecords

public void writeRecords(@Nonnull
                         WritePrecision precision,
                         @Nonnull
                         io.reactivex.Flowable<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 (optional)

records - specifies the records in InfluxDB Line Protocol

writeRecords

public void writeRecords(@Nonnull
                         String bucket,
                         @Nonnull
                         String org,
                         @Nonnull
                         WritePrecision precision,
                         @Nonnull
                         io.reactivex.Flowable<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 (optional)

records - specifies the records in InfluxDB Line Protocol

writeRecords

public void 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 (optional)

records - specifies the records in InfluxDB Line Protocol

writeRecords

public void 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 (optional)

records - specifies the records in InfluxDB Line Protocol

writePoint

public void writePoint(@Nonnull
                       io.reactivex.Maybe<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:

point - specifies the Data point to write into bucket

writePoint

public void writePoint(@Nonnull
                       String bucket,
                       @Nonnull
                       String org,
                       @Nonnull
                       io.reactivex.Maybe<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

point - specifies the Data point to write into bucket

writePoints

public void writePoints(@Nonnull
                        io.reactivex.Flowable<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:

points - specifies the Data points to write into bucket

writePoints

public void writePoints(@Nonnull
                        String bucket,
                        @Nonnull
                        String org,
                        @Nonnull
                        io.reactivex.Flowable<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

points - specifies the Data points to write into bucket

writePoints

public void writePoints(@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:

points - specifies the Data points to write into bucket

writePoints

public void writePoints(@Nonnull
                        String bucket,
                        @Nonnull
                        String org,
                        @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

points - specifies the Data points to write into bucket

writeMeasurement

public <M> void writeMeasurement(@Nonnull
                                 WritePrecision precision,
                                 @Nonnull
                                 io.reactivex.Maybe<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 (optional)

measurement - specifies the Measurement to write into bucket

writeMeasurement

public <M> void writeMeasurement(@Nonnull
                                 String bucket,
                                 @Nonnull
                                 String org,
                                 @Nonnull
                                 WritePrecision precision,
                                 @Nonnull
                                 io.reactivex.Maybe<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 (optional)

measurement - specifies the Measurement to write into bucket

writeMeasurements

public <M> void writeMeasurements(@Nonnull
                                  WritePrecision precision,
                                  @Nonnull
                                  io.reactivex.Flowable<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 (optional)

measurements - specifies the Measurements to write into bucket

writeMeasurements

public <M> void writeMeasurements(@Nonnull
                                  String bucket,
                                  @Nonnull
                                  String org,
                                  @Nonnull
                                  WritePrecision precision,
                                  @Nonnull
                                  io.reactivex.Flowable<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 (optional)

measurements - specifies the Measurements to write into bucket

writeMeasurements

public <M> void 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 (optional)

measurements - specifies the Measurements to write into bucket

writeMeasurements

public <M> void 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 (optional)

measurements - specifies the Measurements to write into bucket

listenEvents

@Nonnull
public <T extends AbstractWriteEvent> io.reactivex.Observable<T> listenEvents(@Nonnull
                                                                                       Class<T> eventType)

Description copied from interface: WriteReactiveApi

Listen the events produced by WriteApi.

The WriteApi produces: WriteSuccessEvent, BackpressureEvent, WriteErrorEvent and WriteRetriableErrorEvent.

Specified by:

listenEvents in interface WriteReactiveApi

Type Parameters:

T - type of event to listen

Parameters:

eventType - type of event to listen

Returns:

lister for eventType events

close

public void close()

Description copied from interface: WriteReactiveApi

Close threads for asynchronous batch writing.

Specified by:

close in interface WriteReactiveApi

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractWriteClient