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

Class VariantAvroDynamicTableRecordGenerator

java.lang.Object

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

org.apache.iceberg.flink.sink.dynamic.VariantAvroDynamicTableRecordGenerator

All Implemented Interfaces:

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

public class VariantAvroDynamicTableRecordGenerator
extends DynamicTableRecordGenerator

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
VariantAvroDynamicTableRecordGenerator(org.apache.flink.table.types.logical.RowType rowType, Map<String,String> writeProperties, org.apache.flink.configuration.Configuration flinkConfiguration)

Method Summary

Modifier and Type	Method	Description
void	generate(org.apache.flink.table.data.RowData inputRecord, org.apache.flink.util.Collector<DynamicRecord> out)	Takes the user-defined input and yields zero, one, or multiple DynamicRecords using the Collector.
void	open(org.apache.flink.api.common.functions.OpenContext openContext)

Methods inherited from class org.apache.iceberg.flink.sink.dynamic.DynamicTableRecordGenerator

fieldNameToPosition, flinkDynamicSinkConf, rowType, validateRequiredColumnAndType

Methods inherited from class java.lang.Object

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

Constructor Details

VariantAvroDynamicTableRecordGenerator

public VariantAvroDynamicTableRecordGenerator(org.apache.flink.table.types.logical.RowType rowType,
 Map<String,String> writeProperties,
 org.apache.flink.configuration.Configuration flinkConfiguration)

Method Details

open

public void open(org.apache.flink.api.common.functions.OpenContext openContext)
          throws Exception

Specified by:

open in interface DynamicRecordGenerator<org.apache.flink.table.data.RowData>

Overrides:

open in class DynamicTableRecordGenerator

Throws:

Exception

generate

public void generate(org.apache.flink.table.data.RowData inputRecord,
 org.apache.flink.util.Collector<DynamicRecord> out)
              throws Exception

Description copied from interface: DynamicRecordGenerator

Takes the user-defined input and yields zero, one, or multiple DynamicRecords using the Collector.

Throws:

Exception