InputRecord

data class InputRecord(val stream: DestinationStream, val data: AirbyteValue, val emittedAtMs: Long, val meta: Meta?, val serialized: String, val fileReference: AirbyteRecordMessageFileReference? = null, val checkpointId: CheckpointId? = null, val unknownFieldNames: Set<String> = emptySet()) : InputMessage

Constructors

constructor(stream: DestinationStream, data: String, emittedAtMs: Long, changes: MutableList<Meta.Change> = mutableListOf(), fileReference: AirbyteRecordMessageFileReference? = null, checkpointId: CheckpointId? = null, unknownFieldNames: Set<String> = emptySet())

Convenience constructor, primarily intended for use in tests.

constructor(stream: DestinationStream, data: AirbyteValue, emittedAtMs: Long, meta: Meta?, serialized: String, fileReference: AirbyteRecordMessageFileReference? = null, checkpointId: CheckpointId? = null, unknownFieldNames: Set<String> = emptySet())

val fileReference: AirbyteRecordMessageFileReference? = null

open override fun asProtobuf(): AirbyteMessage.AirbyteMessageProtobuf

open override fun asProtocolMessage(): AirbyteMessage

open fun writeProtocolMessage(dataChannelFormat: DataChannelFormat = DataChannelFormat.JSONL, outputStream: OutputStream)