Class RowDataTaskWriterFactory

  • All Implemented Interfaces:
    java.io.Serializable, TaskWriterFactory<org.apache.flink.table.data.RowData>

    public class RowDataTaskWriterFactory
    extends java.lang.Object
    implements TaskWriterFactory<org.apache.flink.table.data.RowData>
    See Also:
    Serialized Form
    • Constructor Summary

      Constructors 
      Constructor Description
      RowDataTaskWriterFactory​(Table table, org.apache.flink.table.types.logical.RowType flinkSchema, long targetFileSizeBytes, FileFormat format, java.util.Map<java.lang.String,​java.lang.String> writeProperties, java.util.List<java.lang.Integer> equalityFieldIds, boolean upsert)  
      RowDataTaskWriterFactory​(SerializableSupplier<Table> tableSupplier, org.apache.flink.table.types.logical.RowType flinkSchema, long targetFileSizeBytes, FileFormat format, java.util.Map<java.lang.String,​java.lang.String> writeProperties, java.util.List<java.lang.Integer> equalityFieldIds, boolean upsert)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      TaskWriter<org.apache.flink.table.data.RowData> 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.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • RowDataTaskWriterFactory

        public RowDataTaskWriterFactory​(Table table,
                                        org.apache.flink.table.types.logical.RowType flinkSchema,
                                        long targetFileSizeBytes,
                                        FileFormat format,
                                        java.util.Map<java.lang.String,​java.lang.String> writeProperties,
                                        java.util.List<java.lang.Integer> equalityFieldIds,
                                        boolean upsert)
      • RowDataTaskWriterFactory

        public RowDataTaskWriterFactory​(SerializableSupplier<Table> tableSupplier,
                                        org.apache.flink.table.types.logical.RowType flinkSchema,
                                        long targetFileSizeBytes,
                                        FileFormat format,
                                        java.util.Map<java.lang.String,​java.lang.String> writeProperties,
                                        java.util.List<java.lang.Integer> equalityFieldIds,
                                        boolean upsert)
    • Method Detail

      • initialize

        public void initialize​(int taskId,
                               int attemptId)
        Description copied from interface: TaskWriterFactory
        Initialize the factory with a given taskId and attemptId.
        Specified by:
        initialize in interface TaskWriterFactory<org.apache.flink.table.data.RowData>
        Parameters:
        taskId - the identifier of task.
        attemptId - the attempt id of this task.
      • create

        public TaskWriter<org.apache.flink.table.data.RowData> create()
        Description copied from interface: TaskWriterFactory
        Initialize a TaskWriter with given task id and attempt id.
        Specified by:
        create in interface TaskWriterFactory<org.apache.flink.table.data.RowData>
        Returns:
        a newly created task writer.