Пожалуйста, найдите нижеприведенную программу, которую я использую. Он компилируется, но не дает никакого вывода. Просьба помочь с ошибкой.
import gzip
import warc
import os
from mrjob.job import MRJob
class DocumentCounter(MRJob):
def mapper(self, _, line):
entries = os.listdir("C://Users//HP//WARCDataset")
for entry in entries:
yield 1,1
def reducer(self, key, values):
yield key, sum(values)
if __name__ == '__main__':
DocumentCounter.run()
Снимок экрана среды IDE и окна вывода. Результат не отображается, даже если программа работает успешно.