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,StorageApiWritePayload>>,org.apache.beam.sdk.values.PCollectionTuple>
Constructor and Description |
---|
StorageApiWriteUnshardedRecords(org.apache.beam.sdk.io.gcp.bigquery.StorageApiDynamicDestinations<ElementT,DestinationT> dynamicDestinations,
BigQueryServices bqServices,
org.apache.beam.sdk.values.TupleTag<BigQueryStorageApiInsertError> failedRowsTag,
@Nullable org.apache.beam.sdk.values.TupleTag<com.google.api.services.bigquery.model.TableRow> successfulRowsTag,
org.apache.beam.sdk.coders.Coder<BigQueryStorageApiInsertError> failedRowsCoder,
org.apache.beam.sdk.coders.Coder<com.google.api.services.bigquery.model.TableRow> successfulRowsCoder,
boolean autoUpdateSchema,
boolean ignoreUnknownValues,
BigQueryIO.Write.CreateDisposition createDisposition,
@Nullable java.lang.String kmsKey,
boolean usesCdc,
com.google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation defaultMissingValueInterpretation) |
Modifier and Type | Method and Description |
---|---|
org.apache.beam.sdk.values.PCollectionTuple |
expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<DestinationT,StorageApiWritePayload>> input) |
addAnnotation, compose, compose, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setResourceHints, toString, validate, validate
public StorageApiWriteUnshardedRecords(org.apache.beam.sdk.io.gcp.bigquery.StorageApiDynamicDestinations<ElementT,DestinationT> dynamicDestinations, BigQueryServices bqServices, org.apache.beam.sdk.values.TupleTag<BigQueryStorageApiInsertError> failedRowsTag, @Nullable org.apache.beam.sdk.values.TupleTag<com.google.api.services.bigquery.model.TableRow> successfulRowsTag, org.apache.beam.sdk.coders.Coder<BigQueryStorageApiInsertError> failedRowsCoder, org.apache.beam.sdk.coders.Coder<com.google.api.services.bigquery.model.TableRow> successfulRowsCoder, boolean autoUpdateSchema, boolean ignoreUnknownValues, BigQueryIO.Write.CreateDisposition createDisposition, @Nullable java.lang.String kmsKey, boolean usesCdc, com.google.cloud.bigquery.storage.v1.AppendRowsRequest.MissingValueInterpretation defaultMissingValueInterpretation)
public org.apache.beam.sdk.values.PCollectionTuple expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<DestinationT,StorageApiWritePayload>> input)
expand
in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<DestinationT,StorageApiWritePayload>>,org.apache.beam.sdk.values.PCollectionTuple>