JavaでFiles.readAlllinesで読み込んだ設定ファイルをstreamApiでリストに出来ないかと悩んでいます。

Question

前提・実現したいこと

JavaでFiles.readAlllinesで読み込んだ設定ファイルをstreamApiでリストに出来ないかと悩んでいます。

読みこむファイルは以下のようなファイルです。

# コメント行
<No1,
hoge,hoge,
fuga,fuga,
>,,
<No2,
piyo,piyo,
foo,foo,
>,,
<No3,
hello,hello,
>,,

実現したいリストは、以下のようなリストのリストにしたいと思っています。

[["No1","hoge","fuga"], ["No2", "piyo", "foo"], ["No3", "hello", ""]]

現在このような、処理に続けて、streamApiの中で実現できればいいなと考えています。

Files.readAlllines(path, StandardCharsets.UTF_8
.stream()
.filter( //必要ないコメント行などを消す )

できなければ、一度、全行、配列にして、ループで<から始まる行から>で始まる行までを配列に詰め直す処理を考えていますが、
もっといい方法が無いか考えております。

Answer 1

java.util.LinkedHashSet

要素が挿入された順序を保持し重複を許さないコレクションはLinkedHashSetです。これを利用するのは<から>まで(1行分)です。複数行はDeque<Set<String>>に格納します。

static Deque<Set<String>> readLines(String fileName) {
  Deque<Set<String>> result = null;
  try (BufferedReader fr = new BufferedReader(new FileReader(fileName))) {
    result = 
      fr.lines()
        .filter(s -> !s.matches("^#.*")) // コメント除去
        .flatMap(s -> Stream.of(s.split(",+")))
        .filter(s -> !s.isEmpty())
        .collect(
          ArrayDeque<Set<String>>::new, 
          (acc, s) -> {
            if (s.matches("^<.*$")) { // 行の開始
              Set<String> hs = new LinkedHashSet<>();
              hs.add(s.substring(1));
              acc.addLast(hs);
            } else if (!s.matches(".*>$")) {
              (acc.getLast()).add(s); // 要素の追加、重複除去
            }
          }, 
          Deque::addAll);
  } catch (IOException e) {
    e.printStackTrace();
  }
  return result;
}

Streamを使ってみたけれど、whileでループさせてもほぼ同じコードになります。

Stream.itearate()/limit()

リストの要素数を揃えるには末尾に""を追加しなければなりません。そのためにiterate()を使います。ただし、最長のListに長さを揃えるのか、定数を与えて揃えるのかでやり方が異なります。以下は要素数を定数3に固定したコード例です。

static Function<Integer, Stream<String>> fillSpace = h -> Stream.iterate("", s -> s).limit(3 - h);

public static void main(String[] args) {
  Deque<Set<String>> list = readLines(FILE_NAME);
  list.stream().map(
    row -> Stream.concat(row.stream(),fillSpace.apply(row.size())).collect(Collectors.toList())
  ).forEach(System.out::println);
}

fillSpaceという関数が""を必要なだけ追加します。全体に冗長です。もっと簡潔に書けると思います。Streamを使う練習だと思ってチャレンジしてみてください。

完全版(追記)

コメント行除去を追加しました。結果をList<List<String>>に変更。

import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.util.ArrayDeque;
import java.util.Deque;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
import java.util.stream.Stream;

public class SettingsToList {

  static String FILE_NAME = "... /settings.txt";
  static final int ARRAY_SIZE = 3;

  public static void main(String[] args) {
    Deque<Set<String>> list = readLines(FILE_NAME);
    //list.forEach(System.out::println);
    List<List<String>> result = 
    list.stream()
        .map( r -> Stream.concat(
                     r.stream(), 
                     Stream.iterate("", s -> s).limit(ARRAY_SIZE - r.size())
                   ).collect(Collectors.toList()))
        .collect(Collectors.toList());
    System.out.println(result);
  }
  
  static Deque<Set<String>> readLines(String fileName) {
    Deque<Set<String>> result = null;
    try (BufferedReader fr = new BufferedReader(new FileReader(fileName))) {
      result = 
        fr.lines()
          .filter(s -> !s.matches("^#.*")) // コメント除去
          .flatMap(s -> Stream.of(s.split(",+")))
          .filter(s -> !s.isEmpty())
          .collect(
            ArrayDeque<Set<String>>::new, 
            (acc, s) -> {
              if (s.matches("^<.*$")) { // 行の開始
                Set<String> hs = new LinkedHashSet<>();
                hs.add(s.substring(1));
                acc.addLast(hs);
              } else if (!s.matches(".*>$")) {
                (acc.getLast()).add(s); // 要素の追加、重複除去
              }
            }, 
            Deque::addAll);
    } catch (IOException e) {
      e.printStackTrace();
    }
    return result;
  }
}

Streamを使う意義はご自分で考えてください。

Answer 2

根本的な話として、Files.linesで一発でStreamとして引っ張れます。しかし、お望みの処理はStreamでやるには不向きです。順番に依存する処理のため、Streamのほとんどの中間処理に求められる要件を満たしませんし、どうしても副作用を必要とする処理を噛ませないと難しそうです。

「全行配列にして〜」ということですが、そもそもreadAllLinesの結果がListで返ってくるので、配列化の必要はないはずです。