org.apache.beam.sdk.io.iceberg

Class IcebergWriteSchemaTransformProvider.Config

java.lang.Object

org.apache.beam.sdk.io.iceberg.IcebergWriteSchemaTransformProvider.Config

Enclosing class:

IcebergWriteSchemaTransformProvider

@DefaultSchema(value=AutoValueSchema.class)
public abstract static class IcebergWriteSchemaTransformProvider.Config
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IcebergWriteSchemaTransformProvider.Config.Builder

Constructor Summary

Constructors

Constructor and Description
Config()

Method Summary

Modifier and Type	Method and Description
static IcebergWriteSchemaTransformProvider.Config.Builder	builder()
abstract IcebergSchemaTransformCatalogConfig	getCatalogConfig()
abstract java.lang.String	getTable()
void	validate()

Methods inherited from class java.lang.Object

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

Constructor Detail

Config

public Config()

Method Detail

builder

public static IcebergWriteSchemaTransformProvider.Config.Builder builder()

getTable

@SchemaFieldDescription(value="Identifier of the Iceberg table to write to.")
public abstract java.lang.String getTable()

getCatalogConfig

@SchemaFieldDescription(value="Configuration parameters used to set up the Iceberg catalog.")
public abstract IcebergSchemaTransformCatalogConfig getCatalogConfig()

validate

public void validate()