Package org.apache.iceberg.flink.sink

Class FlinkFileWriterFactory

java.lang.Object

org.apache.iceberg.data.RegistryBasedFileWriterFactory<org.apache.flink.table.data.RowData,org.apache.flink.table.types.logical.RowType>

org.apache.iceberg.flink.sink.FlinkFileWriterFactory

All Implemented Interfaces:

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

public class FlinkFileWriterFactory
extends RegistryBasedFileWriterFactory<org.apache.flink.table.data.RowData,org.apache.flink.table.types.logical.RowType>
implements Serializable

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	FlinkFileWriterFactory.Builder

Method Summary

Methods inherited from class org.apache.iceberg.data.RegistryBasedFileWriterFactory

equalityDeleteInputSchema, inputSchema, newDataWriter, newEqualityDeleteWriter, newPositionDeleteWriter

Methods inherited from class java.lang.Object

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