InputGlobalCheckpoint

data class InputGlobalCheckpoint(val sharedState: JsonNode?, val checkpointKey: CheckpointKey? = null, val streamStates: List<CheckpointMessage.Checkpoint> = emptyList(), val sourceRecordCount: Long? = null) : InputCheckpoint

Constructors

constructor(sharedState: JsonNode?, checkpointKey: CheckpointKey? = null, streamStates: List<CheckpointMessage.Checkpoint> = emptyList(), sourceRecordCount: Long? = null)

val sharedState: JsonNode?

open fun asProtobuf(): AirbyteMessage.AirbyteMessageProtobuf

open override fun asProtocolMessage(): AirbyteMessage

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