org.apache.iceberg.flink.sink

Class RowDataTaskWriterFactory

java.lang.Object

org.apache.iceberg.flink.sink.RowDataTaskWriterFactory

public class RowDataTaskWriterFactory
extends java.lang.Object

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RowDataTaskWriterFactory.FlinkFileAppenderFactory

Constructor Summary

Constructors

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)

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RowDataTaskWriterFactory

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)

Method Detail

initialize

public 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

public TaskWriter<org.apache.flink.table.data.RowData> create()

Initialize a TaskWriter with given task id and attempt id.

Returns:

a newly created task writer.