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

Class StorageApiWritePayload

java.lang.Object

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

@DefaultSchema(value=AutoValueSchema.class)
public abstract class StorageApiWritePayload
extends java.lang.Object

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

Constructor Summary

Constructors

Constructor and Description
StorageApiWritePayload()

Method Summary

Modifier and Type	Method and Description
abstract byte[]	getPayload()
TableRow	getUnknownFields()
abstract byte[]	getUnknownFieldsPayload()

Methods inherited from class java.lang.Object

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

Constructor Detail

StorageApiWritePayload

public StorageApiWritePayload()

Method Detail

getPayload

public abstract byte[] getPayload()

getUnknownFieldsPayload

@Nullable
public abstract byte[] getUnknownFieldsPayload()

getUnknownFields

@Memoized
 @Nullable
public TableRow getUnknownFields()
                                               throws java.io.IOException

Throws:

java.io.IOException