@AutoService(value=org.apache.beam.sdk.schemas.transforms.SchemaTransformProvider.class) public class BigQueryDirectReadSchemaTransformProvider extends org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider<BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransformConfiguration>
TypedSchemaTransformProvider
for BigQuery Storage Read API jobs
configured via BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransformConfiguration
.
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 |
BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransform
A
SchemaTransform for BigQuery Storage Read API, configured with BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransformConfiguration and instantiated by BigQueryDirectReadSchemaTransformProvider . |
static class |
BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransformConfiguration
Configuration for reading from BigQuery with Storage Read API.
|
Constructor and Description |
---|
BigQueryDirectReadSchemaTransformProvider() |
Modifier and Type | Method and Description |
---|---|
protected java.lang.Class<BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransformConfiguration> |
configurationClass() |
protected org.apache.beam.sdk.schemas.transforms.SchemaTransform |
from(BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransformConfiguration configuration) |
java.lang.String |
identifier() |
java.util.List<java.lang.String> |
inputCollectionNames() |
java.util.List<java.lang.String> |
outputCollectionNames() |
configurationSchema, dependencies, from
public BigQueryDirectReadSchemaTransformProvider()
protected java.lang.Class<BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransformConfiguration> configurationClass()
configurationClass
in class org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider<BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransformConfiguration>
protected org.apache.beam.sdk.schemas.transforms.SchemaTransform from(BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransformConfiguration configuration)
from
in class org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider<BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransformConfiguration>
public java.lang.String identifier()
public java.util.List<java.lang.String> inputCollectionNames()
public java.util.List<java.lang.String> outputCollectionNames()