BatchStateUpdate

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