Package org.apache.iceberg.connect.data

Class SchemaUtils

java.lang.Object

org.apache.iceberg.connect.data.SchemaUtils

public class SchemaUtils
extends java.lang.Object

Method Summary

Modifier and Type	Method	Description
static void	applySchemaUpdates(Table table, SchemaUpdate.Consumer updates)
static PartitionSpec	createPartitionSpec(Schema schema, java.util.List<java.lang.String> partitionBy)
static Type	inferIcebergType(java.lang.Object value, IcebergSinkConfig config)
static Type.PrimitiveType	needsDataTypeUpdate(Type currentIcebergType, org.apache.kafka.connect.data.Schema valueSchema)
static Type	toIcebergType(org.apache.kafka.connect.data.Schema valueSchema, IcebergSinkConfig config)

Methods inherited from class java.lang.Object

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

Method Detail

needsDataTypeUpdate

public static Type.PrimitiveType needsDataTypeUpdate(Type currentIcebergType,
                                                     org.apache.kafka.connect.data.Schema valueSchema)

applySchemaUpdates

public static void applySchemaUpdates(Table table,
                                      SchemaUpdate.Consumer updates)

createPartitionSpec

public static PartitionSpec createPartitionSpec(Schema schema,
                                                java.util.List<java.lang.String> partitionBy)

toIcebergType

public static Type toIcebergType(org.apache.kafka.connect.data.Schema valueSchema,
                                 IcebergSinkConfig config)

inferIcebergType

public static Type inferIcebergType(java.lang.Object value,
                                    IcebergSinkConfig config)