Анализ файла журнала в hadoop с помощью java-программы

Question

Я написал небольшую программу карт для чтения файлов журнала и поиска слова «extract». Только если слово найдено, оно должно написать строку для объекта контекста. Но почему-то я вижу все строки в выходном файле. Вот мой код

 public void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException { 
     String line = value.toString(); 
     StringTokenizer tokenizer = new StringTokenizer(line); 
     while (tokenizer.hasMoreTokens()) { 
      word.set(tokenizer.nextToken()); 
      if(word.find("extract") >= -1) { 
       context.write(word, null); 
      } 
     } 
    } 

Не могли бы вы сообщить мне, что я делаю неправильно? Thanks, aarthi

Answer 1

Если вы хотите написать строку в контексте; вот код кода

public void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException { 

    String line = value.toString(); 

    if (line.contains("extract")) { 
     context.write(value,null); 
    } 

}