Package org.apache.iceberg.connect.data

Class Utilities

java.lang.Object

org.apache.iceberg.connect.data.Utilities

public class Utilities
extends java.lang.Object

Method Summary

Modifier and Type	Method	Description
static TaskWriter<Record>	createTableWriter(Table table, java.lang.String tableName, IcebergSinkConfig config)
static java.lang.Object	extractFromRecordValue(java.lang.Object recordValue, java.lang.String fieldName)
static Catalog	loadCatalog(IcebergSinkConfig config)

Methods inherited from class java.lang.Object

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

Method Detail

loadCatalog

public static Catalog loadCatalog(IcebergSinkConfig config)

extractFromRecordValue

public static java.lang.Object extractFromRecordValue(java.lang.Object recordValue,
                                                      java.lang.String fieldName)

createTableWriter

public static TaskWriter<Record> createTableWriter(Table table,
                                                   java.lang.String tableName,
                                                   IcebergSinkConfig config)