Package org.apache.iceberg.flink.sink

Interface TaskWriterFactory<T>

Type Parameters:
T - data type of record.
All Superinterfaces:
Serializable
All Known Implementing Classes:
RowDataTaskWriterFactory
public interface TaskWriterFactory<T> extends Serializable
Factory to create TaskWriter

  • Method Summary

    Modifier and Type
    Method
    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 Details

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