Package org.apache.beam.io.debezium
Class DebeziumTransformRegistrar
java.lang.Object
org.apache.beam.io.debezium.DebeziumTransformRegistrar
- All Implemented Interfaces:
ExternalTransformRegistrar
@AutoService(ExternalTransformRegistrar.class)
public class DebeziumTransformRegistrar
extends Object
implements ExternalTransformRegistrar
Exposes
DebeziumIO.Read
as an external transform for cross-language usage.-
Nested Class Summary
Nested Classes -
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionMap
<String, Class<? extends ExternalTransformBuilder<?, ?, ?>>> A mapping from URN to anExternalTransformBuilder
class.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
knownBuilderInstances
-
Field Details
-
READ_JSON_URN
- See Also:
-
-
Constructor Details
-
DebeziumTransformRegistrar
public DebeziumTransformRegistrar()
-
-
Method Details
-
knownBuilders
Description copied from interface:ExternalTransformRegistrar
A mapping from URN to anExternalTransformBuilder
class.- Specified by:
knownBuilders
in interfaceExternalTransformRegistrar
-