public class StorageApiWriteUnshardedRecords<DestinationT,ElementT>
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<DestinationT,ElementT>>,org.apache.beam.sdk.values.PCollection<java.lang.Void>>
Constructor and Description |
---|
StorageApiWriteUnshardedRecords(org.apache.beam.sdk.io.gcp.bigquery.StorageApiDynamicDestinations<ElementT,DestinationT> dynamicDestinations,
BigQueryIO.Write.CreateDisposition createDisposition,
java.lang.String kmsKey,
BigQueryServices bqServices,
org.apache.beam.sdk.coders.Coder<DestinationT> destinationCoder) |
Modifier and Type | Method and Description |
---|---|
org.apache.beam.sdk.values.PCollection<java.lang.Void> |
expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<DestinationT,ElementT>> input) |
public StorageApiWriteUnshardedRecords(org.apache.beam.sdk.io.gcp.bigquery.StorageApiDynamicDestinations<ElementT,DestinationT> dynamicDestinations, BigQueryIO.Write.CreateDisposition createDisposition, java.lang.String kmsKey, BigQueryServices bqServices, org.apache.beam.sdk.coders.Coder<DestinationT> destinationCoder)
public org.apache.beam.sdk.values.PCollection<java.lang.Void> expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<DestinationT,ElementT>> input)
expand
in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<DestinationT,ElementT>>,org.apache.beam.sdk.values.PCollection<java.lang.Void>>