public final class ReductionAggregation extends Object
Modifier and Type | Method and Description |
---|---|
static ReductionAggregation |
all()
All reduction.
|
static ReductionAggregation |
any()
Any reduction.
|
static ReductionAggregation |
collectList() |
static ReductionAggregation |
collectList(NullPolicy nullPolicy)
Collect the values into a list.
|
static ReductionAggregation |
collectSet()
Collect the values into a set.
|
static ReductionAggregation |
collectSet(NullPolicy nullPolicy,
NullEquality nullEquality,
NaNEquality nanEquality)
Collect the values into a set.
|
static ReductionAggregation |
createTDigest(int delta)
tDigest reduction.
|
boolean |
equals(Object other) |
int |
hashCode() |
static ReductionAggregation |
histogram()
Create HistogramAggregation, computing the frequencies for each unique row.
|
static ReductionAggregation |
max()
Max Aggregation
|
static ReductionAggregation |
mean()
Arithmetic mean reduction.
|
static ReductionAggregation |
median()
Median reduction.
|
static ReductionAggregation |
mergeHistogram()
Create MergeHistogramAggregation, to merge multiple histograms.
|
static ReductionAggregation |
mergeLists()
Merge the partial lists produced by multiple CollectListAggregations.
|
static ReductionAggregation |
mergeSets()
Merge the partial sets produced by multiple CollectSetAggregations.
|
static ReductionAggregation |
mergeSets(NullEquality nullEquality,
NaNEquality nanEquality)
Merge the partial sets produced by multiple CollectSetAggregations.
|
static ReductionAggregation |
mergeTDigest(int delta)
tDigest merge reduction.
|
static ReductionAggregation |
min()
Min Aggregation
|
static ReductionAggregation |
nth(int offset)
Get the nth, non-null, element in a group.
|
static ReductionAggregation |
nth(int offset,
NullPolicy nullPolicy)
Get the nth element in a group.
|
static ReductionAggregation |
nunique()
Number of unique, non-null, elements.
|
static ReductionAggregation |
nunique(NullPolicy nullPolicy)
Number of unique elements.
|
static ReductionAggregation |
product()
Product Aggregation.
|
static ReductionAggregation |
quantile(double... quantiles)
Aggregate to compute the specified quantiles.
|
static ReductionAggregation |
quantile(QuantileMethod method,
double... quantiles)
Aggregate to compute various quantiles.
|
static ReductionAggregation |
standardDeviation()
Standard deviation aggregation with 1 as the delta degrees of freedom.
|
static ReductionAggregation |
standardDeviation(int ddof)
Standard deviation aggregation.
|
static ReductionAggregation |
sum()
Sum Aggregation
|
static ReductionAggregation |
sumOfSquares()
Sum of squares reduction.
|
static ReductionAggregation |
variance()
Variance aggregation with 1 as the delta degrees of freedom.
|
static ReductionAggregation |
variance(int ddof)
Variance aggregation.
|
public static ReductionAggregation sum()
public static ReductionAggregation product()
public static ReductionAggregation min()
public static ReductionAggregation max()
public static ReductionAggregation any()
public static ReductionAggregation all()
public static ReductionAggregation sumOfSquares()
public static ReductionAggregation mean()
public static ReductionAggregation variance()
public static ReductionAggregation variance(int ddof)
ddof
- delta degrees of freedom. The divisor used in calculation of variance is
N - ddof
, where N is the population size.public static ReductionAggregation standardDeviation()
public static ReductionAggregation standardDeviation(int ddof)
ddof
- delta degrees of freedom. The divisor used in calculation of std is
N - ddof
, where N is the population size.public static ReductionAggregation median()
public static ReductionAggregation quantile(double... quantiles)
public static ReductionAggregation quantile(QuantileMethod method, double... quantiles)
public static ReductionAggregation nunique()
public static ReductionAggregation nunique(NullPolicy nullPolicy)
nullPolicy
- INCLUDE if nulls should be counted else EXCLUDE. If nulls are counted they
compare as equal so multiple null values in a range would all only
increase the count by 1.public static ReductionAggregation nth(int offset)
offset
- the offset to look at. Negative numbers go from the end of the group. Any
value outside of the group range results in a null.public static ReductionAggregation nth(int offset, NullPolicy nullPolicy)
offset
- the offset to look at. Negative numbers go from the end of the group. Any
value outside of the group range results in a null.nullPolicy
- INCLUDE if nulls should be included in the aggregation or EXCLUDE if they
should be skipped.public static ReductionAggregation createTDigest(int delta)
public static ReductionAggregation mergeTDigest(int delta)
public static ReductionAggregation collectList()
public static ReductionAggregation collectList(NullPolicy nullPolicy)
nullPolicy
- Indicates whether to include/exclude nulls during collection.public static ReductionAggregation collectSet()
public static ReductionAggregation collectSet(NullPolicy nullPolicy, NullEquality nullEquality, NaNEquality nanEquality)
nullPolicy
- Indicates whether to include/exclude nulls during collection.nullEquality
- Flag to specify whether null entries within each list should be considered equal.nanEquality
- Flag to specify whether NaN values in floating point column should be considered equal.public static ReductionAggregation mergeLists()
public static ReductionAggregation mergeSets()
public static ReductionAggregation mergeSets(NullEquality nullEquality, NaNEquality nanEquality)
nullEquality
- Flag to specify whether null entries within each list should be considered equal.nanEquality
- Flag to specify whether NaN values in floating point column should be considered equal.public static ReductionAggregation histogram()
public static ReductionAggregation mergeHistogram()
Copyright © 2024. All rights reserved.