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 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.