Package org.apache.beam.sdk.io.gcp.spanner

Class SpannerTransformRegistrar

java.lang.Object

org.apache.beam.sdk.io.gcp.spanner.SpannerTransformRegistrar

All Implemented Interfaces:

ExternalTransformRegistrar

@AutoService(ExternalTransformRegistrar.class)
public class SpannerTransformRegistrar
extends Object
implements ExternalTransformRegistrar

Exposes SpannerIO.WriteRows, SpannerIO.ReadRows and SpannerIO.ChangeStreamRead as an external transform for cross-language usage.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SpannerTransformRegistrar.ChangeStreamReaderBuilder
static class	SpannerTransformRegistrar.CrossLanguageConfiguration
static class	SpannerTransformRegistrar.DeleteBuilder
static class	SpannerTransformRegistrar.InsertBuilder
static class	SpannerTransformRegistrar.InsertOrUpdateBuilder
static class	SpannerTransformRegistrar.ReadBuilder
static class	SpannerTransformRegistrar.ReplaceBuilder
static class	SpannerTransformRegistrar.UpdateBuilder

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DELETE_URN
static final String	INSERT_OR_UPDATE_URN
static final String	INSERT_URN
static final String	READ_CHANGE_STREAM_URN
static final String	READ_URN
static final String	REPLACE_URN
static final String	UPDATE_URN

Constructor Summary

Constructors

Constructor	Description
SpannerTransformRegistrar()

Method Summary

Modifier and Type	Method	Description
@NonNull Map<String,ExternalTransformBuilder<?,?,?>>	knownBuilderInstances()	A mapping from URN to an ExternalTransformBuilder instance.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.beam.sdk.expansion.ExternalTransformRegistrar

knownBuilders

Field Details

INSERT_URN

public static final String INSERT_URN

See Also:

• Constant Field Values

UPDATE_URN

public static final String UPDATE_URN

See Also:

• Constant Field Values

REPLACE_URN

public static final String REPLACE_URN

See Also:

• Constant Field Values

INSERT_OR_UPDATE_URN

public static final String INSERT_OR_UPDATE_URN

See Also:

• Constant Field Values

DELETE_URN

public static final String DELETE_URN

See Also:

• Constant Field Values

READ_URN

public static final String READ_URN

See Also:

• Constant Field Values

READ_CHANGE_STREAM_URN

public static final String READ_CHANGE_STREAM_URN

See Also:

• Constant Field Values

Constructor Details

SpannerTransformRegistrar

public SpannerTransformRegistrar()

Method Details

knownBuilderInstances

public @NonNull Map<String,ExternalTransformBuilder<?,?,?>> knownBuilderInstances()

Description copied from interface: ExternalTransformRegistrar

A mapping from URN to an ExternalTransformBuilder instance.

Specified by:

knownBuilderInstances in interface ExternalTransformRegistrar