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

BufferedFormattingWriter

class BufferedFormattingWriter<T : OutputStream>(writer: ObjectStorageFormattingWriter, buffer: ManagedByteArrayOutputStream, streamProcessor: StreamProcessor<T>, wrappingBuffer: T) : ObjectStorageFormattingWriter(source)

Constructors

BufferedFormattingWriter

constructor(writer: ObjectStorageFormattingWriter, buffer: ManagedByteArrayOutputStream, streamProcessor: StreamProcessor<T>, wrappingBuffer: T)

Properties

val bufferSize: Int

Functions

open override fun accept(record: DestinationRecordRaw)

open override fun close()

fun finish(): ByteArray?

open override fun flush()

fun takeBytes(): ByteArray?