Package org.apache.flink.cdc.connectors.iceberg.sink.v2

Class TableSchemaWrapper

java.lang.Object

org.apache.flink.cdc.connectors.iceberg.sink.v2.TableSchemaWrapper

public class TableSchemaWrapper
extends Object

A Wrapper for Schema.

Constructor Summary

Constructors

Constructor	Description
TableSchemaWrapper(Schema schema, java.time.ZoneId zoneId)

Method Summary

Modifier and Type	Method	Description
List<RecordData.FieldGetter>	getFieldGetters()
Schema	getSchema()

Methods inherited from class java.lang.Object

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

Constructor Detail

TableSchemaWrapper

public TableSchemaWrapper(Schema schema,
                          java.time.ZoneId zoneId)

Method Detail

getSchema

public Schema getSchema()

getFieldGetters

public List<RecordData.FieldGetter> getFieldGetters()