Package org.apache.beam.sdk.io.influxdb

Class InfluxDbIO.Write

  • All Implemented Interfaces:
    java.io.Serializable, org.apache.beam.sdk.transforms.display.HasDisplayData
    Enclosing class:
    InfluxDbIO
    public abstract static class InfluxDbIO.Write
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<java.lang.String>,​org.apache.beam.sdk.values.PDone>
    A PTransform to write to a InfluxDB datasource.
    See Also:
    Serialized Form

    • Field Summary

      • Fields inherited from class org.apache.beam.sdk.transforms.PTransform

        annotations, displayData, name, resourceHints

    • Constructor Summary

      Constructors 
      Constructor Description
      Write()  

    • Constructor Detail

      • Write

        public Write()

    • Method Detail

      • expand

        public org.apache.beam.sdk.values.PDone expand​(org.apache.beam.sdk.values.PCollection<java.lang.String> input)
        Specified by:
        expand in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<java.lang.String>,​org.apache.beam.sdk.values.PDone>

      • populateDisplayData

        public void populateDisplayData​(org.apache.beam.sdk.transforms.display.DisplayData.Builder builder)
        Specified by:
        populateDisplayData in interface org.apache.beam.sdk.transforms.display.HasDisplayData
        Overrides:
        populateDisplayData in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<java.lang.String>,​org.apache.beam.sdk.values.PDone>

      • withBatchSize

        public InfluxDbIO.Write withBatchSize​(int batchSize)
        Number of elements to batch. *

      • withDisableCertificateValidation

        public InfluxDbIO.Write withDisableCertificateValidation​(boolean disableCertificateValidation)
        Disable SSL certification validation. *

      • withRetentionPolicy

        public InfluxDbIO.Write withRetentionPolicy​(java.lang.String rp)
        Sets the retention policy to use. *

      • withConsistencyLevel

        public InfluxDbIO.Write withConsistencyLevel​(org.influxdb.InfluxDB.ConsistencyLevel consistencyLevel)
        Sets the consistency level to use. ALL("all") Write succeeds only if write reached all cluster members. ANY("any") Write succeeds if write reached at least one cluster members. ONE("one") Write succeeds if write reached at least one cluster members. QUORUM("quorum") Write succeeds only if write reached a quorum of cluster members.

      • withDatabase

        public InfluxDbIO.Write withDatabase​(java.lang.String database)
        Writes to the specified database.