Skip to content

Commit 2aac264

Browse files
committed
Add label to circuit breaker
1 parent 896120e commit 2aac264

File tree

7 files changed

+9
-9
lines changed

7 files changed

+9
-9
lines changed

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

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

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

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

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

Lines changed: 2 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/aggregation/X-2State.java.st

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,10 +29,10 @@ final class $v1_Type$$v2_Type$State implements AggregatorState {
2929
$endif$
3030
private boolean seen;
3131

32-
$v1_Type$$v2_Type$State($v1_type$ v1, $v2_type$ v2$if(v2_BytesRef)$, CircuitBreaker breaker$endif$) {
32+
$v1_Type$$v2_Type$State($v1_type$ v1, $v2_type$ v2$if(v2_BytesRef)$, CircuitBreaker breaker, String label$endif$) {
3333
this.v1 = v1;
3434
$if(v2_BytesRef)$
35-
this.v2 = new BreakingBytesRefBuilder(breaker, "$v1_Type$$v2_Type$State", v2.length);
35+
this.v2 = new BreakingBytesRefBuilder(breaker, label, v2.length);
3636
this.v2.copyBytes(v2);
3737
$else$
3838
this.v2 = v2;

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/aggregation/X-ValueByTimestampAggregator.java.st

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ public class $Occurrence$$Type$ByTimestampAggregator {
4747

4848
public static Long$Type$State initSingle(DriverContext driverContext) {
4949
$if(BytesRef)$
50-
return new LongBytesRefState(0, new BytesRef(), driverContext.breaker());
50+
return new LongBytesRefState(0, new BytesRef(), driverContext.breaker(), describe());
5151
$else$
5252
return new Long$Type$State(0, 0);
5353
$endif$

x-pack/plugin/esql/qa/testFixtures/src/main/resources/stats_first.csv-spec

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,7 @@ FROM logs
134134
| STATS message = FIRST(message, @timestamp) BY system
135135
;
136136

137-
message:text | system:keyword
137+
message:keyword | system:keyword
138138
Pinging 192.168.86.046 | ping
139139
Running cats (cycle 1) | cron
140140
Doing java stuff for 192.168.86.038 | java

x-pack/plugin/esql/qa/testFixtures/src/main/resources/stats_last.csv-spec

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,7 @@ FROM logs
134134
| STATS message = LAST(message, @timestamp) BY system
135135
;
136136

137-
message:text | system:keyword
137+
message:keyword | system:keyword
138138
No response | ping
139139
Running cats (cycle 3) | cron
140140
More java stuff | java

0 commit comments

Comments
 (0)