org.apache.beam.sdk.io.iceberg

Class SchemaTransformConfiguration

java.lang.Object

org.apache.beam.sdk.io.iceberg.SchemaTransformConfiguration

@DefaultSchema(value=AutoValueSchema.class)
public abstract class SchemaTransformConfiguration
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SchemaTransformConfiguration.Builder

Constructor Summary

Constructors

Constructor and Description
SchemaTransformConfiguration()

Method Summary

Modifier and Type	Method and Description
static SchemaTransformConfiguration.Builder	builder()
abstract @Nullable java.lang.String	getCatalogName()
abstract @Nullable java.util.Map<java.lang.String,java.lang.String>	getCatalogProperties()
abstract @Nullable java.util.Map<java.lang.String,java.lang.String>	getConfigProperties()
IcebergCatalogConfig	getIcebergCatalog()
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

SchemaTransformConfiguration

public SchemaTransformConfiguration()

Method Detail

builder

public static SchemaTransformConfiguration.Builder builder()

getTable

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

getCatalogName

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

getCatalogProperties

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

getConfigProperties

@SchemaFieldDescription(value="Properties passed to the Hadoop Configuration.")
public abstract @Nullable java.util.Map<java.lang.String,java.lang.String> getConfigProperties()

getIcebergCatalog

public IcebergCatalogConfig getIcebergCatalog()