モジュール java.base

パッケージ java.util.stream

インタフェースDoubleStream

すべてのスーパー・インタフェース:

AutoCloseable, BaseStream<Double,DoubleStream>

public interface DoubleStream
extends BaseStream<Double,DoubleStream>

順次および並列の集約操作をサポートするプリミティブdouble値要素のシーケンスです。 これは、Streamに対してdoubleプリミティブ特殊化を行ったものです。

次の例は、StreamとDoubleStreamを使って赤色のウィジェットの重さの合計を計算する集計操作を示したものです。

     double sum = widgets.stream()
                         .filter(w -> w.getColor() == RED)
                         .mapToDouble(w -> w.getWeight())
                         .sum();
 

ストリーム、ストリーム操作、ストリーム・パイプライン、および並列性の詳しい仕様については、Streamのクラス・ドキュメントやjava.util.streamのパッケージ・ドキュメントを参照してください。

導入されたバージョン:

1.8

関連項目:

Stream, java.util.stream

ネストされたクラスのサマリー

ネストされたクラス

修飾子と型	インタフェース	説明
static interface	DoubleStream.Builder	DoubleStreamの可変ビルダーです。

メソッドのサマリー

修飾子と型	メソッド	説明
boolean	allMatch(DoublePredicate predicate)	このストリームのすべての要素が指定された述語に一致するかどうかを返します。
boolean	anyMatch(DoublePredicate predicate)	このストリームのいずれかの要素が指定された述語に一致するかどうかを返します。
OptionalDouble	average()	このストリームの要素の算術平均を記述するOptionalDoubleを返します。このストリームが空の場合は空のOptionalを返します。
Stream<Double>	boxed()	このストリームの各要素をDoubleにボクシングした結果から構成されるStreamを返します。
static DoubleStream.Builder	builder()	DoubleStreamのビルダーを返します。
<R> R	collect(Supplier<R> supplier, ObjDoubleConsumer<R> accumulator, BiConsumer<R,R> combiner)	このストリームの要素に対して可変リダクション操作を実行します。
static DoubleStream	concat(DoubleStream a, DoubleStream b)	最初のストリームの全要素と2番目のストリームの全要素を連結したものを要素に持つ、遅延連結ストリームを作成します。
long	count()	このストリームの要素の個数を返します。
DoubleStream	distinct()	このストリームの重複を除いた要素から構成されるストリームを返します。
default DoubleStream	dropWhile(DoublePredicate predicate)	このストリームが順序付けされている場合、指定された述語と一致する要素の最長接頭辞を削除した後に、このストリームの残りの要素で構成されるストリームを返します。
static DoubleStream	empty()	空の順次DoubleStreamを返します。
DoubleStream	filter(DoublePredicate predicate)	このストリームの要素のうち、指定された述語に一致するものから構成されるストリームを返します。
OptionalDouble	findAny()	ストリームの一部の要素を記述するOptionalDoubleを返します。ストリームが空の場合は空のOptionalDoubleを返します。
OptionalDouble	findFirst()	このストリームの最初の要素を記述するOptionalDoubleを返します。ストリームが空の場合は空のOptionalDoubleを返します。
DoubleStream	flatMap(DoubleFunction<? extends DoubleStream> mapper)	このストリームの各要素をマップされたストリーム(指定されたマッピング関数を各要素に適用することで得られる)の内容で置き換えた結果から成るストリームを返します。
void	forEach(DoubleConsumer action)	このストリームの各要素に対してアクションを実行します。
void	forEachOrdered(DoubleConsumer action)	このストリームの各要素に対してアクションを実行します。検出順が定義されたストリームでは、各要素が検出順に処理されることが保証されます。
static DoubleStream	generate(DoubleSupplier s)	指定されたDoubleSupplierによって生成される要素を含む、順序付けされていない無限順次ストリームを返します。
static DoubleStream	iterate(double seed, DoublePredicate hasNext, DoubleUnaryOperator next)	指定されたnext関数の初期要素への反復適用によって生成される、順序付けられたDoubleStreamを、指定されたhasNext述語を満たすことを条件として戻します。
static DoubleStream	iterate(double seed, DoubleUnaryOperator f)	初期要素seedに関数fを繰り返し適用することで生成される、順序付けされた無限順次DoubleStreamを返します(seed、f(seed)、f(f(seed))、といった要素から成るStreamが生成される)。
DoubleStream	limit(long maxSize)	このストリームの要素をmaxSize以内の長さに切り詰めた結果から成るストリームを返します。
DoubleStream	map(DoubleUnaryOperator mapper)	このストリームの要素に指定された関数を適用した結果から構成されるストリームを返します。
IntStream	mapToInt(DoubleToIntFunction mapper)	このストリームの要素に指定された関数を適用した結果から構成されるIntStreamを返します。
LongStream	mapToLong(DoubleToLongFunction mapper)	このストリームの要素に指定された関数を適用した結果から構成されるLongStreamを返します。
<U> Stream<U>	mapToObj(DoubleFunction<? extends U> mapper)	指定された関数をこのストリームの要素に適用した結果から構成される、オブジェクト値のStreamを返します。
OptionalDouble	max()	このストリームの最大要素を記述するOptionalDoubleまたは空のOptionalDouble(このストリームが空の場合)を返します。
OptionalDouble	min()	このストリームの最小要素を記述するOptionalDoubleまたは空のOptionalDouble(このストリームが空の場合)を返します。
boolean	noneMatch(DoublePredicate predicate)	指定された述語に一致する要素がこのストリーム内に存在しないかどうかを返します。
static DoubleStream	of(double t)	単一要素を含む順次DoubleStreamを返します。
static DoubleStream	of(double... values)	指定された値を要素に持つ、順序付けされた順次ストリームを返します。
DoubleStream	peek(DoubleConsumer action)	このストリームの要素から成るストリームを返すほか、その結果のストリームから消費される各要素に対し、指定されたアクションを実行します。
double	reduce(double identity, DoubleBinaryOperator op)	指定された単位元の値と結合的な累積関数を使ってこのストリームの要素に対してリダクションを実行し、リデュースされた値を返します。
OptionalDouble	reduce(DoubleBinaryOperator op)	結合的累積関数を使用して、このストリームの要素に対してリダクションを実行し、リダクションされた値を記述するOptionalDoubleを返します(ある場合)。
DoubleStream	skip(long n)	このストリームの最初のn個の要素を破棄した残りの要素で構成されるストリームを返します。
DoubleStream	sorted()	このストリームの要素で構成されるストリームをソートされた順序で返します。
double	sum()	このストリーム内の要素の合計を返します。
DoubleSummaryStatistics	summaryStatistics()	このストリームの要素に関する各種のサマリー・データを記述するDoubleSummaryStatisticsを返します。
default DoubleStream	takeWhile(DoublePredicate predicate)	このストリームが順序付けされている場合、指定された述語と一致する、このストリームから取得された要素の最長接頭辞で構成されるストリームを返します。
double[]	toArray()	このストリームの要素を含む配列を返します。

