T
- data type of record.public interface TaskWriterFactory<T>
extends java.io.Serializable
TaskWriter
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.
|
void initialize(int taskId, int attemptId)
taskId
- the identifier of task.attemptId
- the attempt id of this task.TaskWriter<T> create()
TaskWriter
with given task id and attempt id.