'Args:
ds (DataFlow): input DataFlow
nr (int): number of times to repeat each datapoint.'

def __init__(self, ds, nr):

    self.nr = int(nr)
    assert (self.nr >= 1), self.nr
    super(RepeatedDataPoint, self).__init__(ds)