インタフェースjava.util.streamで宣言されたメソッド。BaseStream

close, isParallel, iterator, onClose, parallel, sequential, spliterator, unordered

メソッドの詳細

filter

DoubleStream filter(DoublePredicate predicate)

このストリームの要素のうち、指定された述語に一致するものから構成されるストリームを返します。

これは中間操作です。

パラメータ:

predicate - 各要素を含めるべきか判定する目的で各要素に適用する、非干渉でステートレスな述語

戻り値:

新しいストリーム

map

DoubleStream map(DoubleUnaryOperator mapper)

このストリームの要素に指定された関数を適用した結果から構成されるストリームを返します。

これは中間操作です。

パラメータ:

mapper - 各要素に適用する非干渉でステートレスな関数

戻り値:

新しいストリーム

mapToObj

<U> Stream<U> mapToObj(DoubleFunction<? extends U> mapper)

指定された関数をこのストリームの要素に適用した結果から構成される、オブジェクト値のStreamを返します。

これは中間操作です。

型パラメータ:

U - 新しいストリームの要素の型

パラメータ:

mapper - 各要素に適用する非干渉でステートレスな関数

戻り値:

新しいストリーム

mapToInt

IntStream mapToInt(DoubleToIntFunction mapper)

このストリームの要素に指定された関数を適用した結果から構成されるIntStreamを返します。

これは中間操作です。

パラメータ:

mapper - 各要素に適用する非干渉でステートレスな関数

戻り値:

新しいストリーム

mapToLong

LongStream mapToLong(DoubleToLongFunction mapper)

このストリームの要素に指定された関数を適用した結果から構成されるLongStreamを返します。

これは中間操作です。

パラメータ:

mapper - 各要素に適用する非干渉でステートレスな関数

戻り値:

新しいストリーム

flatMap

DoubleStream flatMap(DoubleFunction<? extends DoubleStream> mapper)

このストリームの各要素をマップされたストリーム(指定されたマッピング関数を各要素に適用することで得られる)の内容で置き換えた結果から成るストリームを返します。 各マップ先ストリームは、その内容がこのストリーム内に配置されるとクローズされます。 (マップ先ストリームがnullの場合はかわりに空のストリームが使用されます。)

これは中間操作です。

パラメータ:

