Package org.apache.iceberg.flink.sink
Class RowDataTaskWriterFactory
- java.lang.Object
-
- org.apache.iceberg.flink.sink.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)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description TaskWriter<org.apache.flink.table.data.RowData>
create()
Initialize aTaskWriter
with given task id and attempt id.void
initialize(int taskId, int attemptId)
Initialize the factory with a given taskId and attemptId.
-
-
-
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)
-
-
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 interfaceTaskWriterFactory<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 aTaskWriter
with given task id and attempt id.- Specified by:
create
in interfaceTaskWriterFactory<org.apache.flink.table.data.RowData>
- Returns:
- a newly created task writer.
-
-