Stream

Java – Stream APIの使い方をわかりやすく解説

JavaのStream APIは、コレクションや配列のデータ処理を簡潔に記述するための機能です。

主に「データのフィルタリング」「変換」「集約」などを行います。

Streamはデータを一方向に流し、元のデータを変更しません。

基本的な使い方は、コレクションから.stream()でStreamを生成し、.filter()で条件を指定、.map()で変換、.collect()で結果を収集します。

例えば、リストから偶数を抽出して2倍にする場合、list.stream().filter(x -> x % 2 == 0).map(x -> x * 2).collect(Collectors.toList())のように記述します。

Streamは遅延評価を採用しており、効率的なデータ処理が可能です。

目次から探す

Stream APIとは

JavaのStream APIは、コレクションや配列などのデータソースに対して、宣言的な方法で操作を行うための機能です。

Java 8から導入され、データの処理をより簡潔かつ効率的に行うことができます。

Stream APIを使用することで、以下のような利点があります。

簡潔なコード: 複雑なループ処理を簡単に記述できる。
遅延評価: 必要なデータのみを処理するため、パフォーマンスが向上する。
並列処理: 簡単に並列処理を実現できるため、大量のデータを効率的に処理できる。

Stream APIは、データの変換、フィルタリング、集約などの操作を行うための中間操作と終端操作を提供しています。

これにより、データの流れを直感的に表現することが可能です。

Stream APIの基本的な使い方

Stream APIを使用するためには、まずデータソースを用意し、そのデータソースからStreamを生成します。

Streamは、コレクションや配列などのデータを操作するための抽象的なデータ構造です。

以下に、Stream APIの基本的な使い方を示すサンプルコードを示します。

import java.util.Arrays;
import java.util.List;
public class App {
    public static void main(String[] args) {
        // サンプルデータのリストを作成
        List<String> fruits = Arrays.asList("りんご", "バナナ", "オレンジ", "ぶどう", "いちご");
        // Streamを生成し、各果物を大文字に変換して表示
        fruits.stream() // Streamを生成
              .map(fruit -> fruit.toUpperCase()) // 各要素を大文字に変換
              .forEach(System.out::println); // 結果を表示
    }
}

このコードでは、以下の処理を行っています。

Listを使用して果物のサンプルデータを作成。
stream()メソッドを呼び出して、リストからStreamを生成。
map()メソッドを使用して、各果物の名前を大文字に変換。
forEach()メソッドで、変換した果物の名前をコンソールに表示。

このように、Stream APIを使うことで、データの操作を簡潔に記述することができます。

りんご
バナナ
オレンジ
ぶどう
いちご

主な中間操作

Stream APIには、データを変換・フィルタリングするための中間操作がいくつか用意されています。

中間操作は、Streamを返すため、複数の操作を連鎖させることができます。

以下に、主な中間操作をいくつか紹介します。

操作名	説明	例
`filter`	条件に合致する要素を抽出する	`stream.filter(fruit -> fruit.startsWith("い"))`
`map`	各要素を変換する	`stream.map(fruit -> fruit.length())`
`distinct`	重複する要素を排除する	`stream.distinct()`
`sorted`	要素をソートする	`stream.sorted()`
`limit`	指定した数の要素を取得する	`stream.limit(3)`
`skip`	指定した数の要素をスキップする	`stream.skip(2)`

例: 中間操作の使用

以下のサンプルコードでは、filterとmapを使用して、特定の条件に合致する要素を抽出し、その要素の長さを表示します。

import java.util.Arrays;
import java.util.List;
public class App {
    public static void main(String[] args) {
        // サンプルデータのリストを作成
        List<String> fruits = Arrays.asList("りんご", "バナナ", "オレンジ", "ぶどう", "いちご");
        // "い"で始まる果物の名前の長さを表示
        fruits.stream() // Streamを生成
              .filter(fruit -> fruit.startsWith("い")) // "い"で始まる果物を抽出
              .map(String::length) // 各果物の名前の長さを取得
              .forEach(System.out::println); // 結果を表示
    }
}

このコードでは、filterを使って「い」で始まる果物を抽出し、mapを使ってその名前の長さを取得しています。

3
3

このように、中間操作を組み合わせることで、データの処理を柔軟に行うことができます。

主な終端操作

Stream APIには、データの処理を完了させるための終端操作がいくつか用意されています。

終端操作は、Streamの処理を実行し、結果を生成するためのメソッドです。

以下に、主な終端操作をいくつか紹介します。

操作名	説明	例
`forEach`	各要素に対して指定した処理を実行する	`stream.forEach(fruit -> System.out.println(fruit))`
`collect`	Streamの要素をコレクションに集約する	`stream.collect(Collectors.toList())`
`reduce`	要素を集約して単一の結果を生成する	`stream.reduce(0, (sum, fruit) -> sum + fruit.length())`
`count`	要素の数をカウントする	`stream.count()`
`anyMatch`	条件に合致する要素が存在するか確認する	`stream.anyMatch(fruit -> fruit.equals("りんご"))`
`allMatch`	全ての要素が条件に合致するか確認する	`stream.allMatch(fruit -> fruit.length() > 2)`

例: 終端操作の使用

以下のサンプルコードでは、collectを使用して、果物の名前をリストに集約し、forEachでそのリストを表示します。

import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
public class App {
    public static void main(String[] args) {
        // サンプルデータのリストを作成
        List<String> fruits = Arrays.asList("りんご", "バナナ", "オレンジ", "ぶどう", "いちご");
        // Streamを生成し、果物の名前を大文字に変換してリストに集約
        List<String> upperCaseFruits = fruits.stream() // Streamを生成
                                              .map(String::toUpperCase) // 各果物を大文字に変換
                                              .collect(Collectors.toList()); // リストに集約
        // 集約したリストを表示
        upperCaseFruits.forEach(System.out::println); // 結果を表示
    }
}

