Skip to content

Commit 0f8c0cb

Browse files
committed
percentile
1 parent 96a7117 commit 0f8c0cb

8 files changed

+0
-72
lines changed

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/aggregation/MedianAbsoluteDeviationDoubleAggregator.java

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -47,15 +47,6 @@ public static void combineIntermediate(QuantileStates.GroupingState state, int g
4747
state.add(groupId, inValue);
4848
}
4949

50-
public static void combineStates(
51-
QuantileStates.GroupingState current,
52-
int currentGroupId,
53-
QuantileStates.GroupingState state,
54-
int statePosition
55-
) {
56-
current.add(currentGroupId, state.getOrNull(statePosition));
57-
}
58-
5950
public static Block evaluateFinal(QuantileStates.GroupingState state, IntVector selected, DriverContext driverContext) {
6051
return state.evaluateMedianAbsoluteDeviation(selected, driverContext);
6152
}

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/aggregation/MedianAbsoluteDeviationFloatAggregator.java

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -48,15 +48,6 @@ public static void combineIntermediate(QuantileStates.GroupingState state, int g
4848
state.add(groupId, inValue);
4949
}
5050

51-
public static void combineStates(
52-
QuantileStates.GroupingState current,
53-
int currentGroupId,
54-
QuantileStates.GroupingState state,
55-
int statePosition
56-
) {
57-
current.add(currentGroupId, state.getOrNull(statePosition));
58-
}
59-
6051
public static Block evaluateFinal(QuantileStates.GroupingState state, IntVector selected, DriverContext driverContext) {
6152
return state.evaluateMedianAbsoluteDeviation(selected, driverContext);
6253
}

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/aggregation/MedianAbsoluteDeviationIntAggregator.java

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -47,15 +47,6 @@ public static void combineIntermediate(QuantileStates.GroupingState state, int g
4747
state.add(groupId, inValue);
4848
}
4949

50-
public static void combineStates(
51-
QuantileStates.GroupingState current,
52-
int currentGroupId,
53-
QuantileStates.GroupingState state,
54-
int statePosition
55-
) {
56-
current.add(currentGroupId, state.getOrNull(statePosition));
57-
}
58-
5950
public static Block evaluateFinal(QuantileStates.GroupingState state, IntVector selected, DriverContext driverContext) {
6051
return state.evaluateMedianAbsoluteDeviation(selected, driverContext);
6152
}

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/aggregation/MedianAbsoluteDeviationLongAggregator.java

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -47,15 +47,6 @@ public static void combineIntermediate(QuantileStates.GroupingState state, int g
4747
state.add(groupId, inValue);
4848
}
4949

50-
public static void combineStates(
51-
QuantileStates.GroupingState current,
52-
int currentGroupId,
53-
QuantileStates.GroupingState state,
54-
int statePosition
55-
) {
56-
current.add(currentGroupId, state.getOrNull(statePosition));
57-
}
58-
5950
public static Block evaluateFinal(QuantileStates.GroupingState state, IntVector selected, DriverContext driverContext) {
6051
return state.evaluateMedianAbsoluteDeviation(selected, driverContext);
6152
}

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/aggregation/PercentileDoubleAggregator.java

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -47,15 +47,6 @@ public static void combineIntermediate(QuantileStates.GroupingState state, int g
4747
state.add(groupId, inValue);
4848
}
4949

50-
public static void combineStates(
51-
QuantileStates.GroupingState current,
52-
int currentGroupId,
53-
QuantileStates.GroupingState state,
54-
int statePosition
55-
) {
56-
current.add(currentGroupId, state.getOrNull(statePosition));
57-
}
58-
5950
public static Block evaluateFinal(QuantileStates.GroupingState state, IntVector selected, DriverContext driverContext) {
6051
return state.evaluatePercentile(selected, driverContext);
6152
}

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/aggregation/PercentileFloatAggregator.java

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -47,15 +47,6 @@ public static void combineIntermediate(QuantileStates.GroupingState state, int g
4747
state.add(groupId, inValue);
4848
}
4949

50-
public static void combineStates(
51-
QuantileStates.GroupingState current,
52-
int currentGroupId,
53-
QuantileStates.GroupingState state,
54-
int statePosition
55-
) {
56-
current.add(currentGroupId, state.getOrNull(statePosition));
57-
}
58-
5950
public static Block evaluateFinal(QuantileStates.GroupingState state, IntVector selected, DriverContext driverContext) {
6051
return state.evaluatePercentile(selected, driverContext);
6152
}

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/aggregation/PercentileIntAggregator.java

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -47,15 +47,6 @@ public static void combineIntermediate(QuantileStates.GroupingState state, int g
4747
state.add(groupId, inValue);
4848
}
4949

50-
public static void combineStates(
51-
QuantileStates.GroupingState current,
52-
int currentGroupId,
53-
QuantileStates.GroupingState state,
54-
int statePosition
55-
) {
56-
current.add(currentGroupId, state.getOrNull(statePosition));
57-
}
58-
5950
public static Block evaluateFinal(QuantileStates.GroupingState state, IntVector selected, DriverContext driverContext) {
6051
return state.evaluatePercentile(selected, driverContext);
6152
}

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/aggregation/PercentileLongAggregator.java

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -47,15 +47,6 @@ public static void combineIntermediate(QuantileStates.GroupingState state, int g
4747
state.add(groupId, inValue);
4848
}
4949

50-
public static void combineStates(
51-
QuantileStates.GroupingState current,
52-
int currentGroupId,
53-
QuantileStates.GroupingState state,
54-
int statePosition
55-
) {
56-
current.add(currentGroupId, state.getOrNull(statePosition));
57-
}
58-
5950
public static Block evaluateFinal(QuantileStates.GroupingState state, IntVector selectedGroups, DriverContext driverContext) {
6051
return state.evaluatePercentile(selectedGroups, driverContext);
6152
}

0 commit comments

Comments
 (0)