

def __iter__(self):
    index = 0
    for path in self.file_paths:
        index += 1
        logging.info('Reading from %s (%d/%d)', path, index, len(self.file_paths))
        with TextFileSource(path, strip_trailing_newlines=self.source.strip_trailing_newlines, coder=self.source.coder).reader() as reader:
            for line in reader:
                (yield line)

dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/io/fileio.py TextMultiFileReader.__iter__/original