Javaでストリーミング

ストリームは、集約操作をサポートするソースからのオブジェクトのシーケンスを表します。ストリームの特徴は次のとおりです-

• 要素のシーケンス −ストリームは、特定のタイプの要素のセットを順番に提供します。ストリームはオンデマンドで要素を取得/計算します。要素を保存することはありません。

• ソース − Streamは、コレクション、配列、またはI/Oリソースを入力ソースとして受け取ります。

• 集計操作 − Streamは、フィルター、マップ、制限、削減、検索、一致などの集約操作をサポートします。

• パイプライン −ほとんどのストリーム操作は、結果をパイプライン化できるようにストリーム自体を返します。これらの操作は中間操作と呼ばれ、その機能は入力を受け取り、処理して、出力をターゲットに返すことです。 collect（）メソッドは、ストリームの終わりをマークするためにパイプライン操作の最後に通常存在するターミナル操作です。

• 自動反復 −明示的な反復が必要なコレクションとは対照的に、ストリーム操作は、提供されたソース要素に対して内部的に反復を実行します。

例

例を見てみましょう-

import java.util.Collection;
import java.util.TreeSet;
import java.util.stream.Collectors;
import java.util.stream.Stream;
public class Demo {
   public static void main(String[] args) {
      Stream<String> stream = Stream.of("25", "10", "15", "20", "25");
      Collection<String> collection = stream.collect(Collectors.toCollection(TreeSet::new));
      System.out.println("Collection = "+collection);
   }
}

出力

Collection = [100, 130, 150, 20, 200, 50, 80]

例

ここで、Javaストリームcounting（）メソッドを使用してストリーム内の要素の数を数えましょう-

import java.util.*;
import java.util.stream.Collectors;
import java.util.stream.Stream;
public class Demo {
   public static void main(String[] args) {
      Stream<String> stream = Stream.of("Kevin", "Jofra","Tom", "Chris", "Liam");
      // count
      long count = stream.collect(Collectors.counting());
      System.out.println("Number of elements in the stream = "+count);
   }
}

出力

Number of elements in the stream = 5