Top Fields Constructors Methods
org.jooq.lambda

pack-priv Class WindowImpl<T>

extends Object
implements Window<T>
Class Inheritance
All Implemented Interfaces
org.jooq.lambda.Window, org.jooq.lambda.Collectable
Imports
java.util.Collection, .Collections, .Comparator, .List, .Map, .Objects, .Optional, .Set, java.util.function.Function, .Predicate, .Supplier, .ToDoubleFunction, .ToIntFunction, .ToLongFunction, java.util.stream.Collector, .Collectors, org.jooq.lambda.tuple.Tuple2
Author
Lukas Eder

Field Summary

Modifier and TypeField and Description
pack-priv final int
index

pack-priv final long
lower

pack-priv final Comparator<? super T>
order

pack-priv final Partition<T>
partition

pack-priv final long
upper

pack-priv final Tuple2<T, Long>
value

Constructor Summary

AccessConstructor and Description
pack-priv
WindowImpl(Tuple2<T, Long> value, Partition<T> partition, WindowSpecification<T> specification)

Method Summary

Modifier and TypeMethod and Description
public boolean
allMatch(Predicate<? super T> predicate)

Implements org.jooq.lambda.Collectable.allMatch.

Whether all elements in the collectable match a given predicate.

public boolean
anyMatch(Predicate<? super T> predicate)

Implements org.jooq.lambda.Collectable.anyMatch.

Whether any element in the collectable matches a given predicate.

public Optional<T>
avg()

Implements org.jooq.lambda.Collectable.avg.

Get the average of the elements in this collectable.

