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

Class TableSchemaInfo

java.lang.Object

org.apache.flink.cdc.connectors.paimon.sink.v2.TableSchemaInfo

public class TableSchemaInfo
extends Object

Keep a list of RecordData.FieldGetter for a specific Schema.

Constructor Summary

Constructors

Constructor	Description
TableSchemaInfo(Schema schema, java.time.ZoneId zoneId, BlobWriteContext blobWriteContext)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

TableSchemaInfo

public TableSchemaInfo(Schema schema,
                       java.time.ZoneId zoneId,
                       @Nullable
                       BlobWriteContext blobWriteContext)

Method Detail

getSchema

public Schema getSchema()

getFieldGetters

public List<RecordData.FieldGetter> getFieldGetters()

hasPrimaryKey

public boolean hasPrimaryKey()

getBlobWriteContext

@Nullable
public BlobWriteContext getBlobWriteContext()