public class RowDataTaskWriterFactory
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
RowDataTaskWriterFactory.FlinkFileAppenderFactory |
Constructor and Description |
---|
RowDataTaskWriterFactory(Schema schema,
org.apache.flink.table.types.logical.RowType flinkSchema,
PartitionSpec spec,
LocationProvider locations,
FileIO io,
EncryptionManager encryptionManager,
long targetFileSizeBytes,
FileFormat format,
java.util.Map<java.lang.String,java.lang.String> tableProperties) |
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(Schema schema, org.apache.flink.table.types.logical.RowType flinkSchema, PartitionSpec spec, LocationProvider locations, FileIO io, EncryptionManager encryptionManager, long targetFileSizeBytes, FileFormat format, java.util.Map<java.lang.String,java.lang.String> tableProperties)
public void initialize(int taskId, int attemptId)
taskId
- the identifier of task.attemptId
- the attempt id of this task.public TaskWriter<org.apache.flink.table.data.RowData> create()
TaskWriter
with given task id and attempt id.