mapper - 新しい値のDoubleStreamを生成するために各要素に適用する、非干渉でステートレスな関数

戻り値:

新しいストリーム

関連項目:

Stream.flatMap(Function)

distinct

DoubleStream distinct()

このストリームの重複を除いた要素から構成されるストリームを返します。 要素が等しいかどうかの比較は、Double.compare(double, double)に従って行われます。

これはステートフルな中間操作です。

戻り値:

結果のストリーム

sorted

DoubleStream sorted()

このストリームの要素で構成されるストリームをソートされた順序で返します。 要素が等しいかどうかの比較は、Double.compare(double, double)に従って行われます。

これはステートフルな中間操作です。

戻り値:

結果のストリーム

peek

DoubleStream peek(DoubleConsumer action)

このストリームの要素から成るストリームを返すほか、その結果のストリームから消費される各要素に対し、指定されたアクションを実行します。

これは中間操作です。

並列ストリーム・パイプラインの場合、上流の操作によって用意された各要素に対し、任意のタイミングで任意のスレッド内でアクションが呼び出される可能性があります。 アクションが共有状態を変更する場合、必要な同期を提供する責任はアクションにあります。

APIのノート:

このメソッドの主な存在理由は、要素がパイプライン内の特定のポイントを通過する際にその内容を確認するようなデバッグをサポートすることにあります。

     DoubleStream.of(1, 2, 3, 4)
         .filter(e -> e > 2)
         .peek(e -> System.out.println("Filtered value: " + e))
         .map(e -> e * e)
         .peek(e -> System.out.println("Mapped value: " + e))
         .sum();
 

ストリーム実装で、一部またはすべての要素(findFirstなどの短絡操作やcount()で説明する例など)の生産を最適化できる場合、それらの要素に対してアクションは起動されません。

パラメータ:

action - ストリームから消費される要素に対して実行すべき非干渉アクション

戻り値:

新しいストリーム

limit

DoubleStream limit(long maxSize)

このストリームの要素をmaxSize以内の長さに切り詰めた結果から成るストリームを返します。

これは、ステートフルな短絡中間操作です。

APIのノート:

limit()は、順次ストリーム・パイプラインでは一般に低コストの操作ですが、順序付けされた並列パイプラインではコストが非常に高くなる可能性があります(特にmaxSizeの値が大きい場合)。任意のn個の要素を返すだけでなく、検出順での最初のn個の要素を返さなければいけない、という制約がlimit(n)に課されるからです。 状況のセマンティックスが許せば、順序付けされていないストリーム・ソース(generate(DoubleSupplier)など)を使用するか、BaseStream.unordered()で順序付けの制約をなくせば、並列パイプラインのlimit()が大幅に高速化される可能性があります。 検出順序との整合性が必要で、かつ並列パイプラインでのlimit()のパフォーマンスやメモリー使用量に問題がある場合には、BaseStream.sequential()で順次実行に切り替えるとパフォーマンスが改善される可能性があります。

パラメータ:

maxSize - ストリームの要素数の上限

戻り値:

新しいストリーム

例外:

IllegalArgumentException - maxSizeが負の場合

skip

DoubleStream skip(long n)

このストリームの最初のn個の要素を破棄した残りの要素で構成されるストリームを返します。 このストリームに含まれる要素の数がn個より少ない場合は、空のストリームが返されます。

これはステートフルな中間操作です。

APIのノート:

skip()は、順次ストリーム・パイプラインでは一般に低コストの操作ですが、順序付けされた並列パイプラインではコストが非常に高くなる可能性があります(特にnの値が大きい場合)。任意のn個の要素をスキップするだけでなく、検出順での最初のn個の要素をスキップしなければいけない、という制約がskip(n)に課されるからです。 状況のセマンティックスが許せば、順序付けされていないストリーム・ソース(generate(DoubleSupplier)など)を使用するか、BaseStream.unordered()で順序付けの制約をなくせば、並列パイプラインのskip()が大幅に高速化される可能性があります。 検出順序との整合性が必要で、かつ並列パイプラインでのskip()のパフォーマンスやメモリー使用量に問題がある場合には、BaseStream.sequential()で順次実行に切り替えるとパフォーマンスが改善される可能性があります。

パラメータ:

n - スキップする先頭要素の数

戻り値:

新しいストリーム

例外:

IllegalArgumentException - nが負の場合

takeWhile

default DoubleStream takeWhile(DoublePredicate predicate)

このストリームが順序付けされている場合、指定された述語と一致する、このストリームから取得された要素の最長接頭辞で構成されるストリームを返します。 それ以外の場合は、このストリームが順序付けられていない場合、指定された述語と一致するこのストリームから取得された要素のサブセットで構成されるストリームが返されます。

