@AutoService(value=org.apache.beam.sdk.schemas.transforms.SchemaTransformProvider.class) public class BigtableWriteSchemaTransformProvider extends org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider<BigtableWriteSchemaTransformProvider.BigtableWriteSchemaTransformConfiguration>
TypedSchemaTransformProvider
for Bigtable Write jobs configured via
BigtableWriteSchemaTransformProvider.BigtableWriteSchemaTransformConfiguration
.
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 |
---|---|
static class |
BigtableWriteSchemaTransformProvider.BigtableWriteSchemaTransformConfiguration
Configuration for writing to Bigtable.
|
static class |
BigtableWriteSchemaTransformProvider.GetMutationsFromBeamRow |
Constructor and Description |
---|
BigtableWriteSchemaTransformProvider() |
Modifier and Type | Method and Description |
---|---|
protected java.lang.Class<BigtableWriteSchemaTransformProvider.BigtableWriteSchemaTransformConfiguration> |
configurationClass() |
protected org.apache.beam.sdk.schemas.transforms.SchemaTransform |
from(BigtableWriteSchemaTransformProvider.BigtableWriteSchemaTransformConfiguration configuration) |
java.lang.String |
identifier() |
java.util.List<java.lang.String> |
inputCollectionNames() |
java.util.List<java.lang.String> |
outputCollectionNames() |
configurationSchema, dependencies, from
public BigtableWriteSchemaTransformProvider()
protected java.lang.Class<BigtableWriteSchemaTransformProvider.BigtableWriteSchemaTransformConfiguration> configurationClass()
configurationClass
in class org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider<BigtableWriteSchemaTransformProvider.BigtableWriteSchemaTransformConfiguration>
protected org.apache.beam.sdk.schemas.transforms.SchemaTransform from(BigtableWriteSchemaTransformProvider.BigtableWriteSchemaTransformConfiguration configuration)
from
in class org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider<BigtableWriteSchemaTransformProvider.BigtableWriteSchemaTransformConfiguration>
public java.lang.String identifier()
public java.util.List<java.lang.String> inputCollectionNames()
public java.util.List<java.lang.String> outputCollectionNames()