Общий счетчик в функции карты hadoop - PullRequest
Новая
       7

Общий счетчик в функции карты hadoop

0 голосов
/ 28 января 2019

Мне нужно поделиться счетчиком из моего картографа.Это возможно?Если так, как это делается? 

public class CounterMapper extends Mapper<Text,Text,Text,Text> {

@Override
protected void map(Text key, Text value, Context context)
                throws IOException, InterruptedException {

    String splittedkey = //some logic ok key

    if(context.getCounter("my_counters", splittedkey).getValue() == 0 )
       context.getCounter("my_counters", splittedkey).increment(1);
    context.write(key, value);
    }
}

В моем драйвере у меня есть список карт, уменьшенный на startRow и StopRow, иногда результат этого сканирования такой же, и мне нужно прыгнуть внутрьфункция карты, но значение my_counters всегда равно нулю.Любое предложение по этому поводу?

...