@AutoService(value=org.apache.beam.sdk.schemas.transforms.SchemaTransformProvider.class) public class SpannerChangestreamsReadSchemaTransformProvider extends org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider<SpannerChangestreamsReadSchemaTransformProvider.SpannerChangestreamsReadConfiguration>
Modifier and Type | Class and Description |
---|---|
static class |
SpannerChangestreamsReadSchemaTransformProvider.DataChangeRecordToRow |
static class |
SpannerChangestreamsReadSchemaTransformProvider.SpannerChangestreamsReadConfiguration |
Modifier and Type | Field and Description |
---|---|
static org.apache.beam.sdk.schemas.Schema |
ERROR_SCHEMA |
static org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.values.Row> |
ERROR_TAG |
static org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.values.Row> |
OUTPUT_TAG |
Constructor and Description |
---|
SpannerChangestreamsReadSchemaTransformProvider() |
Modifier and Type | Method and Description |
---|---|
protected @UnknownKeyFor @NonNull @Initialized java.lang.Class<SpannerChangestreamsReadSchemaTransformProvider.SpannerChangestreamsReadConfiguration> |
configurationClass() |
@UnknownKeyFor @NonNull @Initialized org.apache.beam.sdk.schemas.transforms.SchemaTransform |
from(SpannerChangestreamsReadSchemaTransformProvider.SpannerChangestreamsReadConfiguration configuration) |
@UnknownKeyFor @NonNull @Initialized java.lang.String |
identifier() |
@UnknownKeyFor @NonNull @Initialized java.util.List<java.lang.String> |
inputCollectionNames() |
@UnknownKeyFor @NonNull @Initialized java.util.List<java.lang.String> |
outputCollectionNames() |
configurationSchema, dependencies, from
public static final org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.values.Row> OUTPUT_TAG
public static final org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.values.Row> ERROR_TAG
public static final org.apache.beam.sdk.schemas.Schema ERROR_SCHEMA
public SpannerChangestreamsReadSchemaTransformProvider()
protected @UnknownKeyFor @NonNull @Initialized java.lang.Class<SpannerChangestreamsReadSchemaTransformProvider.SpannerChangestreamsReadConfiguration> configurationClass()
configurationClass
in class org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider<SpannerChangestreamsReadSchemaTransformProvider.SpannerChangestreamsReadConfiguration>
public @UnknownKeyFor @NonNull @Initialized org.apache.beam.sdk.schemas.transforms.SchemaTransform from(SpannerChangestreamsReadSchemaTransformProvider.SpannerChangestreamsReadConfiguration configuration)
from
in class org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider<SpannerChangestreamsReadSchemaTransformProvider.SpannerChangestreamsReadConfiguration>
public @UnknownKeyFor @NonNull @Initialized java.lang.String identifier()
public @UnknownKeyFor @NonNull @Initialized java.util.List<java.lang.String> inputCollectionNames()
public @UnknownKeyFor @NonNull @Initialized java.util.List<java.lang.String> outputCollectionNames()