HBaseMutationCoder (Google Cloud Dataflow + Cloud Bigtable Connector API)


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