Module org.jooq.jool

Package org.jooq.lambda

Class Agg

java.lang.Object

org.jooq.lambda.Agg

public class Agg
extends java.lang.Object

A set of additional Collector implementations.

The class name isn't set in stone and will change.

Constructor Summary

Constructors

Constructor	Description
Agg()

Method Summary

Modifier and Type	Method	Description
static java.util.stream.Collector<java.lang.Boolean,?,java.lang.Boolean>	allMatch()	Get a Collector that calculates the ALL() function.
static <T> java.util.stream.Collector<T,?,java.lang.Boolean>	allMatch(java.util.function.Predicate<? super T> predicate)	Get a Collector that calculates the ALL() function.
static java.util.stream.Collector<java.lang.Boolean,?,java.lang.Boolean>	anyMatch()	Get a Collector that calculates the ANY() function.
static <T> java.util.stream.Collector<T,?,java.lang.Boolean>	anyMatch(java.util.function.Predicate<? super T> predicate)	Get a Collector that calculates the ANY() function.
static <T> java.util.stream.Collector<T,?,java.util.Optional<T>>	avg()	Get a Collector that calculates the AVG() for any type of Number.
static <T,U> java.util.stream.Collector<T,?,java.util.Optional<U>>	avg(java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the AVG() for any type of Number.
private static <T> double	avg0(java.util.List<T> list, java.util.function.ToDoubleFunction<? super T> function)
static <T> java.util.stream.Collector<T,?,java.util.Optional<T>>	bitAnd()	Get a Collector that calculates BIT_AND() for any type of Number.
static <T,U> java.util.stream.Collector<T,?,java.util.Optional<U>>	bitAnd(java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the BIT_AND() for any type of Number.
static <T> java.util.stream.Collector<T,?,java.lang.Integer>	bitAndInt(java.util.function.ToIntFunction<? super T> function)	Get a Collector that calculates the BIT_AND() for any type of Number.
static <T> java.util.stream.Collector<T,?,java.lang.Long>	bitAndLong(java.util.function.ToLongFunction<? super T> function)	Get a Collector that calculates the BIT_AND() for any type of Number.
static <T> java.util.stream.Collector<T,?,java.util.Optional<T>>	bitOr()	Get a Collector that calculates BIT_OR() for any type of Number.
static <T,U> java.util.stream.Collector<T,?,java.util.Optional<U>>	bitOr(java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the BIT_OR() for any type of Number.
static <T> java.util.stream.Collector<T,?,java.lang.Integer>	bitOrInt(java.util.function.ToIntFunction<? super T> function)	Get a Collector that calculates the BIT_OR() for any type of Number.
static <T> java.util.stream.Collector<T,?,java.lang.Long>	bitOrLong(java.util.function.ToLongFunction<? super T> function)	Get a Collector that calculates the BIT_OR() for any type of Number.
static java.util.stream.Collector<java.lang.CharSequence,?,java.lang.String>	commonPrefix()	Get a Collector that calculates the common prefix of a set of strings.
static java.util.stream.Collector<java.lang.CharSequence,?,java.lang.String>	commonSuffix()	Get a Collector that calculates the common suffix of a set of strings.
static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>>	correlationDouble()	Get a Collector that calculates the CORR() function.
static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>>	correlationDouble(java.util.function.ToDoubleFunction<? super T> functionX, java.util.function.ToDoubleFunction<? super T> functionY)	Get a Collector that calculates the CORR() function.
static <T> java.util.stream.Collector<T,?,java.lang.Long>	count()	Get a Collector that calculates the COUNT(*) function.
static <T> java.util.stream.Collector<T,?,java.lang.Long>	countDistinct()	Get a Collector that calculates the COUNT (DISTINCT *) function.
static <T,U> java.util.stream.Collector<T,?,java.lang.Long>	countDistinctBy(java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the COUNT (DISTINCT expr) function.
static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>>	covarianceDouble()	Get a Collector that calculates the COVAR_POP() function.
static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>>	covarianceDouble(java.util.function.ToDoubleFunction<? super T> functionX, java.util.function.ToDoubleFunction<? super T> functionY)	Get a Collector that calculates the COVAR_POP() function.
private static <T> java.util.function.Function<java.util.List<T>,java.util.Optional<java.lang.Double>>	covarianceFinisher(java.util.function.ToDoubleFunction<? super T> functionX, java.util.function.ToDoubleFunction<? super T> functionY, java.util.function.BiFunction<java.util.List<T>,java.util.function.ToDoubleFunction<? super T>,java.lang.Double> sumOrAvg)
static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Long>>	denseRank(T value)	Get a Collector that calculates the DENSE_RANK() function given natural ordering.
static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Long>>	denseRank(T value, java.util.Comparator<? super T> comparator)	Get a Collector that calculates the DENSE_RANK() function given a specific ordering.
static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Long>>	denseRankBy(U value, java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the derived DENSE_RANK() function given natural ordering.
static <T,U> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Long>>	denseRankBy(U value, java.util.function.Function<? super T,? extends U> function, java.util.Comparator<? super U> comparator)	Get a Collector that calculates the derived DENSE_RANK() function given a specific ordering.
static <T> java.util.stream.Collector<T,?,Seq<T>>	dropping(long n)	Get a Collector that skip the first n elements of a collection.
static <T,A,R> java.util.stream.Collector<T,?,R>	filter(java.util.function.Predicate<? super T> predicate, java.util.stream.Collector<T,A,R> downstream)	Get a Collector that filters data passed to downstream collector.
static <T> java.util.stream.Collector<T,?,java.util.Optional<T>>	first()	Get a Collector that calculates the FIRST function.
static <T> java.util.stream.Collector<T,?,java.util.Optional<T>>	last()	Get a Collector that calculates the LAST function.
private static <T1,T2,R> java.util.Optional<R>	mapAll(Tuple2<java.util.Optional<T1>,java.util.Optional<T2>> tuple, Function2<T1,T2,R> function)
private static <T1,T2,T3,R> java.util.Optional<R>	mapAll(Tuple3<java.util.Optional<T1>,java.util.Optional<T2>,java.util.Optional<T3>> tuple, Function3<T1,T2,T3,R> function)
static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,java.util.Optional<T>>	max()	Get a Collector that calculates the MAX() function.
static <T> java.util.stream.Collector<T,?,java.util.Optional<T>>	max(java.util.Comparator<? super T> comparator)	Get a Collector that calculates the MAX() function.
static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<U>>	max(java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the MAX() function.
static <T,U> java.util.stream.Collector<T,?,java.util.Optional<U>>	max(java.util.function.Function<? super T,? extends U> function, java.util.Comparator<? super U> comparator)	Get a Collector that calculates the MAX() function.
static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,Seq<T>>	maxAll()	Get a Collector that calculates the MAX() function, producing multiple results.
static <T> java.util.stream.Collector<T,?,Seq<T>>	maxAll(java.util.Comparator<? super T> comparator)	Get a Collector that calculates the MAX() function, producing multiple results.
static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,Seq<U>>	maxAll(java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the MAX() function, producing multiple results.
static <T,U> java.util.stream.Collector<T,?,Seq<U>>	maxAll(java.util.function.Function<? super T,? extends U> function, java.util.Comparator<? super U> comparator)	Get a Collector that calculates the MAX() function, producing multiple results.
static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,Seq<T>>	maxAllBy(java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the MAX() function, producing multiple results.
static <T,U> java.util.stream.Collector<T,?,Seq<T>>	maxAllBy(java.util.function.Function<? super T,? extends U> function, java.util.Comparator<? super U> comparator)	Get a Collector that calculates the MAX() function, producing multiple results.
static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<T>>	maxBy(java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the MAX() function.
static <T,U> java.util.stream.Collector<T,?,java.util.Optional<T>>	maxBy(java.util.function.Function<? super T,? extends U> function, java.util.Comparator<? super U> comparator)	Get a Collector that calculates the MAX() function.
static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,java.util.Optional<T>>	median()	Get a Collector that calculates the MEDIAN() function given natural ordering.
static <T> java.util.stream.Collector<T,?,java.util.Optional<T>>	median(java.util.Comparator<? super T> comparator)	Get a Collector that calculates the MEDIAN() function given a specific ordering.
static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<U>>	median(java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the MEDIAN() function given a specific ordering.
static <T,U> java.util.stream.Collector<T,?,java.util.Optional<U>>	median(java.util.function.Function<? super T,? extends U> function, java.util.Comparator<? super U> comparator)	Get a Collector that calculates the MEDIAN() function given a specific ordering.
static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,Seq<T>>	medianAll()	Get a Collector that calculates the PERCENTILE_DISC(percentile) function given a specific ordering, producing multiple results.
static <T> java.util.stream.Collector<T,?,Seq<T>>	medianAll(java.util.Comparator<? super T> comparator)	Get a Collector that calculates the PERCENTILE_DISC(percentile) function given a specific ordering, producing multiple results.
static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,Seq<T>>	medianAllBy(java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the derived PERCENTILE_DISC(percentile) function given a specific ordering, producing multiple results.
static <T,U> java.util.stream.Collector<T,?,Seq<T>>	medianAllBy(java.util.function.Function<? super T,? extends U> function, java.util.Comparator<? super U> comparator)	Get a Collector that calculates the derived MEDIAN() function given natural ordering, producing multiple results.
static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<T>>	medianBy(java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the derived MEDIAN() function given natural ordering.
static <T,U> java.util.stream.Collector<T,?,java.util.Optional<T>>	medianBy(java.util.function.Function<? super T,? extends U> function, java.util.Comparator<? super U> comparator)	Get a Collector that calculates the derived MEDIAN() function given a specific ordering.
static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,java.util.Optional<T>>	min()	Get a Collector that calculates the MIN() function.
static <T> java.util.stream.Collector<T,?,java.util.Optional<T>>	min(java.util.Comparator<? super T> comparator)	Get a Collector that calculates the MIN() function.
static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<U>>	min(java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the MIN() function.
static <T,U> java.util.stream.Collector<T,?,java.util.Optional<U>>	min(java.util.function.Function<? super T,? extends U> function, java.util.Comparator<? super U> comparator)	Get a Collector that calculates the MIN() function.
static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,Seq<T>>	minAll()	Get a Collector that calculates the MIN() function, producing multiple results.
static <T> java.util.stream.Collector<T,?,Seq<T>>	minAll(java.util.Comparator<? super T> comparator)	Get a Collector that calculates the MIN() function, producing multiple results.
static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,Seq<U>>	minAll(java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the MIN() function, producing multiple results.
static <T,U> java.util.stream.Collector<T,?,Seq<U>>	minAll(java.util.function.Function<? super T,? extends U> function, java.util.Comparator<? super U> comparator)	Get a Collector that calculates the MIN() function, producing multiple results.
static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,Seq<T>>	minAllBy(java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the MIN() function, producing multiple results.
static <T,U> java.util.stream.Collector<T,?,Seq<T>>	minAllBy(java.util.function.Function<? super T,? extends U> function, java.util.Comparator<? super U> comparator)	Get a Collector that calculates the MIN() function, producing multiple results.
static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<T>>	minBy(java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the MIN() function.
static <T,U> java.util.stream.Collector<T,?,java.util.Optional<T>>	minBy(java.util.function.Function<? super T,? extends U> function, java.util.Comparator<? super U> comparator)	Get a Collector that calculates the MIN() function.
static <T> java.util.stream.Collector<T,?,java.util.Optional<T>>	mode()	Get a Collector that calculates the MODE() function.
private static <T,X> java.util.stream.Collector<T,?,X>	mode0(java.util.function.Function<? super Seq<Tuple2<T,java.lang.Long>>,? extends X> transformer)
static <T> java.util.stream.Collector<T,?,Seq<T>>	modeAll()	Get a Collector that calculates the MODE() function.
static <T,U> java.util.stream.Collector<T,?,Seq<T>>	modeAllBy(java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the MODE() function.
static <T,U> java.util.stream.Collector<T,?,java.util.Optional<T>>	modeBy(java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the MODE() function.
static java.util.stream.Collector<java.lang.Boolean,?,java.lang.Boolean>	noneMatch()	Get a Collector that calculates the NONE() function.
static <T> java.util.stream.Collector<T,?,java.lang.Boolean>	noneMatch(java.util.function.Predicate<? super T> predicate)	Get a Collector that calculates the NONE() function.
static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,java.util.Optional<T>>	percentile(double percentile)	Get a Collector that calculates the PERCENTILE_DISC(percentile) function given natural ordering.
static <T> java.util.stream.Collector<T,?,java.util.Optional<T>>	percentile(double percentile, java.util.Comparator<? super T> comparator)	Get a Collector that calculates the PERCENTILE_DISC(percentile) function given a specific ordering.
static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<U>>	percentile(double percentile, java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the PERCENTILE_DISC(percentile) function given a specific ordering.
static <T,U> java.util.stream.Collector<T,?,java.util.Optional<U>>	percentile(double percentile, java.util.function.Function<? super T,? extends U> function, java.util.Comparator<? super U> comparator)	Get a Collector that calculates the PERCENTILE_DISC(percentile) function given a specific ordering.
static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,Seq<T>>	percentileAll(double percentile)	Get a Collector that calculates the PERCENTILE_DISC(percentile) function given a specific ordering, producing multiple results.
static <T> java.util.stream.Collector<T,?,Seq<T>>	percentileAll(double percentile, java.util.Comparator<? super T> comparator)	Get a Collector that calculates the PERCENTILE_DISC(percentile) function given a specific ordering, producing multiple results.
static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,Seq<T>>	percentileAllBy(double percentile, java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the derived PERCENTILE_DISC(percentile) function given a specific ordering, producing multiple results.
static <T,U> java.util.stream.Collector<T,?,Seq<T>>	percentileAllBy(double percentile, java.util.function.Function<? super T,? extends U> function, java.util.Comparator<? super U> comparator)	Get a Collector that calculates the derived PERCENTILE_DISC(percentile) function given a specific ordering, producing multiple results.
static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<T>>	percentileBy(double percentile, java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the derived PERCENTILE_DISC(percentile) function given natural ordering.
static <T,U> java.util.stream.Collector<T,?,java.util.Optional<T>>	percentileBy(double percentile, java.util.function.Function<? super T,? extends U> function, java.util.Comparator<? super U> comparator)	Get a Collector that calculates the derived PERCENTILE_DISC(percentile) function given a specific ordering.
private static <T,U,R> java.util.stream.Collector<T,java.util.List<Tuple2<T,U>>,R>	percentileCollector(java.util.function.Function<? super T,? extends U> function, java.util.Comparator<? super U> comparator, java.util.function.Supplier<R> onEmpty, java.util.function.Function<T,R> onSingle, java.util.function.Function<java.util.List<Tuple2<T,U>>,R> finisher)
private static int	percentileIndex(double percentile, int size)
static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>>	percentRank(T value)	Get a Collector that calculates the PERCENT_RANK() function given natural ordering.
static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>>	percentRank(T value, java.util.Comparator<? super T> comparator)	Get a Collector that calculates the PERCENT_RANK() function given a specific ordering.
static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>>	percentRankBy(U value, java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the derived PERCENT_RANK() function given natural ordering.
static <T,U> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>>	percentRankBy(U value, java.util.function.Function<? super T,? extends U> function, java.util.Comparator<? super U> comparator)	Get a Collector that calculates the derived PERCENT_RANK() function given a specific ordering.
static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Long>>	rank(T value)	Get a Collector that calculates the RANK() function given natural ordering.
static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Long>>	rank(T value, java.util.Comparator<? super T> comparator)	Get a Collector that calculates the RANK() function given a specific ordering.
static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Long>>	rankBy(U value, java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the derived RANK() function given natural ordering.
static <T,U> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Long>>	rankBy(U value, java.util.function.Function<? super T,? extends U> function, java.util.Comparator<? super U> comparator)	Get a Collector that calculates the derived RANK() function given a specific ordering.
static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>>	regrAvgXDouble()	Get a Collector that calculates the REGR_AVGX() function.
static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>>	regrAvgXDouble(java.util.function.ToDoubleFunction<? super T> functionX, java.util.function.ToDoubleFunction<? super T> functionY)	Get a Collector that calculates the REGR_AVGX() function.
static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>>	regrAvgYDouble()	Get a Collector that calculates the REGR_AVGY() function.
static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>>	regrAvgYDouble(java.util.function.ToDoubleFunction<? super T> functionX, java.util.function.ToDoubleFunction<? super T> functionY)	Get a Collector that calculates the REGR_AVGY() function.
static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.lang.Long>	regrCount()	Get a Collector that calculates the REGR_COUNT() function.
static <T> java.util.stream.Collector<T,?,java.lang.Long>	regrCount(java.util.function.ToDoubleFunction<? super T> functionX, java.util.function.ToDoubleFunction<? super T> functionY)	Get a Collector that calculates the REGR_COUNT() function.
static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>>	regrInterceptDouble()	Get a Collector that calculates the REGR_INTERCEPT() function.
static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>>	regrInterceptDouble(java.util.function.ToDoubleFunction<? super T> functionX, java.util.function.ToDoubleFunction<? super T> functionY)	Get a Collector that calculates the REGR_INTERCEPT() function.
static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>>	regrR2Double()	Get a Collector that calculates the regrR2Double() function.
static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>>	regrR2Double(java.util.function.ToDoubleFunction<? super T> functionX, java.util.function.ToDoubleFunction<? super T> functionY)	Get a Collector that calculates the regrR2Double() function.
static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>>	regrSlopeDouble()	Get a Collector that calculates the REGR_SLOPE() function.
static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>>	regrSlopeDouble(java.util.function.ToDoubleFunction<? super T> functionX, java.util.function.ToDoubleFunction<? super T> functionY)	Get a Collector that calculates the REGR_SLOPE() function.
static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>>	regrSxxDouble()	Get a Collector that calculates the REGR_SXX() function.
static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>>	regrSxxDouble(java.util.function.ToDoubleFunction<? super T> functionX, java.util.function.ToDoubleFunction<? super T> functionY)	Get a Collector that calculates the REGR_SXX() function.
static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>>	regrSxyDouble()	Get a Collector that calculates the REGR_SXY() function.
static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>>	regrSxyDouble(java.util.function.ToDoubleFunction<? super T> functionX, java.util.function.ToDoubleFunction<? super T> functionY)	Get a Collector that calculates the REGR_SXY() function.
static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>>	regrSyyDouble()	Get a Collector that calculates the REGR_SYY() function.
static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>>	regrSyyDouble(java.util.function.ToDoubleFunction<? super T> functionX, java.util.function.ToDoubleFunction<? super T> functionY)	Get a Collector that calculates the REGR_SYY() function.
static <T> java.util.stream.Collector<java.lang.Double,?,java.util.Optional<java.lang.Double>>	stddevDouble()	Get a Collector that calculates the STDDEV_POP() function.
static <T,U> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>>	stddevDouble(java.util.function.ToDoubleFunction<? super T> function)	Get a Collector that calculates the STDDEV_POP() function.
static <T> java.util.stream.Collector<T,?,java.util.Optional<T>>	sum()	Get a Collector that calculates the SUM() for any type of Number.
static <T,U> java.util.stream.Collector<T,?,java.util.Optional<U>>	sum(java.util.function.Function<? super T,? extends U> function)	Get a Collector that calculates the SUM() for any type of Number.
private static <T> double	sum0(java.util.List<T> list, java.util.function.ToDoubleFunction<? super T> function)
static <T> java.util.stream.Collector<T,?,Seq<T>>	taking(long n)	Get a Collector that takes the first n elements from a collection.
private static <T> double	variance0(java.util.List<T> l, java.util.function.ToDoubleFunction<? super T> function)
static java.util.stream.Collector<java.lang.Double,?,java.util.Optional<java.lang.Double>>	varianceDouble()	Get a Collector that calculates the VAR_POP() function.
static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>>	varianceDouble(java.util.function.ToDoubleFunction<? super T> function)	Get a Collector that calculates the VAR_POP() function.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Agg

public Agg()

Method Detail

filter

public static <T,A,R> java.util.stream.Collector<T,?,R> filter(java.util.function.Predicate<? super T> predicate,
                                                                                       java.util.stream.Collector<T,A,R> downstream)

Get a Collector that filters data passed to downstream collector.

first

public static <T> java.util.stream.Collector<T,?,java.util.Optional<T>> first()

Get a Collector that calculates the FIRST function.

Note that unlike in (Oracle) SQL, where the FIRST function is an ordered set aggregate function that produces a set of results, this collector just produces the first value in the order of stream traversal. For matching behaviour to Oracle's [ aggregate function ] KEEP (DENSE_RANK FIRST ORDER BY ... ), use maxAll(Comparator) instead.

last

public static <T> java.util.stream.Collector<T,?,java.util.Optional<T>> last()

Get a Collector that calculates the LAST function.

Note that unlike in (Oracle) SQL, where the FIRST function is an ordered set aggregate function that produces a set of results, this collector just produces the first value in the order of stream traversal. For matching behaviour to Oracle's [ aggregate function ] KEEP (DENSE_RANK LAST ORDER BY ... ), use minAll(Comparator) instead.

taking

public static <T> java.util.stream.Collector<T,?,Seq<T>> taking(long n)

Get a Collector that takes the first n elements from a collection.

dropping

public static <T> java.util.stream.Collector<T,?,Seq<T>> dropping(long n)

Get a Collector that skip the first n elements of a collection.

count

public static <T> java.util.stream.Collector<T,?,java.lang.Long> count()

Get a Collector that calculates the COUNT(*) function.

countDistinct

public static <T> java.util.stream.Collector<T,?,java.lang.Long> countDistinct()

Get a Collector that calculates the COUNT (DISTINCT *) function.

countDistinctBy

public static <T,U> java.util.stream.Collector<T,?,java.lang.Long> countDistinctBy(java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the COUNT (DISTINCT expr) function.

sum

public static <T> java.util.stream.Collector<T,?,java.util.Optional<T>> sum()

Get a Collector that calculates the SUM() for any type of Number.

sum

public static <T,U> java.util.stream.Collector<T,?,java.util.Optional<U>> sum(java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the SUM() for any type of Number.

avg

public static <T> java.util.stream.Collector<T,?,java.util.Optional<T>> avg()

Get a Collector that calculates the AVG() for any type of Number.

avg

public static <T,U> java.util.stream.Collector<T,?,java.util.Optional<U>> avg(java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the AVG() for any type of Number.

min

public static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,java.util.Optional<T>> min()

Get a Collector that calculates the MIN() function.

min

public static <T> java.util.stream.Collector<T,?,java.util.Optional<T>> min(java.util.Comparator<? super T> comparator)

Get a Collector that calculates the MIN() function.

min

public static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<U>> min(java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the MIN() function.

min

public static <T,U> java.util.stream.Collector<T,?,java.util.Optional<U>> min(java.util.function.Function<? super T,? extends U> function,
                                                                                                java.util.Comparator<? super U> comparator)

Get a Collector that calculates the MIN() function.

minBy

public static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<T>> minBy(java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the MIN() function.

minBy

public static <T,U> java.util.stream.Collector<T,?,java.util.Optional<T>> minBy(java.util.function.Function<? super T,? extends U> function,
                                                                                                  java.util.Comparator<? super U> comparator)

Get a Collector that calculates the MIN() function.

minAll

public static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,Seq<T>> minAll()

Get a Collector that calculates the MIN() function, producing multiple results.

minAll

public static <T> java.util.stream.Collector<T,?,Seq<T>> minAll(java.util.Comparator<? super T> comparator)

Get a Collector that calculates the MIN() function, producing multiple results.

minAll

public static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,Seq<U>> minAll(java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the MIN() function, producing multiple results.

minAll

public static <T,U> java.util.stream.Collector<T,?,Seq<U>> minAll(java.util.function.Function<? super T,? extends U> function,
                                                                                    java.util.Comparator<? super U> comparator)

Get a Collector that calculates the MIN() function, producing multiple results.

minAllBy

public static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,Seq<T>> minAllBy(java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the MIN() function, producing multiple results.

minAllBy

public static <T,U> java.util.stream.Collector<T,?,Seq<T>> minAllBy(java.util.function.Function<? super T,? extends U> function,
                                                                                      java.util.Comparator<? super U> comparator)

Get a Collector that calculates the MIN() function, producing multiple results.

max

public static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,java.util.Optional<T>> max()

Get a Collector that calculates the MAX() function.

max

public static <T> java.util.stream.Collector<T,?,java.util.Optional<T>> max(java.util.Comparator<? super T> comparator)

Get a Collector that calculates the MAX() function.

max

public static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<U>> max(java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the MAX() function.

max

public static <T,U> java.util.stream.Collector<T,?,java.util.Optional<U>> max(java.util.function.Function<? super T,? extends U> function,
                                                                                                java.util.Comparator<? super U> comparator)

Get a Collector that calculates the MAX() function.

maxBy

public static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<T>> maxBy(java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the MAX() function.

maxBy

public static <T,U> java.util.stream.Collector<T,?,java.util.Optional<T>> maxBy(java.util.function.Function<? super T,? extends U> function,
                                                                                                  java.util.Comparator<? super U> comparator)

Get a Collector that calculates the MAX() function.

maxAll

public static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,Seq<T>> maxAll()

Get a Collector that calculates the MAX() function, producing multiple results.

maxAll

public static <T> java.util.stream.Collector<T,?,Seq<T>> maxAll(java.util.Comparator<? super T> comparator)

Get a Collector that calculates the MAX() function, producing multiple results.

maxAll

public static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,Seq<U>> maxAll(java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the MAX() function, producing multiple results.

maxAll

public static <T,U> java.util.stream.Collector<T,?,Seq<U>> maxAll(java.util.function.Function<? super T,? extends U> function,
                                                                                    java.util.Comparator<? super U> comparator)

Get a Collector that calculates the MAX() function, producing multiple results.

maxAllBy

public static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,Seq<T>> maxAllBy(java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the MAX() function, producing multiple results.

maxAllBy

public static <T,U> java.util.stream.Collector<T,?,Seq<T>> maxAllBy(java.util.function.Function<? super T,? extends U> function,
                                                                                      java.util.Comparator<? super U> comparator)

Get a Collector that calculates the MAX() function, producing multiple results.

allMatch

public static java.util.stream.Collector<java.lang.Boolean,?,java.lang.Boolean> allMatch()

Get a Collector that calculates the ALL() function.

allMatch

public static <T> java.util.stream.Collector<T,?,java.lang.Boolean> allMatch(java.util.function.Predicate<? super T> predicate)

Get a Collector that calculates the ALL() function.

anyMatch

public static java.util.stream.Collector<java.lang.Boolean,?,java.lang.Boolean> anyMatch()

Get a Collector that calculates the ANY() function.

anyMatch

public static <T> java.util.stream.Collector<T,?,java.lang.Boolean> anyMatch(java.util.function.Predicate<? super T> predicate)

Get a Collector that calculates the ANY() function.

noneMatch

public static java.util.stream.Collector<java.lang.Boolean,?,java.lang.Boolean> noneMatch()

Get a Collector that calculates the NONE() function.

noneMatch

public static <T> java.util.stream.Collector<T,?,java.lang.Boolean> noneMatch(java.util.function.Predicate<? super T> predicate)

Get a Collector that calculates the NONE() function.

bitAnd

public static <T> java.util.stream.Collector<T,?,java.util.Optional<T>> bitAnd()

Get a Collector that calculates BIT_AND() for any type of Number.

bitAnd

public static <T,U> java.util.stream.Collector<T,?,java.util.Optional<U>> bitAnd(java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the BIT_AND() for any type of Number.

bitAndInt

public static <T> java.util.stream.Collector<T,?,java.lang.Integer> bitAndInt(java.util.function.ToIntFunction<? super T> function)

Get a Collector that calculates the BIT_AND() for any type of Number.

bitAndLong

public static <T> java.util.stream.Collector<T,?,java.lang.Long> bitAndLong(java.util.function.ToLongFunction<? super T> function)

Get a Collector that calculates the BIT_AND() for any type of Number.

bitOr

public static <T> java.util.stream.Collector<T,?,java.util.Optional<T>> bitOr()

Get a Collector that calculates BIT_OR() for any type of Number.

bitOr

public static <T,U> java.util.stream.Collector<T,?,java.util.Optional<U>> bitOr(java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the BIT_OR() for any type of Number.

bitOrInt

public static <T> java.util.stream.Collector<T,?,java.lang.Integer> bitOrInt(java.util.function.ToIntFunction<? super T> function)

Get a Collector that calculates the BIT_OR() for any type of Number.

bitOrLong

public static <T> java.util.stream.Collector<T,?,java.lang.Long> bitOrLong(java.util.function.ToLongFunction<? super T> function)

Get a Collector that calculates the BIT_OR() for any type of Number.

mode

public static <T> java.util.stream.Collector<T,?,java.util.Optional<T>> mode()

Get a Collector that calculates the MODE() function.

modeAll

public static <T> java.util.stream.Collector<T,?,Seq<T>> modeAll()

Get a Collector that calculates the MODE() function.

mode0

private static <T,X> java.util.stream.Collector<T,?,X> mode0(java.util.function.Function<? super Seq<Tuple2<T,java.lang.Long>>,? extends X> transformer)

modeBy

public static <T,U> java.util.stream.Collector<T,?,java.util.Optional<T>> modeBy(java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the MODE() function.

modeAllBy

public static <T,U> java.util.stream.Collector<T,?,Seq<T>> modeAllBy(java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the MODE() function.

rank

public static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Long>> rank(T value)

Get a Collector that calculates the RANK() function given natural ordering.

rank

public static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Long>> rank(T value,
                                                                                                      java.util.Comparator<? super T> comparator)

Get a Collector that calculates the RANK() function given a specific ordering.

rankBy

public static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Long>> rankBy(U value,
                                                                                                                                                        java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the derived RANK() function given natural ordering.

rankBy

public static <T,U> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Long>> rankBy(U value,
                                                                                                                java.util.function.Function<? super T,? extends U> function,
                                                                                                                java.util.Comparator<? super U> comparator)

Get a Collector that calculates the derived RANK() function given a specific ordering.

denseRank

public static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Long>> denseRank(T value)

Get a Collector that calculates the DENSE_RANK() function given natural ordering.

denseRank

public static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Long>> denseRank(T value,
                                                                                                           java.util.Comparator<? super T> comparator)

Get a Collector that calculates the DENSE_RANK() function given a specific ordering.

denseRankBy

public static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Long>> denseRankBy(U value,
                                                                                                                                                             java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the derived DENSE_RANK() function given natural ordering.

denseRankBy

public static <T,U> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Long>> denseRankBy(U value,
                                                                                                                     java.util.function.Function<? super T,? extends U> function,
                                                                                                                     java.util.Comparator<? super U> comparator)

Get a Collector that calculates the derived DENSE_RANK() function given a specific ordering.

percentRank

public static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>> percentRank(T value)

Get a Collector that calculates the PERCENT_RANK() function given natural ordering.

percentRank

public static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>> percentRank(T value,
                                                                                                               java.util.Comparator<? super T> comparator)

Get a Collector that calculates the PERCENT_RANK() function given a specific ordering.

percentRankBy

public static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>> percentRankBy(U value,
                                                                                                                                                                 java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the derived PERCENT_RANK() function given natural ordering.

percentRankBy

public static <T,U> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>> percentRankBy(U value,
                                                                                                                         java.util.function.Function<? super T,? extends U> function,
                                                                                                                         java.util.Comparator<? super U> comparator)

Get a Collector that calculates the derived PERCENT_RANK() function given a specific ordering.

median

public static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,java.util.Optional<T>> median()

Get a Collector that calculates the MEDIAN() function given natural ordering.

median

public static <T> java.util.stream.Collector<T,?,java.util.Optional<T>> median(java.util.Comparator<? super T> comparator)

Get a Collector that calculates the MEDIAN() function given a specific ordering.

median

public static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<U>> median(java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the MEDIAN() function given a specific ordering.

median

public static <T,U> java.util.stream.Collector<T,?,java.util.Optional<U>> median(java.util.function.Function<? super T,? extends U> function,
                                                                                                   java.util.Comparator<? super U> comparator)

Get a Collector that calculates the MEDIAN() function given a specific ordering.

medianBy

public static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<T>> medianBy(java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the derived MEDIAN() function given natural ordering.

medianBy

public static <T,U> java.util.stream.Collector<T,?,java.util.Optional<T>> medianBy(java.util.function.Function<? super T,? extends U> function,
                                                                                                     java.util.Comparator<? super U> comparator)

Get a Collector that calculates the derived MEDIAN() function given a specific ordering.

percentile

public static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,java.util.Optional<T>> percentile(double percentile)

Get a Collector that calculates the PERCENTILE_DISC(percentile) function given natural ordering.

percentile

public static <T> java.util.stream.Collector<T,?,java.util.Optional<T>> percentile(double percentile,
                                                                                               java.util.Comparator<? super T> comparator)

Get a Collector that calculates the PERCENTILE_DISC(percentile) function given a specific ordering.

percentile

public static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<U>> percentile(double percentile,
                                                                                                                                               java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the PERCENTILE_DISC(percentile) function given a specific ordering.

percentile

public static <T,U> java.util.stream.Collector<T,?,java.util.Optional<U>> percentile(double percentile,
                                                                                                       java.util.function.Function<? super T,? extends U> function,
                                                                                                       java.util.Comparator<? super U> comparator)

Get a Collector that calculates the PERCENTILE_DISC(percentile) function given a specific ordering.

percentileBy

public static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,java.util.Optional<T>> percentileBy(double percentile,
                                                                                                                                                 java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the derived PERCENTILE_DISC(percentile) function given natural ordering.

percentileBy

public static <T,U> java.util.stream.Collector<T,?,java.util.Optional<T>> percentileBy(double percentile,
                                                                                                         java.util.function.Function<? super T,? extends U> function,
                                                                                                         java.util.Comparator<? super U> comparator)

Get a Collector that calculates the derived PERCENTILE_DISC(percentile) function given a specific ordering.

percentileAll

public static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,Seq<T>> percentileAll(double percentile)

Get a Collector that calculates the PERCENTILE_DISC(percentile) function given a specific ordering, producing multiple results.

percentileAll

public static <T> java.util.stream.Collector<T,?,Seq<T>> percentileAll(double percentile,
                                                                                   java.util.Comparator<? super T> comparator)

Get a Collector that calculates the PERCENTILE_DISC(percentile) function given a specific ordering, producing multiple results.

percentileAllBy

public static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,Seq<T>> percentileAllBy(double percentile,
                                                                                                                                     java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the derived PERCENTILE_DISC(percentile) function given a specific ordering, producing multiple results.

percentileAllBy

public static <T,U> java.util.stream.Collector<T,?,Seq<T>> percentileAllBy(double percentile,
                                                                                             java.util.function.Function<? super T,? extends U> function,
                                                                                             java.util.Comparator<? super U> comparator)

Get a Collector that calculates the derived PERCENTILE_DISC(percentile) function given a specific ordering, producing multiple results.

percentileCollector

private static <T,U,R> java.util.stream.Collector<T,java.util.List<Tuple2<T,U>>,R> percentileCollector(java.util.function.Function<? super T,? extends U> function,
                                                                                                                                     java.util.Comparator<? super U> comparator,
                                                                                                                                     java.util.function.Supplier<R> onEmpty,
                                                                                                                                     java.util.function.Function<T,R> onSingle,
                                                                                                                                     java.util.function.Function<java.util.List<Tuple2<T,U>>,R> finisher)

percentileIndex

private static int percentileIndex(double percentile,
                                   int size)

medianAll

public static <T extends java.lang.Comparable<? super T>> java.util.stream.Collector<T,?,Seq<T>> medianAll()

Get a Collector that calculates the PERCENTILE_DISC(percentile) function given a specific ordering, producing multiple results.

medianAll

public static <T> java.util.stream.Collector<T,?,Seq<T>> medianAll(java.util.Comparator<? super T> comparator)

Get a Collector that calculates the PERCENTILE_DISC(percentile) function given a specific ordering, producing multiple results.

medianAllBy

public static <T,U extends java.lang.Comparable<? super U>> java.util.stream.Collector<T,?,Seq<T>> medianAllBy(java.util.function.Function<? super T,? extends U> function)

Get a Collector that calculates the derived PERCENTILE_DISC(percentile) function given a specific ordering, producing multiple results.

medianAllBy

public static <T,U> java.util.stream.Collector<T,?,Seq<T>> medianAllBy(java.util.function.Function<? super T,? extends U> function,
                                                                                         java.util.Comparator<? super U> comparator)

Get a Collector that calculates the derived MEDIAN() function given natural ordering, producing multiple results.

stddevDouble

public static <T> java.util.stream.Collector<java.lang.Double,?,java.util.Optional<java.lang.Double>> stddevDouble()

Get a Collector that calculates the STDDEV_POP() function.

stddevDouble

public static <T,U> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>> stddevDouble(java.util.function.ToDoubleFunction<? super T> function)

Get a Collector that calculates the STDDEV_POP() function.

varianceDouble

public static java.util.stream.Collector<java.lang.Double,?,java.util.Optional<java.lang.Double>> varianceDouble()

Get a Collector that calculates the VAR_POP() function.

varianceDouble

public static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>> varianceDouble(java.util.function.ToDoubleFunction<? super T> function)

Get a Collector that calculates the VAR_POP() function.

variance0

private static <T> double variance0(java.util.List<T> l,
                                    java.util.function.ToDoubleFunction<? super T> function)

covarianceDouble

public static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>> covarianceDouble()

Get a Collector that calculates the COVAR_POP() function.

covarianceDouble

public static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>> covarianceDouble(java.util.function.ToDoubleFunction<? super T> functionX,
                                                                                                                    java.util.function.ToDoubleFunction<? super T> functionY)

Get a Collector that calculates the COVAR_POP() function.

covarianceFinisher

private static <T> java.util.function.Function<java.util.List<T>,java.util.Optional<java.lang.Double>> covarianceFinisher(java.util.function.ToDoubleFunction<? super T> functionX,
                                                                                                                                java.util.function.ToDoubleFunction<? super T> functionY,
                                                                                                                                java.util.function.BiFunction<java.util.List<T>,java.util.function.ToDoubleFunction<? super T>,java.lang.Double> sumOrAvg)

correlationDouble

public static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>> correlationDouble()

Get a Collector that calculates the CORR() function.

correlationDouble

public static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>> correlationDouble(java.util.function.ToDoubleFunction<? super T> functionX,
                                                                                                                     java.util.function.ToDoubleFunction<? super T> functionY)

Get a Collector that calculates the CORR() function.

regrCount

public static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.lang.Long> regrCount()

Get a Collector that calculates the REGR_COUNT() function.

regrCount

public static <T> java.util.stream.Collector<T,?,java.lang.Long> regrCount(java.util.function.ToDoubleFunction<? super T> functionX,
                                                                                       java.util.function.ToDoubleFunction<? super T> functionY)

Get a Collector that calculates the REGR_COUNT() function.

regrAvgXDouble

public static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>> regrAvgXDouble()

Get a Collector that calculates the REGR_AVGX() function.

regrAvgXDouble

public static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>> regrAvgXDouble(java.util.function.ToDoubleFunction<? super T> functionX,
                                                                                                                  java.util.function.ToDoubleFunction<? super T> functionY)

Get a Collector that calculates the REGR_AVGX() function.

regrAvgYDouble

public static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>> regrAvgYDouble()

Get a Collector that calculates the REGR_AVGY() function.

regrAvgYDouble

public static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>> regrAvgYDouble(java.util.function.ToDoubleFunction<? super T> functionX,
                                                                                                                  java.util.function.ToDoubleFunction<? super T> functionY)

Get a Collector that calculates the REGR_AVGY() function.

regrSxxDouble

public static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>> regrSxxDouble()

Get a Collector that calculates the REGR_SXX() function.

regrSxxDouble

public static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>> regrSxxDouble(java.util.function.ToDoubleFunction<? super T> functionX,
                                                                                                                 java.util.function.ToDoubleFunction<? super T> functionY)

Get a Collector that calculates the REGR_SXX() function.

regrSxyDouble

public static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>> regrSxyDouble()

Get a Collector that calculates the REGR_SXY() function.

regrSxyDouble

public static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>> regrSxyDouble(java.util.function.ToDoubleFunction<? super T> functionX,
                                                                                                                 java.util.function.ToDoubleFunction<? super T> functionY)

Get a Collector that calculates the REGR_SXY() function.

regrSyyDouble

public static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>> regrSyyDouble()

Get a Collector that calculates the REGR_SYY() function.

regrSyyDouble

public static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>> regrSyyDouble(java.util.function.ToDoubleFunction<? super T> functionX,
                                                                                                                 java.util.function.ToDoubleFunction<? super T> functionY)

Get a Collector that calculates the REGR_SYY() function.

regrSlopeDouble

public static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>> regrSlopeDouble()

Get a Collector that calculates the REGR_SLOPE() function.

regrSlopeDouble

public static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>> regrSlopeDouble(java.util.function.ToDoubleFunction<? super T> functionX,
                                                                                                                   java.util.function.ToDoubleFunction<? super T> functionY)

Get a Collector that calculates the REGR_SLOPE() function.

regrInterceptDouble

public static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>> regrInterceptDouble()

Get a Collector that calculates the REGR_INTERCEPT() function.

regrInterceptDouble

public static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>> regrInterceptDouble(java.util.function.ToDoubleFunction<? super T> functionX,
                                                                                                                       java.util.function.ToDoubleFunction<? super T> functionY)

Get a Collector that calculates the REGR_INTERCEPT() function.

regrR2Double

public static java.util.stream.Collector<Tuple2<java.lang.Double,java.lang.Double>,?,java.util.Optional<java.lang.Double>> regrR2Double()

Get a Collector that calculates the regrR2Double() function.

regrR2Double

public static <T> java.util.stream.Collector<T,?,java.util.Optional<java.lang.Double>> regrR2Double(java.util.function.ToDoubleFunction<? super T> functionX,
                                                                                                                java.util.function.ToDoubleFunction<? super T> functionY)

Get a Collector that calculates the regrR2Double() function.

sum0

private static <T> double sum0(java.util.List<T> list,
                               java.util.function.ToDoubleFunction<? super T> function)

avg0

private static <T> double avg0(java.util.List<T> list,
                               java.util.function.ToDoubleFunction<? super T> function)

commonPrefix

public static java.util.stream.Collector<java.lang.CharSequence,?,java.lang.String> commonPrefix()

Get a Collector that calculates the common prefix of a set of strings.

commonSuffix

public static java.util.stream.Collector<java.lang.CharSequence,?,java.lang.String> commonSuffix()

Get a Collector that calculates the common suffix of a set of strings.

mapAll

private static <T1,T2,R> java.util.Optional<R> mapAll(Tuple2<java.util.Optional<T1>,java.util.Optional<T2>> tuple,
                                                                  Function2<T1,T2,R> function)

mapAll

private static <T1,T2,T3,R> java.util.Optional<R> mapAll(Tuple3<java.util.Optional<T1>,java.util.Optional<T2>,java.util.Optional<T3>> tuple,
                                                                           Function3<T1,T2,T3,R> function)