PipelineMessage
data class PipelineMessage<K : WithStream, T>(val checkpointCounts: Map<CheckpointId, CheckpointValue>, val key: K, val value: T, val postProcessingCallback: suspend () -> Unit? = null, var context: PipelineContext? = null) : PipelineEvent<K, T>
A message that contains a keyed payload. The key is used to manage the state of the payload's corresponding io.airbyte.cdk.load.pipeline.BatchAccumulator. checkpointCounts is used by the CDK to perform state message bookkeeping. postProcessingCallback is for releasing resources associated with the message.
Constructors
Link copied to clipboard
constructor(checkpointCounts: Map<CheckpointId, CheckpointValue>, key: K, value: T, postProcessingCallback: suspend () -> Unit? = null, context: PipelineContext? = null)