public class StorageApiWritesShardedRecords<DestinationT,ElementT>
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<org.apache.beam.sdk.util.ShardedKey<DestinationT>,java.lang.Iterable<ElementT>>>,org.apache.beam.sdk.values.PCollection<java.lang.Void>>
Constructor and Description |
---|
StorageApiWritesShardedRecords(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<org.apache.beam.sdk.util.ShardedKey<DestinationT>,java.lang.Iterable<ElementT>>> input) |
public StorageApiWritesShardedRecords(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<org.apache.beam.sdk.util.ShardedKey<DestinationT>,java.lang.Iterable<ElementT>>> input)
expand
in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<org.apache.beam.sdk.util.ShardedKey<DestinationT>,java.lang.Iterable<ElementT>>>,org.apache.beam.sdk.values.PCollection<java.lang.Void>>