bulk-cdk-toolkit-legacy-task-load-object-storage/io.airbyte.cdk.load.file.object_storage/AvroFormattingWriter

AvroFormattingWriter

class AvroFormattingWriter(stream: DestinationStream, outputStream: OutputStream, formatConfig: AvroFormatConfiguration, rootLevelFlattening: Boolean) : ObjectStorageFormattingWriter(source)

Constructors

AvroFormattingWriter

constructor(stream: DestinationStream, outputStream: OutputStream, formatConfig: AvroFormatConfiguration, rootLevelFlattening: Boolean)

Properties

val log: KLogger

Functions

open override fun accept(record: DestinationRecordRaw)

open override fun close()

open override fun flush()