Package org.apache.iceberg.flink.sink

Class RowDataTaskWriterFactory

java.lang.Object

org.apache.iceberg.flink.sink.RowDataTaskWriterFactory

All Implemented Interfaces:

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

public class RowDataTaskWriterFactory
extends Object
implements TaskWriterFactory<org.apache.flink.table.data.RowData>

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
RowDataTaskWriterFactory(Table table, org.apache.flink.table.types.logical.RowType flinkSchema, long targetFileSizeBytes, FileFormat format, Map<String,String> writeProperties, Collection<Integer> equalityFieldIds, boolean upsert)
RowDataTaskWriterFactory(SerializableSupplier<Table> tableSupplier, org.apache.flink.table.types.logical.RowType flinkSchema, long targetFileSizeBytes, FileFormat format, Map<String,String> writeProperties, Collection<Integer> equalityFieldIds, boolean upsert)
RowDataTaskWriterFactory(SerializableSupplier<Table> tableSupplier, org.apache.flink.table.types.logical.RowType flinkSchema, long targetFileSizeBytes, FileFormat format, Map<String,String> writeProperties, Collection<Integer> equalityFieldIds, boolean upsert, Schema schema, PartitionSpec spec)

Method Summary

Modifier and Type	Method	Description
TaskWriter<org.apache.flink.table.data.RowData>	create()	Initialize a TaskWriter with given task id and attempt id.
void	initialize(int taskId, int attemptId)	Initialize the factory with a given taskId and attemptId.

Methods inherited from class java.lang.Object

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

Constructor Details

RowDataTaskWriterFactory

public RowDataTaskWriterFactory(Table table,
 org.apache.flink.table.types.logical.RowType flinkSchema,
 long targetFileSizeBytes,
 FileFormat format,
 Map<String,String> writeProperties,
 Collection<Integer> equalityFieldIds,
 boolean upsert)

RowDataTaskWriterFactory

public RowDataTaskWriterFactory(SerializableSupplier<Table> tableSupplier,
 org.apache.flink.table.types.logical.RowType flinkSchema,
 long targetFileSizeBytes,
 FileFormat format,
 Map<String,String> writeProperties,
 Collection<Integer> equalityFieldIds,
 boolean upsert)

RowDataTaskWriterFactory

public RowDataTaskWriterFactory(SerializableSupplier<Table> tableSupplier,
 org.apache.flink.table.types.logical.RowType flinkSchema,
 long targetFileSizeBytes,
 FileFormat format,
 Map<String,String> writeProperties,
 Collection<Integer> equalityFieldIds,
 boolean upsert,
 Schema schema,
 PartitionSpec spec)

Method Details

initialize

public void initialize(int taskId,
 int attemptId)

Description copied from interface: TaskWriterFactory

Initialize the factory with a given taskId and attemptId.

Specified by:

initialize in interface TaskWriterFactory<org.apache.flink.table.data.RowData>

Parameters:

taskId - the identifier of task.

attemptId - the attempt id of this task.

create

public TaskWriter<org.apache.flink.table.data.RowData> create()

Description copied from interface: TaskWriterFactory

Initialize a TaskWriter with given task id and attempt id.

Specified by:

create in interface TaskWriterFactory<org.apache.flink.table.data.RowData>

Returns:

a newly created task writer.