このストリームが順序付けされている場合、最も長い接頭辞は、指定された述語と一致するこのストリームの要素の連続したシーケンスです。 シーケンスの最初の要素がこのストリームの最初の要素であり、シーケンスの最後の要素の直後の要素が指定された述語と一致しません。

このストリームが順序付けされておらず、このストリームの一部の(すべてではない)要素が指定された述語と一致する場合、この操作の動作は非決定的であり、一致する要素のサブセット(空のセットを含む)を自由に取得できます。

このストリームのすべての要素が指定された述語と一致する場合、このストリームが順序付けされているか順序付けられていないかに関係なく、この操作はすべての要素を取ります(結果は入力と同じです)。または、ストリームの要素が指定の述語と一致しない場合、要素は取られません(結果は空のストリームになります)。

これは、ステートフルな短絡中間操作です。

APIのノート:

takeWhile()は通常、順次ストリーム・パイプラインに対する安価な操作ですが、順序付けられたパラレル・パイプラインでは、有効な接頭辞のみでなく、検出順序で要素の最も長い接頭辞を返すように操作が制約されるため、非常にコストがかかります。 順序付けされていないストリーム・ソース(generate(DoubleSupplier)など)を使用するか、BaseStream.unordered()で順序付け制約を削除すると、状況のセマンティクスが許可されている場合、パラレル・パイプラインでtakeWhile()が大幅に高速化される可能性があります。 検出順序との整合性が必要で、パラレル・パイプラインのtakeWhile()でパフォーマンスまたはメモリー使用率が低下している場合、BaseStream.sequential()を使用して順次実行に切り替えると、パフォーマンスが向上する可能性があります。

実装要件:

デフォルトの実装では、このストリームのspliteratorが取得され、トラバーサルでのこの操作のセマンティクスをサポートするためにそのスプリッテレータがラップされ、ラップされたスプリッテレータに関連付けられた新しいストリームが返されます。 返されるストリームは、このストリームの実行特性(BaseStream.isParallel()によるパラレル実行または順次実行)を保持しますが、ラップされたスプリッテレータは分割をサポートしないことを選択できます。 返されたストリームが閉じられると、返されたストリームとこのストリームの両方のクローズ・ハンドラが呼び出されます。

パラメータ:

predicate - 要素の最長接頭辞を決定するために要素に適用する非干渉でステートレスな述語。

戻り値:

新しいストリーム

導入されたバージョン:

9

dropWhile

default DoubleStream dropWhile(DoublePredicate predicate)

このストリームが順序付けされている場合、指定された述語と一致する要素の最長接頭辞を削除した後に、このストリームの残りの要素で構成されるストリームを返します。 それ以外の場合は、このストリームが順序付けされていない場合、指定された述語と一致する要素のサブセットを削除した後に、このストリームの残りの要素で構成されるストリームが返されます。

このストリームが順序付けされている場合、最も長い接頭辞は、指定された述語と一致するこのストリームの要素の連続したシーケンスです。 シーケンスの最初の要素がこのストリームの最初の要素であり、シーケンスの最後の要素の直後の要素が指定された述語と一致しません。

このストリームが順序付けされておらず、このストリームの一部の(すべてではない)要素が指定された述語と一致する場合、この操作の動作は非決定的であり、一致する要素のサブセット(空のセットを含む)を自由に削除できます。

このストリームのすべての要素が指定された述語と一致する場合、このストリームが順序付けされているか順序付けられていないかに関係なく、この操作によってすべての要素が削除されます(結果は空のストリームです)。または、指定された述語に一致するストリームの要素がない場合、要素は削除されません(結果は入力と同じです)。

これはステートフルな中間操作です。

APIのノート:

dropWhile()は通常、順次ストリーム・パイプラインに対する安価な操作ですが、順序付けられたパラレル・パイプラインでは、有効な接頭辞のみでなく、検出順序で要素の最も長い接頭辞を返すように操作が制約されるため、非常にコストがかかります。 順序付けされていないストリーム・ソース(generate(DoubleSupplier)など)を使用するか、BaseStream.unordered()で順序付け制約を削除すると、状況のセマンティクスが許可されている場合、パラレル・パイプラインでdropWhile()が大幅に高速化される可能性があります。 検出順序との整合性が必要で、パラレル・パイプラインのdropWhile()でパフォーマンスまたはメモリー使用率が低下している場合、BaseStream.sequential()を使用して順次実行に切り替えると、パフォーマンスが向上する可能性があります。

実装要件:

