org.apache.beam.sdk.io.gcp.bigquery

Class RowMutationInformation

java.lang.Object

org.apache.beam.sdk.io.gcp.bigquery.RowMutationInformation

public abstract class RowMutationInformation
extends java.lang.Object

This class indicates how to apply a row update to BigQuery. A sequence number must always be supplied to order the updates. Incorrect sequence numbers will result in unexpected state in the BigQuery table.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RowMutationInformation.MutationType

Constructor Summary

Constructors

Constructor and Description
RowMutationInformation()

Method Summary

Modifier and Type	Method and Description
abstract RowMutationInformation.MutationType	getMutationType()
abstract long	getSequenceNumber()
static RowMutationInformation	of(RowMutationInformation.MutationType mutationType, long sequenceNumber)

Methods inherited from class java.lang.Object

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

Constructor Detail

RowMutationInformation

public RowMutationInformation()

Method Detail

getMutationType

public abstract RowMutationInformation.MutationType getMutationType()

getSequenceNumber

public abstract long getSequenceNumber()

of

public static RowMutationInformation of(RowMutationInformation.MutationType mutationType,
                                        long sequenceNumber)