Java 8 - 要素をHashMapにマージするには

Question

問題のシナリオを説明しましょう。

ファイルから一度に1行ずつ読んでいます。私は区切り記号を使用して行を分割し、各単語の頻度を数えてマップに保存します。

コードスニペット：私は次の行を読んだとき

Map<String, Integer> frequencyMap = new HashMap<>(); 
try { 
       fileReader = new FileReader(fileName); 
       BufferedReader bufferedReader = new BufferedReader(fileReader); 
       String line = ""; 
       while ((line = bufferedReader.readLine()) != null) { 
        frequencyMap = Arrays.stream(line.split(PHRASE_SEPARATOR)) 
                  .map(String::trim) 
                  .collect(Collectors.groupingBy(Function.identity(), Collectors.summingInt(e -> 1))); 
       } 
       bufferedReader.close(); 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 

はしかし、それは、既存の値にキーと値のペアをマージしません。ファイルから行を読み込んでいる間に、新しいキーと値のペアがマージされるようにするにはどうすればよいですか。

Answer 1

あなたが行くようにカウントをマージする必要があるので、あなたは、文字列のストリームとしてファイルを読み込み、分割、およびこのように、単一の実行にマップする必要があります。

Map<String,Integer> frequencyMap = Files.lines(Paths.get(fileName)) 
    .map(line -> line.split(PHRASE_SEPARATOR)) 
    .flatMap(Arrays::stream) 
    .map(String::trim) 
    .collect(Collectors.groupingBy(Function.identity(), Collectors.summingInt(e -> 1))); 

または例外セーフなアプローチを使用します：あなたは、現在の行のマップを持っていたら

Map<String,Integer> frequencyMap = null; 
try (Stream<String> stream = Files.lines(Paths.get(fileName))) { 
    frequencyMap = stream 
     .map(line -> line.split(PHRASE_SEPARATOR)) 
     .flatMap(Arrays::stream) 
     .map(String::trim) 
     .collect(Collectors.groupingBy(Function.identity(), Collectors.summingInt(e -> 1))); 
} catch (IOException e) { 
    e.printStackTrace(); 
} 

Demo.

Answer 2

あなたのコードはすべての反復でfrequencyMapを置き換えているため、それらはすべてカウントされません。

また、マップ操作の出力がリストの場合は、flatMapを使用して、そのリスト内のすべてのエントリをストリームのエントリとして追加できます。このタイプの一対多の関係を行うときに非常に役立ちます。このような何かがうまくいくかもしれない

は、それをテストする機会がなかった。

import java.io.IOException; 
import java.nio.file.Files; 
import java.nio.file.Paths; 
import java.util.Map; 
import java.util.function.Function; 
import java.util.stream.Collectors; 
import java.util.stream.Stream; 

public class FileReaderTest { 

public void main(String[] args) { 

    String fileName = args[0]; //sorry, getting lazy here... 

    try (Stream<String> stream = Files.lines(Paths.get(fileName))) { 
     Map<String, Long> frequencyMap = stream 
       .flatMap(line -> Stream.of(line.split(LINE_SEPARATOR))) 
       .map(String::trim) 
       .collect(Collectors.groupingBy(
         Function.identity(), 
         Collectors.counting())); 
    } catch (IOException e) { 
     e.printStackTrace(); 
    } 
} 

}

このコードの問題は、それが最終的にはメモリ内のファイル全体をロードすることです。小さなファイルの場合は大丈夫ですが、大きなファイルの場合は実装が異なります。

Answer 3

は、ファイル全体のための周波数をカウントマップでそれをマージする必要があります。

Map<String, Long> lineFrequencies = Arrays.stream(line.split(PHRASE_SEPARATOR)) 
    .map(String::trim) 
    .collect(Collectors.groupingBy(
     Function.identity(), 
     Collectors.counting())); 

// Merging of lineFrequencies into frequencyMap happens here 
lineFrequencies.forEach((k, v) -> frequencyMap.merge(k, v, Long::sum)); 

ここで私は存在しない値（で提供された値をマージする（この場合Long::sumで）提供される機能を使用していますMap.merge方法を、使用しました：だから、あなたのwhileループ内で、私はこれを行うだろうマップに指定されたキーのマッピングがすでに存在する場合）、または指定されたキーを指定された値にマップします（マップに指定されたキーのマッピングが含まれていない場合）。

このコードでは、frequencyMapをMap<String, Integer>からMap<String, Long>に変更する必要があります。これはIMHOには影響しません。