Package org.apache.beam.sdk.io.iceberg

Class IcebergCatalogConfig

java.lang.Object

org.apache.beam.sdk.io.iceberg.IcebergCatalogConfig

All Implemented Interfaces:

Serializable

public abstract class IcebergCatalogConfig
extends Object
implements Serializable

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	IcebergCatalogConfig.Builder

Constructor Summary

Constructors

Constructor	Description
IcebergCatalogConfig()

Method Summary

Modifier and Type	Method	Description
static IcebergCatalogConfig.Builder	builder()
org.apache.iceberg.catalog.Catalog	catalog()
boolean	createNamespace(String namespace)
void	createTable(String tableIdentifier, Schema tableSchema, @Nullable List<String> partitionFields)
boolean	dropNamespace(String namespace, boolean cascade)
boolean	dropTable(String tableIdentifier)
abstract @Nullable String	getCatalogName()
abstract @Nullable Map<String,String>	getCatalogProperties()
abstract @Nullable Map<String,String>	getConfigProperties()
Set<String>	listNamespaces()
Set<String>	listTables(String namespace)
abstract IcebergCatalogConfig.Builder	toBuilder()

Methods inherited from class java.lang.Object

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

Constructor Details

IcebergCatalogConfig

public IcebergCatalogConfig()

Method Details

getCatalogName

@Pure
public abstract @Nullable String getCatalogName()

getCatalogProperties

@Pure
public abstract @Nullable Map<String,String> getCatalogProperties()

getConfigProperties

@Pure
public abstract @Nullable Map<String,String> getConfigProperties()

builder

@Pure
public static IcebergCatalogConfig.Builder builder()

toBuilder

public abstract IcebergCatalogConfig.Builder toBuilder()

catalog

public org.apache.iceberg.catalog.Catalog catalog()

createNamespace

public boolean createNamespace(String namespace)

listNamespaces

public Set<String> listNamespaces()

dropNamespace

public boolean dropNamespace(String namespace,
 boolean cascade)

createTable

public void createTable(String tableIdentifier,
 Schema tableSchema,
 @Nullable List<String> partitionFields)

dropTable

public boolean dropTable(String tableIdentifier)

listTables

public Set<String> listTables(String namespace)