org.apache.iceberg.flink.sink

Interface TaskWriterFactory<T>

Type Parameters:

T - data type of record.

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

RowDataTaskWriterFactory

public interface TaskWriterFactory<T>
extends java.io.Serializable

Factory to create TaskWriter

Method Summary

Modifier and Type	Method and Description
TaskWriter<T>	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.

Method Detail

initialize

void initialize(int taskId,
                int attemptId)

Initialize the factory with a given taskId and attemptId.

Parameters:

taskId - the identifier of task.

attemptId - the attempt id of this task.

create

TaskWriter<T> create()

Initialize a TaskWriter with given task id and attempt id.

Returns:

a newly created task writer.