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

Class RowMutation

java.lang.Object

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

public abstract class RowMutation
extends Object

A convenience class for applying row updates to BigQuery using BigQueryIO.applyRowMutations(). This class encapsulates a TableRow payload along with information how to update the row. A sequence number must also 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	Description
static class	RowMutation.RowMutationCoder

Constructor Summary

Constructors

Constructor	Description
RowMutation()

Method Summary

Modifier and Type	Method	Description
abstract RowMutationInformation	getMutationInformation()
abstract com.google.api.services.bigquery.model.TableRow	getTableRow()
static RowMutation	of(com.google.api.services.bigquery.model.TableRow tableRow, RowMutationInformation rowMutationInformation)

Methods inherited from class java.lang.Object

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

Constructor Details

RowMutation

public RowMutation()

Method Details

getTableRow

public abstract com.google.api.services.bigquery.model.TableRow getTableRow()

getMutationInformation

public abstract RowMutationInformation getMutationInformation()

of

public static RowMutation of(com.google.api.services.bigquery.model.TableRow tableRow,
 RowMutationInformation rowMutationInformation)