HBaseMutationCoder (Google Cloud Dataflow + Cloud Bigtable Connector 0.9.7.1 API)

com.google.cloud.bigtable.dataflow.coders

Class HBaseMutationCoder

  • All Implemented Interfaces:
    Coder<Mutation>, Serializable


    public class HBaseMutationCoder
    extends AtomicCoder<Mutation>
    When Dataflow notices a slowdown in executing Puts and Deletes, it will send those Puts and Deletes to be processed on another Dataflow machine. This class handles the serialization and deserialization of the Puts and Deletes.

    See CloudBigtableIO#initializeForWrite(Pipeline).

    See Also:
    Serialized Form


Monitor your resources on the go

Get the Google Cloud Console app to help you manage your projects.

Send feedback about...

Cloud Bigtable Documentation