デフォルトの実装では、このストリームのspliteratorが取得され、トラバーサルでのこの操作のセマンティクスをサポートするためにそのスプリッテレータがラップされ、ラップされたスプリッテレータに関連付けられた新しいストリームが返されます。 返されるストリームは、このストリームの実行特性(BaseStream.isParallel()によるパラレル実行または順次実行)を保持しますが、ラップされたスプリッテレータは分割をサポートしないことを選択できます。 返されたストリームが閉じられると、返されたストリームとこのストリームの両方のクローズ・ハンドラが呼び出されます。

パラメータ:

predicate - 要素の最長接頭辞を決定するために要素に適用する非干渉でステートレスな述語。

戻り値:

新しいストリーム

導入されたバージョン:

9

forEach

void forEach(DoubleConsumer action)

このストリームの各要素に対してアクションを実行します。

これは終端操作です。

並列ストリーム・パイプラインの場合、この操作は、ストリームの検出順序を考慮することを保証しません。保証すると並列性のメリットが犠牲になるからです。 与えられた任意の要素に対し、ライブラリが選択した任意のタイミングで任意のスレッド内でアクションが実行される可能性があります。 アクションが共有状態にアクセスする場合、必要な同期を提供する責任はアクションにあります。

パラメータ:

action - 要素に対して実行する非干渉アクション

forEachOrdered

void forEachOrdered(DoubleConsumer action)

このストリームの各要素に対してアクションを実行します。検出順が定義されたストリームでは、各要素が検出順に処理されることが保証されます。

これは終端操作です。

パラメータ:

action - 要素に対して実行する非干渉アクション

関連項目:

forEach(DoubleConsumer)

toArray

double[] toArray()

このストリームの要素を含む配列を返します。

これは終端操作です。

戻り値:

このストリームの要素を含む配列

reduce

double reduce(double identity,
              DoubleBinaryOperator op)

指定された単位元の値と結合的な累積関数を使ってこのストリームの要素に対してリダクションを実行し、リデュースされた値を返します。 これは、次の操作に相当します。

     double result = identity;
     for (double element : this stream)
         result = accumulator.applyAsDouble(result, element)
     return result;
 

ただし、順次実行の制約が課されるわけではありません。

identity値はアキュムレータ関数の単位元でなければいけません。 つまり、すべてのxについて、accumulator.apply(identity, x)がxに等しくなります。 アキュムレータ関数は結合的な関数でなければいけません。

これは終端操作です。

APIのノート:

合計、最小、最大、平均はすべて、リダクションの特殊な場合です。 数値ストリームの合計は次のように表現できます。

     double sum = numbers.reduce(0, (a, b) -> a+b);
 

あるいは、次のようによりコンパクトにします。

     double sum = numbers.reduce(0, Double::sum);
 

これは、単純にループで中間合計を更新していく方法に比べて遠回りな集計方法に見えるかもしれませんが、リダクション操作の並列化が容易に行え、並列化の際に同期を追加する必要がなく、データ競合のリスクも大幅に減少します。

パラメータ:

identity - 蓄積関数に対する単位元の値

op - 2つの値を結合するための結合的、非干渉およびステートレスな関数

戻り値:

リダクションの結果

関連項目:

sum(), min(), max(), average()

reduce

OptionalDouble reduce(DoubleBinaryOperator op)

結合的累積関数を使用して、このストリームの要素に対してリダクションを実行し、リダクションされた値を記述するOptionalDoubleを返します(ある場合)。 これは、次の操作に相当します。

     boolean foundAny = false;
     double result = null;
     for (double element : this stream) {
         if (!foundAny) {
             foundAny = true;
             result = element;
         }
         else
             result = accumulator.applyAsDouble(result, element);
     }
     return foundAny ? OptionalDouble.of(result) : OptionalDouble.empty();
 

ただし、順次実行の制約が課されるわけではありません。

アキュムレータ関数は結合的な関数でなければいけません。

これは終端操作です。

パラメータ:

op - 2つの値を結合するための結合的、非干渉およびステートレスな関数

戻り値:

リダクションの結果

関連項目:

reduce(double, DoubleBinaryOperator)

collect

<R> R collect(Supplier<R> supplier,
              ObjDoubleConsumer<R> accumulator,
              BiConsumer<R,R> combiner)

このストリームの要素に対して可変リダクション操作を実行します。 可変リダクションとは、リデュース対象の値がArrayListのような可変の結果コンテナであり、結果を置き換えるかわりに結果の状態を更新することによって要素が組み込まれるようなリダクションのことです。 これは次と同等の結果を生成します。

     R result = supplier.get();
     for (double element : this stream)
         accumulator.accept(result, element);
     return result;
 

collect操作はreduce(double, DoubleBinaryOperator)と同様、同期を追加しなくても並列化できます。

これは終端操作です。

型パラメータ:

R - 可変結果コンテナのタイプ

パラメータ:

