Class 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

      All Methods Static Methods Concrete Methods 
      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)