Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   Any

2.  final def ##: Int

   Definition Classes

   Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   Any

4.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

5.  def getClass(): Class[_ <: AnyVal]

   Definition Classes

   AnyVal → Any

6.  final def isInstanceOf[T0]: Boolean

   Definition Classes

   Any

7.  def saveAsBigQueryTable(table: Table, schema: TableSchema = TypedTableWriteParam.DefaultSchema, writeDisposition: WriteDisposition = TypedTableWriteParam.DefaultWriteDisposition, createDisposition: CreateDisposition = TypedTableWriteParam.DefaultCreateDisposition, tableDescription: String = TypedTableWriteParam.DefaultTableDescription, timePartitioning: TimePartitioning = TypedTableWriteParam.DefaultTimePartitioning, clustering: Clustering = TypedTableWriteParam.DefaultClustering, method: Method = TypedTableWriteParam.DefaultMethod, triggeringFrequency: Duration = TypedTableWriteParam.DefaultTriggeringFrequency, sharding: Sharding = TypedTableWriteParam.DefaultSharding, failedInsertRetryPolicy: InsertRetryPolicy = TypedTableWriteParam.DefaultFailedInsertRetryPolicy, successfulInsertsPropagation: Boolean = TableWriteParam.DefaultSuccessfulInsertsPropagation, extendedErrorInfo: Boolean = TypedTableWriteParam.DefaultExtendedErrorInfo, configOverride: BigQueryTypedTable.WriteParam.ConfigOverride[GenericRecord] = TypedTableWriteParam.DefaultConfigOverride): ClosedTap[GenericRecord]

   Save this SCollection as a BigQuery table using Avro writing function.

   Save this SCollection as a BigQuery table using Avro writing function. Note that elements must be of type GenericRecord.

   returns

   a ClosedTap containing some side output(s) depending on the given parameters

   • BigQueryIO.SuccessfulTableLoads if method is Method.FILE_LOADS.
   • BigQueryIO.SuccessfulInserts if method is Method.STREAMING_INSERTS and successfulInsertsPropagation is true.
   • BigQueryIO.SuccessfulStorageApiInserts if method id Method.STORAGE_WRITE_API or Method.STORAGE_API_AT_LEAST_ONCE.
   • BigQueryIO.FailedInserts if method is Method.FILE_LOADS or Method.STREAMING_INSERTS.
   • BigQueryIO.FailedInsertsWithErr if method is Method.STREAMING_INSERTS and extendedErrorInfo is true.
   • BigQueryIO.FailedStorageApiInserts if method id Method.STORAGE_WRITE_API or Method.STORAGE_API_AT_LEAST_ONCE.

8.  def toString(): String

   Definition Classes

   Any