supplier - 新しい可変結果コンテナを作成する関数。 並列実行の場合、この関数は複数回呼び出される可能性がありますが、そのたびに新しい値を返す必要があります。

accumulator - 要素を結果コンテナに折りたたむ必要がある相関、非干渉、ステートレス関数。

combiner - 2つの部分的な結果コンテナを受け入れてマージする相関関数、非干渉関数、ステートレス関数で、累計関数と互換性がある必要があります。 コンバイナ関数は、2番目の結果コンテナの要素を最初の結果コンテナに折りたたむ必要があります。

戻り値:

リダクションの結果

関連項目:

Stream.collect(Supplier, BiConsumer, BiConsumer)

sum

double sum()

このストリーム内の要素の合計を返します。 合計は、リダクションの特殊な場合です。 浮動小数点合計が正確であれば、このメソッドは次と同等になります。

     return reduce(0, Double::sum);
 

しかし、浮動小数点合計は正確ではないため、上記コードは、このメソッドが行う合計計算と必ずしも同等になりません。

浮動小数点合計の値は、入力値と加算操作順序の両方の関数になります。 このメソッドの加算操作の順序は意図的に未定義になっていますが、それは、実装が計算結果の速度や精度を柔軟に改善できるようにするためです。 特に、このメソッドを補正加算などのテクニックを使って実装すれば、double値の単純な合計に比べ、数値合計の誤り限界を減らせます。 操作の順序が未指定で、異なる合計スキームを使用する可能性があるため、このメソッドの出力は同じ入力要素で異なる場合があります。

様々な条件によって、無限合計が計算される場合があります。 これは、合計されるすべての要素が有限であっても発生する可能性があります。 いずれかの要素が無限である場合、合計は無限になります。

• いずれかの要素がNaNの場合、最終合計はNaNになります。
• 要素に1つ以上の無限大が含まれている場合、合計は無限またはNaNになります。
  • 要素に逆符号の無限性が含まれている場合、合計はNaNになります。
  • 要素に1つの符号の無限が含まれ、中間合計が反対符号の無限大にオーバーフローした場合、合計はNaNになります。

有限値の中間合計は、反対符号付き無限要素にオーバーフローする可能性があります。その場合、要素がすべて有限であっても、最終合計はNaNになります。 すべての要素がゼロの場合、ゼロの符号は最終合計で保持されることは保証されません。

これは終端操作です。

APIのノート:

要素が絶対値の昇順にソートされていると、生成される結果の精度が高まる傾向があります。

戻り値:

このストリームの要素の合計

min

OptionalDouble min()

このストリームの最小要素を記述するOptionalDoubleまたは空のOptionalDouble(このストリームが空の場合)を返します。 いずれかのストリーム要素がNaNの場合、最小要素はDouble.NaNになります。 数値比較演算子とは異なり、このメソッドは負のゼロが厳密には正のゼロよりも小さいと見なします。 これはリダクションの特殊な場合であり、次と同等になります。

     return reduce(Double::min);
 

これは終端操作です。

戻り値:

このストリームの最小要素を含むOptionalDoubleまたは空のOptional (ストリームが空の場合)

max

OptionalDouble max()

このストリームの最大要素を記述するOptionalDoubleまたは空のOptionalDouble(このストリームが空の場合)を返します。 いずれかのストリーム要素がNaNの場合、最大要素はDouble.NaNになります。 数値比較演算子とは異なり、このメソッドは負のゼロが厳密には正のゼロよりも小さいと見なします。 これはリダクションの特殊な場合であり、次と同等になります。

     return reduce(Double::max);
 

これは終端操作です。

戻り値:

このストリームの最大要素を含むOptionalDoubleまたは空のOptional (ストリームが空の場合)

count

long count()

このストリームの要素の個数を返します。 これはリダクションの特殊な場合であり、次と同等になります。

     return mapToLong(e -> 1L).sum();
 

これは終端操作です。

APIのノート:

ストリーム・ソースからカウントを直接計算できる場合、実装は、ストリーム・パイプラインを(順次またはパラレルで)実行しないことを選択できます。 このような場合、ソース要素はトラバースされず、中間操作は評価されません。 デバッグなどの無害なケースを除き、副作用を伴う行動パラメータには強く推奨されません。 たとえば、次のストリームについて考えてみます。

     DoubleStream s = DoubleStream.of(1, 2, 3, 4);
     long count = s.peek(System.out::println).count();
 

ストリーム・ソースでカバーされる要素の数がわかっており、中間操作peekは、ストリームに要素を注入または削除しません(flatMapまたはfilter操作の場合も同様)。 したがって、カウントは4で、パイプラインを実行する必要はなく、副作用として要素を出力します。

戻り値:

