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 java.lang.String	getCatalogName()
abstract java.util.Map<java.lang.String,java.lang.String>	getCatalogProperties()
abstract java.lang.String	getTable()

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()

getCatalogName

@SchemaFieldDescription(value="Name of the catalog containing the table.")
public abstract java.lang.String getCatalogName()

getCatalogProperties

@SchemaFieldDescription(value="Configuration properties used to set up the Iceberg catalog.")
public abstract java.util.Map<java.lang.String,java.lang.String> getCatalogProperties()