C D E G I O P R W
All Classes All Packages

C

create(ValueProvider<String>, ValueProvider<String>, ValueProvider<String>) - Static method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO.DataSourceConfiguration

D

DataSourceConfiguration() - Constructor for class org.apache.beam.sdk.io.influxdb.InfluxDbIO.DataSourceConfiguration

E

expand(PBegin) - Method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Read

expand(PCollection<String>) - Method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Write

G

getConnection(InfluxDbIO.DataSourceConfiguration, boolean) - Static method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO

I

InfluxDbIO - Class in org.apache.beam.sdk.io.influxdb

IO to read and write from InfluxDB.

InfluxDbIO.DataSourceConfiguration - Class in org.apache.beam.sdk.io.influxdb

A POJO describing a DataSourceConfiguration such as URL, userName and password.

InfluxDbIO.Read - Class in org.apache.beam.sdk.io.influxdb

A PTransform to read from InfluxDB metric or data related to query.

InfluxDbIO.Write - Class in org.apache.beam.sdk.io.influxdb

A PTransform to write to a InfluxDB datasource.

O

org.apache.beam.sdk.io.influxdb - package org.apache.beam.sdk.io.influxdb

Transforms for reading and writing from/to InfluxDB.

P

populateDisplayData(DisplayData.Builder) - Method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Read

populateDisplayData(DisplayData.Builder) - Method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Write

R

read() - Static method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO

Read() - Constructor for class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Read

W

withBatchSize(int) - Method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Write

Number of elements to batch.

withConsistencyLevel(InfluxDB.ConsistencyLevel) - Method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Write

Sets the consistency level to use.

withDatabase(String) - Method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Read

Reads from the specified database.

withDatabase(String) - Method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Write

Writes to the specified database.

withDataSourceConfiguration(InfluxDbIO.DataSourceConfiguration) - Method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Read

Reads from the InfluxDB instance indicated by the given configuration.

withDataSourceConfiguration(InfluxDbIO.DataSourceConfiguration) - Method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Write

Writes to the InfluxDB instance indicated by the given configuration.

withDisableCertificateValidation(boolean) - Method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Read

Disable SSL certification validation.

withDisableCertificateValidation(boolean) - Method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Write

Disable SSL certification validation.

withFromDateTime(String) - Method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Read

Read metric data from the fromDateTime.

withMetric(String) - Method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Read

Sets the metric to use.

withQuery(String) - Method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Read

Sets the query to use.

withRetentionPolicy(String) - Method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Read

Sets the retention policy to use.

withRetentionPolicy(String) - Method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Write

Sets the retention policy to use.

withToDateTime(String) - Method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Read

Read metric data till the toDateTime.

write() - Static method in class org.apache.beam.sdk.io.influxdb.InfluxDbIO

Write() - Constructor for class org.apache.beam.sdk.io.influxdb.InfluxDbIO.Write

C D E G I O P R W
All Classes All Packages