このストリームの要素の個数

average

OptionalDouble average()

このストリームの要素の算術平均を記述するOptionalDoubleを返します。このストリームが空の場合は空のOptionalを返します。

計算された平均は数値的に変化し、合計を計算する際の特殊なケース動作になります。詳細は、sum()を参照してください。

平均は、リダクションの特殊な場合です。

これは終端操作です。

APIのノート:

要素が絶対値の昇順にソートされていると、生成される結果の精度が高まる傾向があります。

戻り値:

このストリームの平均要素を含むOptionalDoubleまたは空のオプション(ストリームが空の場合)

summaryStatistics

DoubleSummaryStatistics summaryStatistics()

このストリームの要素に関する各種のサマリー・データを記述するDoubleSummaryStatisticsを返します。 これはリダクションの特殊な場合です。

これは終端操作です。

戻り値:

このストリームの要素に関する各種のサマリー・データを記述するDoubleSummaryStatistics

anyMatch

boolean anyMatch(DoublePredicate predicate)

このストリームのいずれかの要素が指定された述語に一致するかどうかを返します。 すべての要素で述語を評価するとは限りません(結果を決定するのに必要でない場合)。 ストリームが空の場合、falseが返され、述語は評価されません。

これは短絡終端操作です。

APIのノート:

このメソッドは、ストリームの要素に対する述語の存在量化(あるxについてP(x))を評価します。

パラメータ:

predicate - ストリームの要素に適用する非干渉でステートレスな述語

戻り値:

指定された述語に一致する要素がストリーム内に存在する場合はtrue、そうでない場合はfalse

allMatch

boolean allMatch(DoublePredicate predicate)

このストリームのすべての要素が指定された述語に一致するかどうかを返します。 すべての要素で述語を評価するとは限りません(結果を決定するのに必要でない場合)。 ストリームが空の場合、trueが返され、述語は評価されません。

これは短絡終端操作です。

APIのノート:

このメソッドは、ストリームの要素に対する述語の全称量化(すべてのxについてP(x))を評価します。 ストリームが空の場合、量化は無意味に満たされると言い、(P(x)とは無関係に)常にtrueになります。

パラメータ:

predicate - ストリームの要素に適用する非干渉でステートレスな述語

戻り値:

ストリームのすべての要素が指定された述語に一致するかストリームが空の場合はtrue、それ以外の場合はfalse

noneMatch

boolean noneMatch(DoublePredicate predicate)

指定された述語に一致する要素がこのストリーム内に存在しないかどうかを返します。 すべての要素で述語を評価するとは限りません(結果を決定するのに必要でない場合)。 ストリームが空の場合、trueが返され、述語は評価されません。

これは短絡終端操作です。

APIのノート:

このメソッドは、ストリームの要素に対する述語の否定の全称量化(すべてのxについて~P(x))を評価します。 ストリームが空の場合、量化は無意味に満たされると言い、P(x)とは無関係に常にtrueになります。

パラメータ:

predicate - ストリームの要素に適用する非干渉でステートレスな述語

戻り値:

ストリームのどの要素も指定された述語に一致しないかストリームが空の場合はtrue、それ以外の場合はfalse

findFirst

OptionalDouble findFirst()

このストリームの最初の要素を記述するOptionalDoubleを返します。ストリームが空の場合は空のOptionalDoubleを返します。 ストリームが検出順序を持たない場合は、任意の要素が返されます。

これは短絡終端操作です。

戻り値:

このストリームの最初の要素を記述するOptionalDoubleまたは空のOptionalDouble (ストリームが空の場合)

findAny

OptionalDouble findAny()

ストリームの一部の要素を記述するOptionalDoubleを返します。ストリームが空の場合は空のOptionalDoubleを返します。

これは短絡終端操作です。

この操作の動作は明らかに非決定論的です。ストリームの任意の要素を自由に選択できます。 これは、並列処理でのパフォーマンスを最大化できるようにするためです。デメリットは、同じソースに対して呼び出すたびに、違う結果が返される可能性がある点です。 (安定した結果が必要な場合は、かわりにfindFirst()を使用してください。)

戻り値:

このストリームのある要素を記述するOptionalDoubleまたは空のOptionalDouble (ストリームが空の場合)

関連項目:

findFirst()

boxed

Stream<Double> boxed()

このストリームの各要素をDoubleにボクシングした結果から構成されるStreamを返します。

これは中間操作です。

戻り値:

ストリームの各要素をDoubleにボクシングした結果から構成されるStream

builder

static DoubleStream.Builder builder()

DoubleStreamのビルダーを返します。

戻り値:

ストリーム・ビルダー

empty

static DoubleStream empty()

空の順次DoubleStreamを返します。

