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[TableRow] = TableWriteParam.DefaultConfigOverride): ClosedTap[TableRow]

   Save this SCollection as a BigQuery table.

   Save this SCollection as a BigQuery table. Note that elements must be of type TableRow.

   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 saveAsTableRowJsonFile(path: String, numShards: Int = TableRowJsonWriteParam.DefaultNumShards, suffix: String = TableRowJsonWriteParam.DefaultSuffix, compression: Compression = TableRowJsonWriteParam.DefaultCompression, shardNameTemplate: String = TableRowJsonWriteParam.DefaultShardNameTemplate, tempDirectory: String = TableRowJsonWriteParam.DefaultTempDirectory, filenamePolicySupplier: FilenamePolicySupplier = TableRowJsonWriteParam.DefaultFilenamePolicySupplier, prefix: String = TableRowJsonWriteParam.DefaultPrefix): ClosedTap[TableRow]

   Save this SCollection as a BigQuery TableRow JSON text file.

   Save this SCollection as a BigQuery TableRow JSON text file. Note that elements must be of type TableRow.

   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.

9.  def toString(): String

   Definition Classes

   Any