protected static class BigQueryFileLoadsWriteSchemaTransformProvider.BigQueryWriteSchemaTransform
extends org.apache.beam.sdk.schemas.transforms.SchemaTransform
SchemaTransform
that performs BigQueryIO.Write
s based on a BigQueryFileLoadsWriteSchemaTransformConfiguration
.Modifier and Type | Method and Description |
---|---|
org.apache.beam.sdk.values.PCollectionRowTuple |
expand(org.apache.beam.sdk.values.PCollectionRowTuple input) |
void |
validate(org.apache.beam.sdk.options.PipelineOptions options) |
addAnnotation, compose, compose, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setResourceHints, toString, validate
public void validate(org.apache.beam.sdk.options.PipelineOptions options)
validate
in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollectionRowTuple,org.apache.beam.sdk.values.PCollectionRowTuple>
public org.apache.beam.sdk.values.PCollectionRowTuple expand(org.apache.beam.sdk.values.PCollectionRowTuple input)
expand
in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollectionRowTuple,org.apache.beam.sdk.values.PCollectionRowTuple>