Package org.apache.beam.sdk.io.gcp.bigtable

Class BigtableWriteResult

java.lang.Object

org.apache.beam.sdk.io.gcp.bigtable.BigtableWriteResult

@DefaultCoder(BigtableWriteResultCoder.class)
public abstract class BigtableWriteResult
extends Object

The result of writing a batch of rows to Bigtable. Rows are written to bigtable in batches (based on the runner-chosen bundle size). Once each batch finishes, a single BigtableWriteResult is emitted.

Constructor Summary

Constructors

Constructor	Description
BigtableWriteResult()

Method Summary

Modifier and Type	Method	Description
static BigtableWriteResult	create(long rowsWritten)
abstract long	getRowsWritten()	The number of rows written in this batch.

Methods inherited from class java.lang.Object

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

Constructor Details

BigtableWriteResult

public BigtableWriteResult()

Method Details

create

public static BigtableWriteResult create(long rowsWritten)

getRowsWritten

public abstract long getRowsWritten()

The number of rows written in this batch.