'Args:
ds (DataFlow): input dataflow
size (int): size'

def __init__(self, ds, size):

    super(FixedSizeData, self).__init__(ds)
    self._size = int(size)
    self.itr = None
    self._guard = DataFlowReentrantGuard()
