@AutoService(value=SchemaTransformProvider.class) public class IcebergCdcReadSchemaTransformProvider extends TypedSchemaTransformProvider<IcebergCdcReadSchemaTransformProvider.Configuration>
IcebergIO.readRows(org.apache.beam.sdk.io.iceberg.IcebergCatalogConfig)
. Reads records from Iceberg and
outputs a PCollection
of Beam Row
s.Modifier and Type | Class and Description |
---|---|
static class |
IcebergCdcReadSchemaTransformProvider.Configuration |
Constructor and Description |
---|
IcebergCdcReadSchemaTransformProvider() |
Modifier and Type | Method and Description |
---|---|
protected SchemaTransform |
from(IcebergCdcReadSchemaTransformProvider.Configuration configuration)
Produce a SchemaTransform from ConfigT.
|
java.lang.String |
identifier()
Returns an id that uniquely represents this transform.
|
java.util.List<java.lang.String> |
outputCollectionNames()
Returns the output collection names of this transform.
|
configurationClass, configurationSchema, dependencies, from
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
description, inputCollectionNames
public IcebergCdcReadSchemaTransformProvider()
protected SchemaTransform from(IcebergCdcReadSchemaTransformProvider.Configuration configuration)
TypedSchemaTransformProvider
InvalidConfigurationException
or a
InvalidSchemaException
.from
in class TypedSchemaTransformProvider<IcebergCdcReadSchemaTransformProvider.Configuration>
public java.util.List<java.lang.String> outputCollectionNames()
SchemaTransformProvider
public java.lang.String identifier()
SchemaTransformProvider