Uses of Interface
com.gengoai.stream.MDoubleStream

Packages that use MDoubleStream

Package	Description
com.gengoai.stream	A unified stream interface that can work across Java and Spark streams.
com.gengoai.stream.local
com.gengoai.stream.spark

Uses of MDoubleStream in com.gengoai.stream

Methods in com.gengoai.stream that return MDoubleStream

Modifier and Type	Method	Description
MDoubleStream	MDoubleStream.cache()	Caches the stream.
MDoubleStream	MDoubleStream.distinct()	Removes duplicates from the stream
MDoubleStream	StreamingContext.doubleStream(double... values)	Creates a MDoubleStream from a variable list of doubles
abstract MDoubleStream	StreamingContext.doubleStream(DoubleStream doubleStream)	Creates a MDoubleStream from a Java DoubleStream
MDoubleStream	StreamingContext.emptyDouble()	Creates an empty MDoubleStream
MDoubleStream	MDoubleStream.filter(SerializableDoublePredicate predicate)	Filters the stream.
MDoubleStream	MDoubleStream.flatMap(SerializableDoubleFunction<double[]> mapper)	Maps the doubles in this stream to one or more new doubles using the given function.
MDoubleStream	MDoubleStream.limit(int n)	Limits the stream to the first number items.
MDoubleStream	MDoubleStream.map(SerializableDoubleUnaryOperator mapper)	Maps the doubles in the stream using the given function
MDoubleStream	MPairStream.mapToDouble(SerializableToDoubleBiFunction<? super T,? super U> function)	Maps the key-value pairs to doubles
MDoubleStream	MStream.mapToDouble(SerializableToDoubleFunction<? super T> function)	Maps objects in this stream to double values
MDoubleStream	MDoubleStream.onClose(SerializableRunnable onCloseHandler)	Sets the handler to call when the stream is closed.
MDoubleStream	MDoubleStream.parallel()	Ensures that the stream is parallel or distributed.
MDoubleStream	MDoubleStream.repartition(int numberOfPartition)	Repartitions the stream to the given number of partitions.
MDoubleStream	MDoubleStream.skip(int n)	Skips the first n items in the stream
MDoubleStream	MDoubleStream.sorted(boolean ascending)	Sorts the double stream in ascending order.
MDoubleStream	MDoubleStream.union(MDoubleStream other)	Unions this stream with another

Methods in com.gengoai.stream with parameters of type MDoubleStream

Modifier and Type	Method	Description
MDoubleStream	MDoubleStream.union(MDoubleStream other)	Unions this stream with another

Uses of MDoubleStream in com.gengoai.stream.local

Classes in com.gengoai.stream.local that implement MDoubleStream

Modifier and Type	Class	Description
class	LocalMDoubleStream

Methods in com.gengoai.stream.local that return MDoubleStream

Modifier and Type	Method	Description
MDoubleStream	LocalMDoubleStream.cache()
MDoubleStream	LocalMDoubleStream.distinct()
MDoubleStream	LocalStreamingContext.doubleStream(double... values)
MDoubleStream	LocalStreamingContext.doubleStream(DoubleStream doubleStream)
MDoubleStream	LocalMDoubleStream.filter(@NonNull SerializableDoublePredicate predicate)
MDoubleStream	LocalMDoubleStream.flatMap(@NonNull SerializableDoubleFunction<double[]> mapper)
MDoubleStream	LocalMDoubleStream.limit(int n)
MDoubleStream	LocalMDoubleStream.map(@NonNull SerializableDoubleUnaryOperator mapper)
MDoubleStream	AbstractLocalMPairStream.mapToDouble(@NonNull SerializableToDoubleBiFunction<? super K,? super V> function)
MDoubleStream	LocalMDoubleStream.onClose(@NonNull SerializableRunnable onCloseHandler)
MDoubleStream	LocalMDoubleStream.parallel()
MDoubleStream	LocalMDoubleStream.repartition(int numberOfPartition)
MDoubleStream	LocalMDoubleStream.skip(int n)
MDoubleStream	LocalMDoubleStream.sorted(boolean ascending)
MDoubleStream	LocalMDoubleStream.union(@NonNull MDoubleStream other)

Methods in com.gengoai.stream.local with parameters of type MDoubleStream

Modifier and Type	Method	Description
MDoubleStream	LocalMDoubleStream.union(@NonNull MDoubleStream other)

Uses of MDoubleStream in com.gengoai.stream.spark

Methods in com.gengoai.stream.spark that return MDoubleStream

Modifier and Type	Method	Description
MDoubleStream	SparkPairStream.mapToDouble(SerializableToDoubleBiFunction<? super T,? super U> function)