Uses of Interface
com.gengoai.function.SerializableBinaryOperator

Packages that use SerializableBinaryOperator

Package	Description
com.gengoai.function	Checked and Serializable versions of Java 8's functional elements.
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 SerializableBinaryOperator in com.gengoai.function

Methods in com.gengoai.function that return SerializableBinaryOperator

Modifier and Type	Method	Description
static <T> SerializableBinaryOperator<T>	Unchecked.binaryOperator(CheckedBinaryOperator<T> checked)	Generates a version of BinaryOperator that will capture exceptions and rethrow them as runtime exceptions

Methods in com.gengoai.function with parameters of type SerializableBinaryOperator

Modifier and Type	Method	Description
static <T> BinaryOperator<T>	Serialized.binaryOperator(SerializableBinaryOperator<T> serialized)	Generates a serialized version of BinaryOperator

Uses of SerializableBinaryOperator in com.gengoai.stream

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

Modifier and Type	Method	Description
T	MStream.fold(T zeroValue, SerializableBinaryOperator<T> operator)	Performs a reduction on the elements of this stream using the given binary operator.
Optional<T>	MStream.reduce(SerializableBinaryOperator<T> reducer)	Performs a reduction on the elements of this stream using the given binary operator.
MPairStream<T,U>	MPairStream.reduceByKey(SerializableBinaryOperator<U> operator)	Performs a reduction by key on the elements of this stream using the given binary operator.

Uses of SerializableBinaryOperator in com.gengoai.stream.local

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

Modifier and Type	Method	Description
MPairStream<K,V>	AbstractLocalMPairStream.reduceByKey(@NonNull SerializableBinaryOperator<V> operator)

Uses of SerializableBinaryOperator in com.gengoai.stream.spark

Methods in com.gengoai.stream.spark with parameters of type SerializableBinaryOperator

Modifier and Type	Method	Description
T	SparkStream.fold(T zeroValue, SerializableBinaryOperator<T> operator)
Optional<T>	SparkStream.reduce(SerializableBinaryOperator<T> reducer)
MPairStream<T,U>	SparkPairStream.reduceByKey(SerializableBinaryOperator<U> operator)