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

Defines transforms for reading and writing from Google BigQuery.

See: Description

Interface Summary

Interface	Description
BigQueryOptions	Properties needed when using Google BigQuery with the Apache Beam SDK.

Class Summary

Class	Description
BigQueryCoderProviderRegistrar	A CoderProviderRegistrar for standard types used with BigQueryIO.
BigQueryHelpers	A set of helper functions and classes used by BigQueryIO.
BigQueryIO	PTransforms for reading and writing BigQuery tables.
BigQueryIO.Read	Implementation of BigQueryIO.read().
BigQueryIO.Write<T>	Implementation of BigQueryIO.write().
CreateTables<DestinationT>	Creates any tables needed before performing streaming writes to the tables.
DynamicDestinations<T,DestinationT>	This class provides the most general way of specifying dynamic BigQuery table destinations.
InsertRetryPolicy	A retry policy for streaming BigQuery inserts.
InsertRetryPolicy.Context	Contains information about a failed insert.
PrepareWrite<T,DestinationT>	Prepare an input PCollection for writing to BigQuery.
StreamingInserts<DestinationT>	PTransform that performs streaming BigQuery write.
StreamingWriteTables	This transform takes in key-value pairs of TableRow entries and the TableDestination it should be written to.
TableDestination	Encapsulates a BigQuery table destination.
TableDestinationCoder	A coder for TableDestination objects.
TableRowJsonCoder	A Coder that encodes BigQuery TableRow objects in their native JSON format.
WriteResult	The result of a BigQueryIO.Write transform.

Enum Summary

Enum	Description
BigQueryIO.Write.CreateDisposition	An enumeration type for the BigQuery create disposition strings.
BigQueryIO.Write.WriteDisposition	An enumeration type for the BigQuery write disposition strings.

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

Defines transforms for reading and writing from Google BigQuery.

See Also:

BigQueryIO