@AutoService(value=SchemaTransformProvider.class) public class IcebergWriteSchemaTransformProvider extends TypedSchemaTransformProvider<IcebergWriteSchemaTransformProvider.Config>
IcebergIO.writeRows(org.apache.beam.sdk.io.iceberg.IcebergCatalogConfig)
. Writes Beam Rows to Iceberg and
outputs a PCollection<Row>
representing snapshots created in the process.Modifier and Type | Class and Description |
---|---|
static class |
IcebergWriteSchemaTransformProvider.Config |
Constructor and Description |
---|
IcebergWriteSchemaTransformProvider() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
description()
Returns a description regarding the
SchemaTransform represented by the SchemaTransformProvider . |
protected SchemaTransform |
from(IcebergWriteSchemaTransformProvider.Config configuration)
Produce a SchemaTransform from ConfigT.
|
java.lang.String |
identifier()
Returns an id that uniquely represents this transform.
|
java.util.List<java.lang.String> |
inputCollectionNames()
Returns the input collection names of this transform.
|
java.util.List<java.lang.String> |
outputCollectionNames()
Returns the output collection names of this transform.
|
configurationClass, configurationSchema, dependencies, from
public java.lang.String description()
SchemaTransformProvider
SchemaTransform
represented by the SchemaTransformProvider
. Please keep the language generic (i.e. not specific to any
programming language). The description may be markdown formatted.protected SchemaTransform from(IcebergWriteSchemaTransformProvider.Config configuration)
TypedSchemaTransformProvider
InvalidConfigurationException
or a
InvalidSchemaException
.from
in class TypedSchemaTransformProvider<IcebergWriteSchemaTransformProvider.Config>
public java.util.List<java.lang.String> inputCollectionNames()
SchemaTransformProvider
public java.util.List<java.lang.String> outputCollectionNames()
SchemaTransformProvider
public java.lang.String identifier()
SchemaTransformProvider