Package org.apache.beam.sdk.extensions.sql.impl.transform.agg

@DefaultAnnotation(org.checkerframework.checker.nullness.qual.NonNull.class) package org.apache.beam.sdk.extensions.sql.impl.transform.agg

Implementation of standard SQL aggregation functions, e.g. VAR_POP, VAR_SAMP.

Related Packages

Package	Description
org.apache.beam.sdk.extensions.sql.impl.transform	PTransform used in a BeamSql pipeline.

Classes

Class	Description
AggregationCombineFnAdapter<T>	Wrapper Combine.CombineFns for aggregation function calls.
CountIf	Returns the count of TRUE values for expression.
CountIf.CountIfFn
CovarianceFn<T extends Number>	Combine.CombineFn for Covariance on Number types.
VarianceFn<T extends Number>	Combine.CombineFn for Variance on Number types.