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

com.google.cloud.bigtable.beam

Class CloudBigtableIO.CloudBigtableSingleTableBufferedWriteFn

• java.lang.Object
• • org.apache.beam.sdk.transforms.DoFn<In,Out>
  • • com.google.cloud.bigtable.beam.AbstractCloudBigtableTableDoFn<InputType,Void>
    • • com.google.cloud.bigtable.beam.CloudBigtableIO.CloudBigtableSingleTableBufferedWriteFn

• All Implemented Interfaces:

  Serializable, HasDisplayData

  Enclosing class:

  CloudBigtableIO

  ---

  
  

  public static class CloudBigtableIO.CloudBigtableSingleTableBufferedWriteFn
  extends AbstractCloudBigtableTableDoFn<InputType,Void>

  A DoFn that can write either a bounded or unbounded PCollection of Mutations to a table specified via a CloudBigtableTableConfiguration using the BufferedMutator.

  See Also:

  Serialized Form

• • Nested Class Summary

    • Nested classes/interfaces inherited from class org.apache.beam.sdk.transforms.DoFn

      DoFn.BoundedPerElement, DoFn.BundleFinalizer, DoFn.Element, DoFn.FieldAccess, DoFn.FinishBundle, DoFn.FinishBundleContext, DoFn.GetInitialRestriction, DoFn.GetRestrictionCoder, DoFn.MultiOutputReceiver, DoFn.NewTracker, DoFn.OnTimer, DoFn.OnTimerContext, DoFn.OnWindowExpiration, DoFn.OutputReceiver<T>, DoFn.ProcessContext, DoFn.ProcessContinuation, DoFn.ProcessElement, DoFn.RequiresStableInput, DoFn.Setup, DoFn.SplitRestriction, DoFn.StartBundle, DoFn.StartBundleContext, DoFn.StateId, DoFn.Teardown, DoFn.TimerId, DoFn.Timestamp, DoFn.UnboundedPerElement, DoFn.WindowedContext

  • Field Summary

    • Fields inherited from class com.google.cloud.bigtable.beam.AbstractCloudBigtableTableDoFn

      config, connection, DOFN_LOG

  • Constructor Summary

    Constructors 

    Constructor and Description
    CloudBigtableSingleTableBufferedWriteFn(CloudBigtableTableConfiguration config)

  • Method Summary

    All Methods Instance Methods Concrete Methods 

    Modifier and Type	Method and Description
    void	finishBundle(DoFn.FinishBundleContext context) Closes the BufferedMutator and Connection.
    void	processElement(DoFn.ProcessContext context) Performs an asynchronous mutation via BufferedMutator.mutate(Mutation).
    void	setupBufferedMutator(DoFn.StartBundleContext context)

    • Methods inherited from class com.google.cloud.bigtable.beam.AbstractCloudBigtableTableDoFn

      getConfig, getConnection, logExceptions, logRetriesExhaustedWithDetailsException, populateDisplayData, rethrowException

    • Methods inherited from class org.apache.beam.sdk.transforms.DoFn

      getAllowedTimestampSkew, getInputTypeDescriptor, getOutputTypeDescriptor, prepareForProcessing

    • Methods inherited from class java.lang.Object

      clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

• • Constructor Detail

    • CloudBigtableSingleTableBufferedWriteFn

      public CloudBigtableSingleTableBufferedWriteFn(CloudBigtableTableConfiguration config)

  • Method Detail

    • setupBufferedMutator

      @DoFn.StartBundle
      public void setupBufferedMutator(DoFn.StartBundleContext context)
                                                  throws IOException

      Throws:

      IOException

    • processElement

      @DoFn.ProcessElement
      public void processElement(DoFn.ProcessContext context)
                                               throws Exception

      Performs an asynchronous mutation via BufferedMutator.mutate(Mutation).

      Throws:

      Exception

    • finishBundle

      @DoFn.FinishBundle
      public void finishBundle(DoFn.FinishBundleContext context)
                                           throws Exception

      Closes the BufferedMutator and Connection.

      Throws:

      Exception