public class RowDataTaskWriterFactory extends java.lang.Object implements TaskWriterFactory<org.apache.flink.table.data.RowData>
Constructor and 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) |
Modifier and Type | Method and 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.
|
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)
public void initialize(int taskId, int attemptId)
TaskWriterFactory
initialize
in interface TaskWriterFactory<org.apache.flink.table.data.RowData>
taskId
- the identifier of task.attemptId
- the attempt id of this task.public TaskWriter<org.apache.flink.table.data.RowData> create()
TaskWriterFactory
TaskWriter
with given task id and attempt id.create
in interface TaskWriterFactory<org.apache.flink.table.data.RowData>