public class StorageApiLoads<DestinationT,ElementT> extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<DestinationT,ElementT>>,WriteResult>
PTransform
manages loads into BigQuery using the Storage API.Constructor and Description |
---|
StorageApiLoads(org.apache.beam.sdk.coders.Coder<DestinationT> destinationCoder,
org.apache.beam.sdk.coders.Coder<ElementT> elementCoder,
org.apache.beam.sdk.io.gcp.bigquery.StorageApiDynamicDestinations<ElementT,DestinationT> dynamicDestinations,
BigQueryIO.Write.CreateDisposition createDisposition,
java.lang.String kmsKey,
org.joda.time.Duration triggeringFrequency,
BigQueryServices bqServices,
int numShards) |
Modifier and Type | Method and Description |
---|---|
WriteResult |
expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<DestinationT,ElementT>> input) |
WriteResult |
expandTriggered(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<DestinationT,ElementT>> input) |
WriteResult |
expandUntriggered(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<DestinationT,ElementT>> input) |
public StorageApiLoads(org.apache.beam.sdk.coders.Coder<DestinationT> destinationCoder, org.apache.beam.sdk.coders.Coder<ElementT> elementCoder, org.apache.beam.sdk.io.gcp.bigquery.StorageApiDynamicDestinations<ElementT,DestinationT> dynamicDestinations, BigQueryIO.Write.CreateDisposition createDisposition, java.lang.String kmsKey, org.joda.time.Duration triggeringFrequency, BigQueryServices bqServices, int numShards)
public WriteResult 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>>,WriteResult>
public WriteResult expandTriggered(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<DestinationT,ElementT>> input)
public WriteResult expandUntriggered(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<DestinationT,ElementT>> input)