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

Class IcebergCatalogConfig.IcebergTableInfo

java.lang.Object

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

Enclosing class:

IcebergCatalogConfig

public static class IcebergCatalogConfig.IcebergTableInfo
extends Object

Method Summary

Modifier and Type	Method	Description
String	getIdentifier()
Map<String,String>	getProperties()
Schema	getSchema()
void	updatePartitionSpec(List<String> partitionsToAdd, Collection<String> partitionsToDrop)
void	updateSchema(List<Schema.Field> columnsToAdd, Collection<String> columnsToDrop)
void	updateTableProps(Map<String,String> setProps, List<String> resetProps)

Methods inherited from class java.lang.Object

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

Method Details

getIdentifier

public String getIdentifier()

getSchema

public Schema getSchema()

getProperties

public Map<String,String> getProperties()

updateTableProps

public void updateTableProps(Map<String,String> setProps,
 List<String> resetProps)

updateSchema

public void updateSchema(List<Schema.Field> columnsToAdd,
 Collection<String> columnsToDrop)

updatePartitionSpec

public void updatePartitionSpec(List<String> partitionsToAdd,
 Collection<String> partitionsToDrop)