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

Interface DynamicRecordGenerator<T>

All Superinterfaces:

Serializable

public interface DynamicRecordGenerator<T>
extends Serializable

A generator to yield DynamicRecord from the provided input.

Method Summary

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

Method Details

open

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

Throws:

Exception

generate

void generate(T inputRecord,
 org.apache.flink.util.Collector<DynamicRecord> out)
       throws Exception

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

Throws:

Exception