@AutoService(value=org.apache.beam.sdk.schemas.transforms.SchemaTransformProvider.class) public class BigQueryStorageWriteApiSchemaTransformProvider extends org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider<BigQueryStorageWriteApiSchemaTransformProvider.BigQueryStorageWriteApiSchemaTransformConfiguration>
TypedSchemaTransformProvider
for BigQuery Storage Write API jobs
configured via BigQueryStorageWriteApiSchemaTransformProvider.BigQueryStorageWriteApiSchemaTransformConfiguration
.
Internal only: This class is actively being worked on, and it will likely change. We provide no backwards compatibility guarantees, and it should not be implemented outside the Beam repository.
Modifier and Type | Class and Description |
---|---|
protected static class |
BigQueryStorageWriteApiSchemaTransformProvider.BigQueryStorageWriteApiSchemaTransform
A
SchemaTransform for BigQuery Storage Write API, configured with BigQueryStorageWriteApiSchemaTransformProvider.BigQueryStorageWriteApiSchemaTransformConfiguration and instantiated by BigQueryStorageWriteApiSchemaTransformProvider . |
static class |
BigQueryStorageWriteApiSchemaTransformProvider.BigQueryStorageWriteApiSchemaTransformConfiguration
Configuration for writing to BigQuery with Storage Write API.
|
Modifier and Type | Field and Description |
---|---|
protected static java.lang.String |
DYNAMIC_DESTINATIONS |
Constructor and Description |
---|
BigQueryStorageWriteApiSchemaTransformProvider() |
Modifier and Type | Method and Description |
---|---|
protected java.lang.Class<BigQueryStorageWriteApiSchemaTransformProvider.BigQueryStorageWriteApiSchemaTransformConfiguration> |
configurationClass() |
java.lang.String |
description() |
protected org.apache.beam.sdk.schemas.transforms.SchemaTransform |
from(BigQueryStorageWriteApiSchemaTransformProvider.BigQueryStorageWriteApiSchemaTransformConfiguration configuration) |
java.lang.String |
identifier() |
java.util.List<java.lang.String> |
inputCollectionNames() |
java.util.List<java.lang.String> |
outputCollectionNames() |
protected static final java.lang.String DYNAMIC_DESTINATIONS
public BigQueryStorageWriteApiSchemaTransformProvider()
protected java.lang.Class<BigQueryStorageWriteApiSchemaTransformProvider.BigQueryStorageWriteApiSchemaTransformConfiguration> configurationClass()
configurationClass
in class org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider<BigQueryStorageWriteApiSchemaTransformProvider.BigQueryStorageWriteApiSchemaTransformConfiguration>
protected org.apache.beam.sdk.schemas.transforms.SchemaTransform from(BigQueryStorageWriteApiSchemaTransformProvider.BigQueryStorageWriteApiSchemaTransformConfiguration configuration)
from
in class org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider<BigQueryStorageWriteApiSchemaTransformProvider.BigQueryStorageWriteApiSchemaTransformConfiguration>
public java.lang.String identifier()
public java.lang.String description()
public java.util.List<java.lang.String> inputCollectionNames()
public java.util.List<java.lang.String> outputCollectionNames()