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