public <U> Optional<U>
avg(Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Collectable.avg.

Get the average of the elements in this collectable.

public double
avgDouble(ToDoubleFunction<? super T> function)

Implements org.jooq.lambda.Collectable.avgDouble.

Get the average of the elements in this collectable as double.

public double
avgInt(ToIntFunction<? super T> function)

Implements org.jooq.lambda.Collectable.avgInt.

Get the average of the elements in this collectable as int.

public double
avgLong(ToLongFunction<? super T> function)

Implements org.jooq.lambda.Collectable.avgLong.

Get the average of the elements in this collectable as long.

public Optional<T>
bitAnd()

Implements org.jooq.lambda.Collectable.bitAnd.

Collect all bits in this stream into a single value by applying bitwise and.

public <U> Optional<U>
bitAnd(Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Collectable.bitAnd.

Collect all bits in this stream into a single value by applying bitwise and.

public int
bitAndInt(ToIntFunction<? super T> function)

Implements org.jooq.lambda.Collectable.bitAndInt.

Collect all bits in this stream into a single value by applying bitwise and.

public long
bitAndLong(ToLongFunction<? super T> function)

Implements org.jooq.lambda.Collectable.bitAndLong.

Collect all bits in this stream into a single value by applying bitwise and.

public Optional<T>
bitOr()

Implements org.jooq.lambda.Collectable.bitOr.

Collect all bits in this stream into a single value by applying bitwise or.

public <U> Optional<U>
bitOr(Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Collectable.bitOr.

Collect all bits in this stream into a single value by applying bitwise or.

public int
bitOrInt(ToIntFunction<? super T> function)

Implements org.jooq.lambda.Collectable.bitOrInt.

Collect all bits in this stream into a single value by applying bitwise or.

public long
bitOrLong(ToLongFunction<? super T> function)

Implements org.jooq.lambda.Collectable.bitOrLong.

Collect all bits in this stream into a single value by applying bitwise or.

public <R, A> R
collect(Collector<? super T, A, R> collector)

Implements org.jooq.lambda.Collectable.collect.

Collect this collectable.

public String
commonPrefix()

Implements org.jooq.lambda.Collectable.commonPrefix.

Get the common prefix of all strings (or to-stringed values) in this stream.

public String
commonSuffix()

Implements org.jooq.lambda.Collectable.commonSuffix.

Get the common prefix of all strings (or to-stringed values) in this stream.

private boolean
completePartition()

public long
count()

Implements org.jooq.lambda.Collectable.count.

Count the values in this collectable.

public long
count(Predicate<? super T> predicate)

Implements org.jooq.lambda.Collectable.count.

Count the values in this collectable, for which a predicate evaluates to true.

public long
countDistinct()

Implements org.jooq.lambda.Collectable.countDistinct.

Count the distinct values in this collectable.

public long
countDistinct(Predicate<? super T> predicate)

Implements org.jooq.lambda.Collectable.countDistinct.

Count the distinct values in this collectable, for which a predicate evaluates to true.

public <U> long
countDistinctBy(Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Collectable.countDistinctBy.

Count the distinct values of a given expression in this collectable.

public <U> long
countDistinctBy(Function<? super T, ? extends U> function, Predicate<? super U> predicate)

Implements org.jooq.lambda.Collectable.countDistinctBy.

Count the distinct values of a given expression in this collectable, for which a predicate evaluates to true.

public long
denseRank()

Implements org.jooq.lambda.Window.denseRank.

The dense rank of the current row within the partition.

public Optional<T>
firstValue()

Implements org.jooq.lambda.Window.firstValue.

The first value in the window.

public <U> Optional<U>
firstValue(Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Window.firstValue.

The first value in the window.

public Optional<T>
lag()

Implements org.jooq.lambda.Window.lag.

The previous value in the window.

public Optional<T>
lag(long lag)

Implements org.jooq.lambda.Window.lag.

The previous value by lag in the window.

public Optional<T>
lastValue()

Implements org.jooq.lambda.Window.lastValue.

The last value in the window.

public <U> Optional<U>
lastValue(Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Window.lastValue.

The last value in the window.

public Optional<T>
lead()

Implements org.jooq.lambda.Window.lead.

The next value in the window.

public Optional<T>
lead(long lead)

Implements org.jooq.lambda.Window.lead.

The next value by lead in the window.

private Optional<T>
lead0(long lead)

private int
lower()

private boolean
lowerInPartition()

public Optional<T>
max()

Implements org.jooq.lambda.Collectable.max.

Get the maximum value.

public Optional<T>
max(Comparator<? super T> comparator)

Implements org.jooq.lambda.Collectable.max.

Get the maximum value by a function.

public <U extends Comparable<? super U>> Optional<U>
max(Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Collectable.max.

Get the maximum value by a function.

public <U> Optional<U>
max(Function<? super T, ? extends U> function, Comparator<? super U> comparator)

Implements org.jooq.lambda.Collectable.max.

Get the maximum value by a function.

public Seq<T>
maxAll()

Implements org.jooq.lambda.Collectable.maxAll.

Get the maximum values.

public Seq<T>
maxAll(Comparator<? super T> comparator)

Implements org.jooq.lambda.Collectable.maxAll.

Get the maximum values by a function.

public <U extends Comparable<? super U>> Seq<U>
maxAll(Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Collectable.maxAll.

Get the maximum values by a function.

public <U> Seq<U>
maxAll(Function<? super T, ? extends U> function, Comparator<? super U> comparator)

Implements org.jooq.lambda.Collectable.maxAll.

Get the maximum values by a function.

public <U extends Comparable<? super U>> Seq<T>
maxAllBy(Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Collectable.maxAllBy.

Get the maximum values by a function.

public <U> Seq<T>
maxAllBy(Function<? super T, ? extends U> function, Comparator<? super U> comparator)

Implements org.jooq.lambda.Collectable.maxAllBy.

Get the maximum values by a function.

public <U extends Comparable<? super U>> Optional<T>
maxBy(Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Collectable.maxBy.

Get the maximum value by a function.

public <U> Optional<T>
maxBy(Function<? super T, ? extends U> function, Comparator<? super U> comparator)

Implements org.jooq.lambda.Collectable.maxBy.

Get the maximum value by a function.

public Optional<T>
median()

Implements org.jooq.lambda.Collectable.median.

Get the median value.

public Optional<T>
median(Comparator<? super T> comparator)

Implements org.jooq.lambda.Collectable.median.

Get the median value.

public <U extends Comparable<? super U>> Optional<T>
medianBy(Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Collectable.medianBy.

Get the median value by a function.

public <U> Optional<T>
medianBy(Function<? super T, ? extends U> function, Comparator<? super U> comparator)

Implements org.jooq.lambda.Collectable.medianBy.

Get the median value by a function.

public Optional<T>
min()

Implements org.jooq.lambda.Collectable.min.

Get the minimum value.

public Optional<T>
min(Comparator<? super T> comparator)

Implements org.jooq.lambda.Collectable.min.

Get the minimum value by a function.

public <U extends Comparable<? super U>> Optional<U>
min(Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Collectable.min.

Get the minimum value by a function.

public <U> Optional<U>
min(Function<? super T, ? extends U> function, Comparator<? super U> comparator)

Implements org.jooq.lambda.Collectable.min.

Get the minimum value by a function.

public Seq<T>
minAll()

Implements org.jooq.lambda.Collectable.minAll.

Get the minimum values.

public Seq<T>
minAll(Comparator<? super T> comparator)

Implements org.jooq.lambda.Collectable.minAll.

Get the minimum values by a function.

public <U extends Comparable<? super U>> Seq<U>
minAll(Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Collectable.minAll.

Get the minimum values by a function.

public <U> Seq<U>
minAll(Function<? super T, ? extends U> function, Comparator<? super U> comparator)

Implements org.jooq.lambda.Collectable.minAll.

Get the minimum values by a function.

public <U extends Comparable<? super U>> Seq<T>
minAllBy(Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Collectable.minAllBy.

Get the minimum values by a function.

public <U> Seq<T>
minAllBy(Function<? super T, ? extends U> function, Comparator<? super U> comparator)

Implements org.jooq.lambda.Collectable.minAllBy.

Get the minimum values by a function.

public <U extends Comparable<? super U>> Optional<T>
minBy(Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Collectable.minBy.

Get the minimum value by a function.

public <U> Optional<T>
minBy(Function<? super T, ? extends U> function, Comparator<? super U> comparator)

Implements org.jooq.lambda.Collectable.minBy.

Get the minimum value by a function.

public Optional<T>
mode()

Implements org.jooq.lambda.Collectable.mode.

Get the mode, i.e. the value that appears most often in the collectable.

public Seq<T>
modeAll()

Implements org.jooq.lambda.Collectable.modeAll.

Get the mode, i.e. the values that appear most often in the collectable.

public <U> Seq<T>
modeAllBy(Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Collectable.modeAllBy.

Get the mode, i.e. the values that appear most often in the collectable.

public <U> Optional<T>
modeBy(Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Collectable.modeBy.

Get the mode, i.e. the value that appears most often in the collectable.

public boolean
noneMatch(Predicate<? super T> predicate)

Implements org.jooq.lambda.Collectable.noneMatch.

Whether no element in the collectable matches a given predicate.

public Optional<T>
nthValue(long n)

Implements org.jooq.lambda.Window.nthValue.

The nth value in the window.

public <U> Optional<U>
nthValue(long n, Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Window.nthValue.

The nth value in the window.

public long
ntile(long bucket)

Implements org.jooq.lambda.Window.ntile.

The bucket number ("ntile") of the current row within the partition.

public Optional<T>
percentile(double percentile)

Implements org.jooq.lambda.Collectable.percentile.

Get the discrete percentile value.

public Optional<T>
percentile(double percentile, Comparator<? super T> comparator)

Implements org.jooq.lambda.Collectable.percentile.

Get the discrete percentile value.

public <U extends Comparable<? super U>> Optional<T>
percentileBy(double percentile, Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Collectable.percentileBy.

Get the discrete percentile value by a function.

public <U> Optional<T>
percentileBy(double percentile, Function<? super T, ? extends U> function, Comparator<? super U> comparator)

Implements org.jooq.lambda.Collectable.percentileBy.

Get the discrete percentile value by a function.

public double
percentRank()

Implements org.jooq.lambda.Window.percentRank.

The precent rank of the current row within the partition.

public long
rank()

Implements org.jooq.lambda.Window.rank.

The rank of the current row within the partition.

public long
rowNumber()

Implements org.jooq.lambda.Window.rowNumber.

The row number of the current row within the partition.

public Optional<T>
sum()

Implements org.jooq.lambda.Collectable.sum.

Get the sum of the elements in this collectable.

public <U> Optional<U>
sum(Function<? super T, ? extends U> function)

Implements org.jooq.lambda.Collectable.sum.

Get the sum of the elements in this collectable.

public double
sumDouble(ToDoubleFunction<? super T> function)

Implements org.jooq.lambda.Collectable.sumDouble.

Get the sum of the elements in this collectable as double.

public int
sumInt(ToIntFunction<? super T> function)

Implements org.jooq.lambda.Collectable.sumInt.

Get the sum of the elements in this collectable as int.

public long
sumLong(ToLongFunction<? super T> function)

Implements org.jooq.lambda.Collectable.sumLong.

Get the sum of the elements in this collectable as long.

public <C extends Collection<T>> C
toCollection(Supplier<C> factory)

Implements org.jooq.lambda.Collectable.toCollection.

Collect the collectable into a Collection.

public List<T>
toList()

Implements org.jooq.lambda.Collectable.toList.

Collect the collectable into an ArrayList.

public <L extends List<T>> L
toList(Supplier<L> factory)

Implements org.jooq.lambda.Collectable.toList.

Collect the collectable into a List.

public <K, V> Map<K, V>
toMap(Function<? super T, ? extends K> keyMapper, Function<? super T, ? extends V> valueMapper)

Implements org.jooq.lambda.Collectable.toMap.

Collect the collectable into a Map.

public <K> Map<K, T>
toMap(Function<? super T, ? extends K> keyMapper)

Implements org.jooq.lambda.Collectable.toMap.

Collect the collectable into a Map with the given keys and the self element as value.

public Set<T>
toSet()

Implements org.jooq.lambda.Collectable.toSet.

Collect the collectable into a LinkedHashSet.

public <S extends Set<T>> S
toSet(Supplier<S> factory)

Implements org.jooq.lambda.Collectable.toSet.

Collect the collectable into a Set.

public String
toString()

Overrides java.lang.Object.toString.

Returns a string representation of the object.

public String
toString(CharSequence delimiter)

Implements org.jooq.lambda.Collectable.toString.

Consume a stream and concatenate all elements using a separator.

public String
toString(CharSequence delimiter, CharSequence prefix, CharSequence suffix)

Implements org.jooq.lambda.Collectable.toString.

Shortcut for calling Stream#collect(Collector) with a Collectors#joining(CharSequence, CharSequence, CharSequence) collector.

public List<T>
toUnmodifiableList()

Implements org.jooq.lambda.Collectable.toUnmodifiableList.

Collect the collectable into an unmodifiable List.

public Set<T>
toUnmodifiableSet()

Implements org.jooq.lambda.Collectable.toUnmodifiableSet.

Collect the collectable into an unmodifiable Set.

private int
upper()

private boolean
upperInPartition()

public T
value()

Implements org.jooq.lambda.Window.value.

The value of the current row in the window.

public Seq<T>
window()

Implements org.jooq.lambda.Window.window.

Stream all elements in the window.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAllwaitwaitwait