Package 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 createTaskWriter
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description TaskWriter<T>
create()
Initialize aTaskWriter
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 aTaskWriter
with given task id and attempt id.- Returns:
- a newly created task writer.
-
-