Package org.apache.iceberg.flink.sink.dynamic

Class DynamicTableRecordGenerator

java.lang.Object

org.apache.iceberg.flink.sink.dynamic.DynamicTableRecordGenerator

All Implemented Interfaces:

Serializable, DynamicRecordGenerator<org.apache.flink.table.data.RowData>

public abstract class DynamicTableRecordGenerator
extends Object
implements DynamicRecordGenerator<org.apache.flink.table.data.RowData>

Abstract base class for SQL-based dynamic record generators. Users will extend this class to create a DynamicRecord from RowData.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
DynamicTableRecordGenerator(org.apache.flink.table.types.logical.RowType rowType)

Method Summary

Modifier and Type	Method	Description
protected org.apache.flink.table.types.logical.RowType	rowType()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.iceberg.flink.sink.dynamic.DynamicRecordGenerator

generate, open

Constructor Details

DynamicTableRecordGenerator

public DynamicTableRecordGenerator(org.apache.flink.table.types.logical.RowType rowType)

Method Details

rowType

protected org.apache.flink.table.types.logical.RowType rowType()