このコードでは、mapを使って果物の名前を大文字に変換し、collectを使ってその結果をリストに集約しています。

りんご
バナナ
オレンジ
ぶどう
いちご

このように、終端操作を使用することで、Streamの処理を完了させ、結果を得ることができます。

Stream APIの応用例

Stream APIは、データの処理を効率的に行うための強力なツールです。

ここでは、実際のアプリケーションでの応用例をいくつか紹介します。

これにより、Stream APIの使い方をより具体的に理解できるでしょう。

フィルタリングと集計

特定の条件に合致するデータをフィルタリングし、その結果を集計する例です。

以下のコードでは、果物のリストから「い」で始まる果物の数をカウントします。

import java.util.Arrays;
import java.util.List;
public class App {
    public static void main(String[] args) {
        // サンプルデータのリストを作成
        List<String> fruits = Arrays.asList("りんご", "バナナ", "いちご", "オレンジ", "いちじく");
        // "い"で始まる果物の数をカウント
        long count = fruits.stream() // Streamを生成
                           .filter(fruit -> fruit.startsWith("い")) // "い"で始まる果物を抽出
                           .count(); // カウント
        // 結果を表示
        System.out.println("「い」で始まる果物の数: " + count);
    }
}

「い」で始まる果物の数: 2

並列処理

Stream APIを使用すると、簡単に並列処理を実現できます。

以下のコードでは、果物のリストを並列に処理し、各果物の名前を大文字に変換します。

import java.util.Arrays;
import java.util.List;
public class App {
    public static void main(String[] args) {
        // サンプルデータのリストを作成
        List<String> fruits = Arrays.asList("りんご", "バナナ", "オレンジ", "ぶどう", "いちご");
        // 並列処理で果物の名前を大文字に変換
        fruits.parallelStream() // 並列Streamを生成
              .map(String::toUpperCase) // 各果物を大文字に変換
              .forEach(System.out::println); // 結果を表示
    }
}

りんご
バナナ
オレンジ
ぶどう
いちご

複雑なデータ処理

Stream APIは、複雑なデータ処理にも対応しています。

以下の例では、果物のリストから名前の長さが5文字以上の果物を抽出し、その名前を大文字に変換してリストに集約します。

import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
public class App {
    public static void main(String[] args) {
        // サンプルデータのリストを作成
        List<String> fruits = Arrays.asList("りんご", "バナナ", "オレンジ", "ぶどう", "いちご", "いちじく");
        // 名前の長さが5文字以上の果物を大文字に変換してリストに集約
        List<String> longFruits = fruits.stream() // Streamを生成
                                         .filter(fruit -> fruit.length() >= 5) // 名前の長さが5文字以上を抽出
                                         .map(String::toUpperCase) // 大文字に変換
                                         .collect(Collectors.toList()); // リストに集約
        // 結果を表示
        longFruits.forEach(System.out::println); // 結果を表示
    }
}

オレンジ
いちご
いちじく

これらの応用例を通じて、Stream APIの強力な機能を活用し、データ処理を効率的に行う方法を理解できるでしょう。

Stream APIを使う際の注意点

Stream APIは非常に便利ですが、使用する際にはいくつかの注意点があります。

これらを理解しておくことで、より効果的にStream APIを活用できるでしょう。

以下に主な注意点を挙げます。

不変性

Streamは不変であるため、元のデータソースを変更することはできません。

Streamを操作しても、元のコレクションや配列はそのまま残ります。

これにより、データの整合性が保たれますが、意図しない変更を避けるために注意が必要です。

遅延評価

Streamの操作は遅延評価されます。

つまり、中間操作は実行されず、終端操作が呼び出されるまで実行されません。

この特性を理解しておかないと、意図した結果が得られない場合があります。

特に、デバッグ時には注意が必要です。

並列処理の注意

parallelStream()を使用して並列処理を行う場合、スレッドセーフでないコレクションや状態を持つオブジェクトを扱うと、予期しない結果を引き起こす可能性があります。

並列処理を行う際は、データの整合性を保つために注意が必要です。

パフォーマンスの考慮

Stream APIは便利ですが、必ずしもパフォーマンスが向上するわけではありません。

特に小規模なデータセットでは、従来のループ処理の方が効率的な場合があります。

データの規模や処理内容に応じて、適切な手法を選択することが重要です。

例外処理

Stream内で発生した例外は、通常の方法で処理することができません。

特に、mapやfilterなどの中間操作内で例外が発生した場合、Stream全体が中断されます。

例外処理を行う際は、適切な方法でエラーハンドリングを行う必要があります。

これらの注意点を理解し、適切にStream APIを使用することで、より効果的にデータ処理を行うことができます。

Stream APIと従来のループ処理の比較

Stream APIと従来のループ処理(forループや拡張forループ)には、それぞれの利点と欠点があります。

以下に、両者を比較し、どのような場面で使い分けるべきかを考察します。

特徴	Stream API	従来のループ処理
可読性	宣言的なスタイルで、コードが簡潔でわかりやすい	命令的なスタイルで、コードが長くなることがある
パフォーマンス	大規模データに対しては並列処理が可能	小規模データに対しては効率的な場合が多い
不変性	元のデータソースを変更しない	元のデータソースを変更することがある
遅延評価	中間操作は遅延評価される	即時に処理が実行される
エラーハンドリング	例外処理が難しい場合がある	通常のtry-catchでエラーハンドリングが可能
状態管理	ステートレスであるため、状態を持たない	状態を持つことができる