@AutoService(value=SchemaTransformProvider.class) public class BigQueryStorageWriteApiSchemaTransformProvider extends 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.
|
Constructor and Description |
---|
BigQueryStorageWriteApiSchemaTransformProvider() |
Modifier and Type | Method and Description |
---|---|
protected java.lang.Class<BigQueryStorageWriteApiSchemaTransformProvider.BigQueryStorageWriteApiSchemaTransformConfiguration> |
configurationClass() |
protected SchemaTransform |
from(BigQueryStorageWriteApiSchemaTransformProvider.BigQueryStorageWriteApiSchemaTransformConfiguration configuration)
Produce a SchemaTransform from ConfigT.
|
java.lang.String |
identifier()
Returns an id that uniquely represents this transform.
|
java.util.List<java.lang.String> |
inputCollectionNames()
Returns the input collection names of this transform.
|
java.util.List<java.lang.String> |
outputCollectionNames()
Returns the output collection names of this transform.
|
configurationSchema, dependencies, from
public BigQueryStorageWriteApiSchemaTransformProvider()
protected java.lang.Class<BigQueryStorageWriteApiSchemaTransformProvider.BigQueryStorageWriteApiSchemaTransformConfiguration> configurationClass()
protected SchemaTransform from(BigQueryStorageWriteApiSchemaTransformProvider.BigQueryStorageWriteApiSchemaTransformConfiguration configuration)
TypedSchemaTransformProvider
InvalidConfigurationException
or a
InvalidSchemaException
.public java.lang.String identifier()
SchemaTransformProvider
public java.util.List<java.lang.String> inputCollectionNames()
SchemaTransformProvider
public java.util.List<java.lang.String> outputCollectionNames()
SchemaTransformProvider