Я пытаюсь передать массив в MapReduce в Hadoop.
for (Map.Entry<Integer, ArrayList<Integer>>entry : treemap.entrySet()) {
str2 = entry.getKey() + "" + entry.getValue();
context.write(new IntWritable(entry.getKey()), new Text(str2));
}
Я получаю список моего массива x раз для x ключей, как и следовало ожидать.Мне нужно всего лишь х раз.
Я хочу11 [2105, 1953, 1339]2 2 [2105, 1321, 13393 3 [1321, 1544, 1222]
Я получаю11 [2105, 1953, 1339]2 2 [2105, 1321, 1339]3 3 [1321, 1544, 1222]11 [2105, 1953, 1339]2 2 [2105, 1321, 1339]3 3 [1321, 1544, 1222]11 [2105, 1953, 1339]2 2 [2105, 1321, 1339]3 3 [1321, 1544, 1222]
Любая помощь будет огромной, я так старался, что даже не помню, что пытался больше.