bulk-cdk-core-load/io.airbyte.cdk.load.message/InputStreamCheckpoint

InputStreamCheckpoint

data class InputStreamCheckpoint(val checkpoint: StreamCheckpoint) : InputCheckpoint

Constructors

Link copied to clipboard
constructor(unmappedNamespace: String?, unmappedName: String, blob: String, sourceRecordCount: Long, destinationRecordCount: Long? = null, checkpointKey: CheckpointKey? = null)
constructor(checkpoint: StreamCheckpoint)

Properties

Link copied to clipboard

Functions

Link copied to clipboard
open fun asProtobuf(): AirbyteMessage.AirbyteMessageProtobuf
Link copied to clipboard
open override fun asProtocolMessage(): AirbyteMessage
Link copied to clipboard
open fun writeProtocolMessage(dataChannelFormat: DataChannelFormat = DataChannelFormat.JSONL, outputStream: OutputStream)