使用mr程序统计每年入职的人数。 最终结果要求如下： 1. 格式如下： 年份：1980 人数:xxx 年份：1981 人数:xxx ....... 2. 两个分区： 0分区存储 入职年份<1982年的 1分区存储 入职年份>=1982年的

好的，你的问题是如何使用mr程序统计每年入职的人数，最终结果要求按年份排序并输出格式如下：

年份：1980 人数：xxx
年份：1981 人数：xxx
......

同时，要求将数据分为两个分区，入职年份<1982年的存储在0分区，入职年份>=1982年的存储在1分区。

首先，我们需要将输入数据按照入职年份进行排序，这可以使用MapReduce框架中的shuffle机制实现。具体来说，我们可以在map阶段将每条数据的入职年份作为key，将整条数据作为value，然后在reduce阶段对每个年份的数据进行统计计算。

同时，我们可以在map阶段将数据分为0分区和1分区，具体方法是在map函数中加入一个判断语句，根据入职年份的大小将数据输出到不同的分区中。

下面是示例代码：

from mrjob.job import MRJob

class EmployeeCount(MRJob):

    def mapper(self, _, line):
        # 将每条数据的入职年份作为key，将整条数据作为value
        data = line.strip().split(',')
        year = int(data[2])
        yield year, data

        # 将数据分为0分区和1分区
        if year < 1982:
            yield '0', data
        else:
            yield '1', data

    def reducer(self, year, values):
        # 统计每个年份的入职人数
        count = 0
        for v in values:
            count += 1
        yield f'年份：{year}\t人数：{count}'

if __name__ == '__main__':
    EmployeeCount.run()

在运行该程序时，可以使用以下命令将输入数据加载到HDFS中：

hadoop fs -put input.txt /input

然后，使用以下命令运行MapReduce作业：

python employee_count.py hdfs:///input --output-dir hdfs:///output

最后，使用以下命令将输出结果从HDFS中下载到本地：

hadoop fs -get /output/part-00000 output.txt

输出结果将保存在output.txt文件中。