Package org.apache.iceberg.flink.sink

Class FlinkFileWriterFactory.Builder

java.lang.Object

org.apache.iceberg.flink.sink.FlinkFileWriterFactory.Builder

Enclosing class:

FlinkFileWriterFactory

public static class FlinkFileWriterFactory.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder(Table table)

Method Summary

Modifier and Type	Method	Description
FlinkFileWriterFactory	build()
FlinkFileWriterFactory.Builder	dataFileFormat(FileFormat newDataFileFormat)
FlinkFileWriterFactory.Builder	dataFlinkType(org.apache.flink.table.types.logical.RowType newDataFlinkType)	Sets a Flink type for data.
FlinkFileWriterFactory.Builder	dataSchema(Schema newDataSchema)
FlinkFileWriterFactory.Builder	dataSortOrder(SortOrder newDataSortOrder)
FlinkFileWriterFactory.Builder	deleteFileFormat(FileFormat newDeleteFileFormat)
FlinkFileWriterFactory.Builder	equalityDeleteFlinkType(org.apache.flink.table.types.logical.RowType newEqualityDeleteFlinkType)	Sets a Flink type for equality deletes.
FlinkFileWriterFactory.Builder	equalityDeleteRowSchema(Schema newEqualityDeleteRowSchema)
FlinkFileWriterFactory.Builder	equalityDeleteSortOrder(SortOrder newEqualityDeleteSortOrder)
FlinkFileWriterFactory.Builder	equalityFieldIds(int[] newEqualityFieldIds)
FlinkFileWriterFactory.Builder	writerProperties(Map<String,String> newWriterProperties)	Sets default writer properties.

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder(Table table)

Method Details

dataFileFormat

public FlinkFileWriterFactory.Builder dataFileFormat(FileFormat newDataFileFormat)

dataSchema

public FlinkFileWriterFactory.Builder dataSchema(Schema newDataSchema)

dataFlinkType

public FlinkFileWriterFactory.Builder dataFlinkType(org.apache.flink.table.types.logical.RowType newDataFlinkType)

Sets a Flink type for data.

If not set, the value is derived from the provided Iceberg schema.

dataSortOrder

public FlinkFileWriterFactory.Builder dataSortOrder(SortOrder newDataSortOrder)

deleteFileFormat

public FlinkFileWriterFactory.Builder deleteFileFormat(FileFormat newDeleteFileFormat)

equalityFieldIds

public FlinkFileWriterFactory.Builder equalityFieldIds(int[] newEqualityFieldIds)

equalityDeleteRowSchema

public FlinkFileWriterFactory.Builder equalityDeleteRowSchema(Schema newEqualityDeleteRowSchema)

equalityDeleteFlinkType

public FlinkFileWriterFactory.Builder equalityDeleteFlinkType(org.apache.flink.table.types.logical.RowType newEqualityDeleteFlinkType)

Sets a Flink type for equality deletes.

If not set, the value is derived from the provided Iceberg schema.

equalityDeleteSortOrder

public FlinkFileWriterFactory.Builder equalityDeleteSortOrder(SortOrder newEqualityDeleteSortOrder)

writerProperties

public FlinkFileWriterFactory.Builder writerProperties(Map<String,String> newWriterProperties)

Sets default writer properties.

build

public FlinkFileWriterFactory build()