Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
16 commits
Select commit Hold shift + click to select a range
9f5188a
Add correlation and covariance aggregate functions to the query engine
CoollZzz Feb 1, 2026
33a229f
Enhance aggregate functions to support TIMESTAMP data type
CoollZzz Feb 2, 2026
b8cc6cb
Add regression aggregate functions: REGR_SLOPE and REGR_INTERCEPT
CoollZzz Mar 10, 2026
b216676
Add skewness and kurtosis aggregate functions with input validation
CoollZzz Mar 11, 2026
891ae63
Refactor input validation for aggregate functions to streamline argum…
CoollZzz Mar 12, 2026
45c24e8
Refactor aggregation function type checks to improve input validation
CoollZzz Mar 12, 2026
d79fe2b
Refactor correlation and regression accumulators to improve code clar…
CoollZzz Mar 13, 2026
56d02db
Refactor skewness,corr calculation in central moment accumulators
CoollZzz Mar 22, 2026
8f0f815
Refactor correlation accumulators to use CovarianceAccumulator for co…
CoollZzz Mar 25, 2026
861124f
Implement removeIntermediate method for CentralMoment, Correlation, C…
CoollZzz Mar 26, 2026
9b4c4cf
Add integration tests for correlation, covariance, regression, and mo…
CoollZzz Mar 26, 2026
9255685
fix: address review comments for statistical aggregation functions
CoollZzz Apr 13, 2026
0d473a9
refactor: update package structure for statistical aggregation accumu…
CoollZzz Apr 29, 2026
23893c5
feat: implement removeInput method for regression, covariance, and co…
CoollZzz May 17, 2026
4080987
Merge tree-model statistical aggregation ITs into one class.
CoollZzz May 25, 2026
6409654
Fix statistical aggregation semantics and reviewer issues
CoollZzz Jun 3, 2026
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,14 @@ public enum BuiltinAggregationFunctionEnum {
AVG("avg"),
SUM("sum"),
MAX_BY("max_by"),
MIN_BY("min_by");
MIN_BY("min_by"),
CORR("corr"),
COVAR_POP("covar_pop"),
COVAR_SAMP("covar_samp"),
REGR_SLOPE("regr_slope"),
REGR_INTERCEPT("regr_intercept"),
SKEWNESS("skewness"),
KURTOSIS("kurtosis");

private final String functionName;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -145,6 +145,34 @@ public static String varSamp(String path) {
return String.format("var_samp(%s)", path);
}

public static String corr(String path) {
return String.format("corr(%s)", path);
}

public static String covarPop(String path) {
return String.format("covar_pop(%s)", path);
}

public static String covarSamp(String path) {
return String.format("covar_samp(%s)", path);
}

public static String regrSlope(String path) {
return String.format("regr_slope(%s)", path);
}

public static String regrIntercept(String path) {
return String.format("regr_intercept(%s)", path);
}

public static String kurtosis(String path) {
return String.format("kurtosis(%s)", path);
}

public static String skewness(String path) {
return String.format("skewness(%s)", path);
}

public static String countUDAF(String path) {
return String.format("count_udaf(%s)", path);
}
Expand Down
Loading
Loading