java - 返回日期，但按Apache Hadoop中的名称和值排序

Question

美好的一天，我不知道我的头衔是否是最好的，但我有以下列表:

201505011000######PEN DRIVE01470
201505011000#######NOTEBOOK11470
201605011000#######NOTEBOOK21471
201705011000#######NOTEBOOK21472
201705011000###GAVETA DE HD01472
201703011000###GAVETA DE HD01473

例如: 201505代表年份和月份，
在 #符号后，我有产品名称，在和价格 01470中代表 14,70。

我需要做的是获取每种产品的较低价格，并显示该价格的年份和月份。
但是我不知道这样做，我可以展示的是更低的价格和产品。

这是我的程序:
MAPPER

package pkg.produto;

import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;

import java.io.IOException;

public class MinProdutoMapper
        extends Mapper<LongWritable, Text, Text, IntWritable> {
    @Override
    public void map(LongWritable key, Text value, Context context)
            throws IOException, InterruptedException {
        String line = value.toString();
        String ano = line.substring(0, 6);
        String produto = line.substring(13, 27);//Nome do produto
        produto = produto.substring(produto.lastIndexOf("#") + 1);
        //String produto_ano = ano+produto ;
        int valor = Integer.parseInt(line.substring(27, 32));//Valor do produto
        context.write(new Text(produto), new IntWritable(valor));
    }
}

REDUCER

package pkg.produto;

import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Reducer;

import java.io.IOException;

public class MinProdutoReducer extends Reducer<Text, IntWritable, Text, IntWritable> {
    @Override
    public void reduce(Text key, Iterable<IntWritable> values, Context context) throws IOException, InterruptedException {
        int minValue = Integer.MAX_VALUE;
        for (IntWritable value : values) {
            minValue = Math.min(minValue, value.get());
        }
        context.write(key, new IntWritable(minValue));
    }
}

有人可以帮忙吗？

Answer 1

您可以看一下次级排序，然后修改您的解决方案。这是一个带有代码示例的链接，可以帮助您解决问题。 secondary-sort