org.apache.iceberg.connect.data

Class SchemaUpdate.Consumer

java.lang.Object

org.apache.iceberg.connect.data.SchemaUpdate.Consumer

Enclosing class:

SchemaUpdate

public static class SchemaUpdate.Consumer
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Consumer()

Method Summary

Modifier and Type	Method and Description
void	addColumn(java.lang.String parentName, java.lang.String name, Type type)
java.util.Collection<SchemaUpdate.AddColumn>	addColumns()
boolean	empty()
void	makeOptional(java.lang.String name)
java.util.Collection<SchemaUpdate.MakeOptional>	makeOptionals()
void	updateType(java.lang.String name, Type.PrimitiveType type)
java.util.Collection<SchemaUpdate.UpdateType>	updateTypes()

Methods inherited from class java.lang.Object

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

Constructor Detail

Consumer

public Consumer()

Method Detail

addColumns

public java.util.Collection<SchemaUpdate.AddColumn> addColumns()

updateTypes

public java.util.Collection<SchemaUpdate.UpdateType> updateTypes()

makeOptionals

public java.util.Collection<SchemaUpdate.MakeOptional> makeOptionals()

empty

public boolean empty()

addColumn

public void addColumn(java.lang.String parentName,
                      java.lang.String name,
                      Type type)

updateType

public void updateType(java.lang.String name,
                       Type.PrimitiveType type)

makeOptional

public void makeOptional(java.lang.String name)