org.apache.iceberg.connect.data

Class PartitionedAppendWriter

java.lang.Object

org.apache.iceberg.io.BaseTaskWriter<T>

org.apache.iceberg.io.PartitionedFanoutWriter<Record>

org.apache.iceberg.connect.data.PartitionedAppendWriter

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, TaskWriter<Record>

public class PartitionedAppendWriter
extends PartitionedFanoutWriter<Record>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.iceberg.io.BaseTaskWriter

BaseTaskWriter.BaseEqualityDeltaWriter, BaseTaskWriter.RollingEqDeleteWriter, BaseTaskWriter.RollingFileWriter

Constructor Summary

Constructors

Constructor and Description
PartitionedAppendWriter(PartitionSpec spec, FileFormat format, FileAppenderFactory<Record> appenderFactory, OutputFileFactory fileFactory, FileIO io, long targetFileSize, Schema schema)

Method Summary

Modifier and Type	Method and Description
protected PartitionKey	partition(Record row) Create a PartitionKey from the values in row.

Methods inherited from class org.apache.iceberg.io.PartitionedFanoutWriter

close, write

Methods inherited from class org.apache.iceberg.io.BaseTaskWriter

abort, complete, setFailure, spec

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.iceberg.io.TaskWriter

dataFiles

Constructor Detail

PartitionedAppendWriter

public PartitionedAppendWriter(PartitionSpec spec,
                               FileFormat format,
                               FileAppenderFactory<Record> appenderFactory,
                               OutputFileFactory fileFactory,
                               FileIO io,
                               long targetFileSize,
                               Schema schema)

Method Detail

partition

protected PartitionKey partition(Record row)

Description copied from class: PartitionedFanoutWriter

Create a PartitionKey from the values in row.

Any PartitionKey returned by this method can be reused by the implementation.

Specified by:

partition in class PartitionedFanoutWriter<Record>

Parameters:

row - a data row