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

UnpartitionedAppendWriter

class UnpartitionedAppendWriter(spec: PartitionSpec, format: FileFormat, appenderFactory: FileAppenderFactory<Record>, outputFileFactory: OutputFileFactory, io: FileIO, targetFileSize: Long) : UnpartitionedWriter<Record>

org.apache.iceberg.io.BaseTaskWriter implementation that handles append-only writes to an un-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)

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)