Передача массива в контекст в mapreduce / hadoop - PullRequest
0 голосов
/ 24 марта 2019

Я пытаюсь передать массив в 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]

Любая помощь будет огромной, я так старался, что даже не помню, что пытался больше.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...