

def map(self):
    reader = csv.reader(self.stream)
    for row in reader:
        self.emit(row[14], row[31])

dataset/ETHPy150Open bbengfort/hadoop-fundamentals/avgdelay/mapper.py Mapper.map/original