BatchStateUpdate

data class BatchStateUpdate(val stream: DestinationStream.Descriptor, val checkpointCounts: Map<CheckpointId, CheckpointValue>, val state: BatchState, val taskName: String, val part: Int, val inputCount: Long = 0) : BatchUpdate

Constructors

constructor(stream: DestinationStream.Descriptor, checkpointCounts: Map<CheckpointId, CheckpointValue>, state: BatchState, taskName: String, part: Int, inputCount: Long = 0)

open override val part: Int

open override val taskName: String