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