戻り値:

空の順次ストリーム

of

static DoubleStream of(double t)

単一要素を含む順次DoubleStreamを返します。

パラメータ:

t - 単一要素

戻り値:

単一要素の順次ストリーム

of

static DoubleStream of(double... values)

指定された値を要素に持つ、順序付けされた順次ストリームを返します。

パラメータ:

values - 新しいストリームの要素

戻り値:

新しいストリーム

iterate

static DoubleStream iterate(double seed,
                            DoubleUnaryOperator f)

初期要素seedに関数fを繰り返し適用することで生成される、順序付けされた無限順次DoubleStreamを返します(seed、f(seed)、f(f(seed))、といった要素から成るStreamが生成される)。

DoubleStreamの最初の要素(位置0)は、指定されたseedになります。 n > 0の場合、位置nの要素は、位置n - 1の要素に関数fを適用した結果になります。

後続の要素にfを適用するアクションの前に、1つの要素にfを適用するアクション。 任意の要素に対して、ライブラリが選択する任意のスレッドでアクションを実行できます。

パラメータ:

seed - 初期要素

f - 新しい要素を生成するために1つ前の要素に適用される関数

戻り値:

新しい順次DoubleStream

iterate

static DoubleStream iterate(double seed,
                            DoublePredicate hasNext,
                            DoubleUnaryOperator next)

指定されたnext関数の初期要素への反復適用によって生成される、順序付けられたDoubleStreamを、指定されたhasNext述語を満たすことを条件として戻します。 ストリームは、hasNext述語がfalseを返すとすぐに終了します。

DoubleStream.iterateは、対応するfor-loopで生成される要素と同じ順序を生成する必要があります。

     for (double index=seed; hasNext.test(index); index = next.applyAsDouble(index)) {
         ...
     }
 

hasNext述語がシード値を保持しない場合、結果の順序は空になることがあります。 それ以外の場合、最初の要素は指定されたseed値になり、次の要素(存在する場合)はnext関数をseed値に適用した結果になり、hasNext述語がストリームの終了を示すまで繰り返されます。

hasNext述語をhappens-before要素に適用するアクションは、その要素にnext関数を適用します。 hasNext述語を後続の要素に適用するアクションの前に、1つの要素にnext関数を適用するアクション。 任意の要素に対して、ライブラリが選択する任意のスレッドでアクションを実行できます。

パラメータ:

seed - 初期要素

hasNext - ストリームを終了する必要があるタイミングを決定するために要素に適用する述語。

next - 新しい要素を生成するために前の要素に適用される関数

戻り値:

新しい順次DoubleStream

導入されたバージョン:

9

generate

static DoubleStream generate(DoubleSupplier s)

指定されたDoubleSupplierによって生成される要素を含む、順序付けされていない無限順次ストリームを返します。 これは、定数ストリームやランダムな要素から成るストリームなどを生成するのに適しています。

パラメータ:

s - 要素を生成するためのDoubleSupplier

戻り値:

順序付けされていない新しい無限順次DoubleStream

concat

static DoubleStream concat(DoubleStream a,
                           DoubleStream b)

最初のストリームの全要素と2番目のストリームの全要素を連結したものを要素に持つ、遅延連結ストリームを作成します。 結果のストリームが順序付けされるのは、入力ストリームがどちらも順序付けされている場合であり、並列的になるのは、入力ストリームのどちらかが並列的な場合です。 結果のストリームのクローズ時には、両方の入力ストリームのクローズ・ハンドラが呼び出されます。

このメソッドは、2つの入力ストリームを操作し、各ストリームをそのソースにバインドします。 その結果、入力ストリーム・ソースに対する後続の変更は、連結ストリーム結果に反映されない可能性があります。

APIのノート:

最適化の機会を保持するために、このメソッドは各ストリームをソースにバインドし、パラメータとして2つのストリームのみを受け入れます。 たとえば、各入力ストリーム・ソースの正確なサイズがわかっている場合は、連結ストリーム・ソースの正確なサイズを計算できます。 バインディングなしで、またはこのメソッドへのネストされたコールなしで、より多くのストリームを連結するには、次のように、ストリームのストリームとアイデンティティ関数によるフラット・マッピングの作成を試みます。

     DoubleStream concat = Stream.of(s1, s2, s3, s4).flatMapToDouble(s -> s);
 

実装上のノート:

連結を繰り返すことでストリームを構築する際には注意が必要です。 深く連結されたストリームの要素にアクセスすると、ディープ・コール・チェーンまたはStackOverflowErrorが発生する可能性があります。

パラメータ:

a - 最初のストリーム

b - 2番目のストリーム

戻り値:

2つの入力ストリームを連結したもの