CloudBigtableIO.CloudBigtableMultiTableWriteFn (Apache Beam + Cloud Bigtable Connector 1.12.0 API)

Stay organized with collections Save and categorize content based on your preferences.
com.google.cloud.bigtable.beam

Class CloudBigtableIO.CloudBigtableMultiTableWriteFn

  • All Implemented Interfaces:
    Serializable, HasDisplayData
    Enclosing class:
    CloudBigtableIO

    public static class CloudBigtableIO.CloudBigtableMultiTableWriteFn
extends AbstractCloudBigtableTableDoFn<InputType,Void>
    A DoFn that can write either a bounded or unbounded PCollection of KV of (String tableName, List of Mutations) to the specified table.

    NOTE: This DoFn will write Puts and Deletes, not Appends and Increments. This limitation exists because if the batch fails partway through, Appends/Increments might be re-run, causing the Mutation to be executed twice, which is never the user's intent. Re-running a Delete will not cause any differences. Re-running a Put isn't normally a problem, but might cause problems in some cases when the number of versions supported by the column family is greater than one. In a case where multiple versions could be a problem, it's best to add a timestamp to the Put.

    See Also:
    Serialized Form