bulk-cdk-toolkit-load-iceberg-parquet/io.airbyte.cdk.load.toolkits.iceberg.parquet.io/PartitionedAppendWriter

PartitionedAppendWriter

class PartitionedAppendWriter(spec: PartitionSpec, format: FileFormat, appenderFactory: FileAppenderFactory<Record>, outputFileFactory: OutputFileFactory, io: FileIO, targetFileSize: Long, schema: Schema) : PartitionedWriter<Record>

org.apache.iceberg.io.BaseTaskWriter implementation that handles append-only writes to a partitioned Iceberg org.apache.iceberg.Table.

Constructors

Link copied to clipboard
constructor(spec: PartitionSpec, format: FileFormat, appenderFactory: FileAppenderFactory<Record>, outputFileFactory: OutputFileFactory, io: FileIO, targetFileSize: Long, schema: Schema)

Functions

Link copied to clipboard
open override fun abort()
Link copied to clipboard
open override fun close()
Link copied to clipboard
open override fun complete(): WriteResult
Link copied to clipboard
open fun dataFiles(): Array<DataFile>
Link copied to clipboard
open override fun write(p0: Record)