Package org.apache.iceberg.flink.sink
-
Interface Summary Interface Description TaskWriterFactory<T> Factory to createTaskWriter
-
Class Summary Class Description AvroGenericRecordToRowDataMapper This util class converts Avro GenericRecord to Flink RowData.FlinkAppenderFactory FlinkSink FlinkSink.Builder RowDataTaskWriterFactory