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

Class StorageApiWritePayload

java.lang.Object

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

@DefaultSchema(AutoValueSchema.class)
public abstract class StorageApiWritePayload
extends Object

Class used to wrap elements being sent to the Storage API sinks.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StorageApiWritePayload.Builder

Constructor Summary

Constructors

Constructor	Description
StorageApiWritePayload()

Method Summary

Modifier and Type	Method	Description
TableRow	getFailsafeTableRow()
abstract byte[]	getFailsafeTableRowPayload()
abstract byte[]	getPayload()
abstract Instant	getTimestamp()
TableRow	getUnknownFields()
abstract byte[]	getUnknownFieldsPayload()
abstract StorageApiWritePayload.Builder	toBuilder()
StorageApiWritePayload	withTimestamp(Instant instant)

Methods inherited from class java.lang.Object

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

Constructor Details

StorageApiWritePayload

public StorageApiWritePayload()

Method Details

getPayload

public abstract byte[] getPayload()

getUnknownFieldsPayload

@Nullable
public abstract byte[] getUnknownFieldsPayload()

getTimestamp

@Nullable
public abstract Instant getTimestamp()

getFailsafeTableRowPayload

@Nullable
public abstract byte[] getFailsafeTableRowPayload()

toBuilder

public abstract StorageApiWritePayload.Builder toBuilder()

withTimestamp

public StorageApiWritePayload withTimestamp(Instant instant)

getUnknownFields

@Memoized
@Nullable
public TableRow getUnknownFields()
                          throws IOException

Throws:

IOException

getFailsafeTableRow

@Memoized
@Nullable
public TableRow getFailsafeTableRow()
                             throws IOException

Throws:

IOException