Skip to content

Commit 40794d0

Browse files
nik9000nik9000
committed
Formatting
1 parent 8dfed18 commit 40794d0

File tree

6 files changed

+146
-184
lines changed

6 files changed

+146
-184
lines changed

‎x-pack/plugin/esql/src/main/generated-src/org/elasticsearch/xpack/esql/expression/function/scalar/nulls/CoalesceBooleanEvaluator.java‎

Lines changed: 24 additions & 31 deletions
Original file line numberDiff line numberDiff line change
@@ -7,10 +7,8 @@
77

88
package org.elasticsearch.xpack.esql.expression.function.scalar.nulls;
99

10-
import org.apache.lucene.util.BytesRef;
1110
import org.elasticsearch.compute.data.Block;
1211
import org.elasticsearch.compute.data.BooleanBlock;
13-
import org.elasticsearch.compute.data.ElementType;
1412
import org.elasticsearch.compute.data.Page;
1513
import org.elasticsearch.compute.operator.DriverContext;
1614
import org.elasticsearch.compute.operator.EvalOperator;
@@ -28,41 +26,36 @@
2826
* This class is generated. Edit {@code X-InEvaluator.java.st} instead.
2927
*/
3028
abstract sealed class CoalesceBooleanEvaluator implements EvalOperator.ExpressionEvaluator permits
31-
CoalesceBooleanEvaluator.CoalesceEagerEvaluator, //
32-
CoalesceBooleanEvaluator.CoalesceLazyEvaluator {
33-
static ExpressionEvaluator.Factory toEvaluator(EvaluatorMapper.ToEvaluator toEvaluator, List<Expression> children) {
34-
List<ExpressionEvaluator.Factory> childEvaluators = children.stream().map(toEvaluator::apply).toList();
35-
if (childEvaluators.stream().allMatch(ExpressionEvaluator.Factory::eagerEvalSafeInLazy)) {
36-
return new ExpressionEvaluator.Factory() {
37-
@Override
38-
public ExpressionEvaluator get(DriverContext context) {
39-
return new CoalesceEagerEvaluator(
40-
context,
41-
childEvaluators.stream().map(x -> x.get(context)).toList()
42-
);
43-
}
29+
CoalesceBooleanEvaluator.CoalesceBooleanEagerEvaluator, //
30+
CoalesceBooleanEvaluator.CoalesceBooleanLazyEvaluator {
4431

45-
@Override
46-
public String toString() {
47-
return "CoalesceEagerEvaluator[values=" + childEvaluators + ']';
48-
}
49-
};
50-
}
32+
static ExpressionEvaluator.Factory toEvaluator(EvaluatorMapper.ToEvaluator toEvaluator, List<Expression> children) {
33+
List<ExpressionEvaluator.Factory> childEvaluators = children.stream().map(toEvaluator::apply).toList();
34+
if (childEvaluators.stream().allMatch(ExpressionEvaluator.Factory::eagerEvalSafeInLazy)) {
5135
return new ExpressionEvaluator.Factory() {
5236
@Override
5337
public ExpressionEvaluator get(DriverContext context) {
54-
return new CoalesceLazyEvaluator(
55-
context,
56-
childEvaluators.stream().map(x -> x.get(context)).toList()
57-
);
38+
return new CoalesceBooleanEagerEvaluator(context, childEvaluators.stream().map(x -> x.get(context)).toList());
5839
}
5940

6041
@Override
6142
public String toString() {
62-
return "CoalesceLazyEvaluator[values=" + childEvaluators + ']';
43+
return "CoalesceBooleanEagerEvaluator[values=" + childEvaluators + ']';
6344
}
6445
};
6546
}
47+
return new ExpressionEvaluator.Factory() {
48+
@Override
49+
public ExpressionEvaluator get(DriverContext context) {
50+
return new CoalesceBooleanLazyEvaluator(context, childEvaluators.stream().map(x -> x.get(context)).toList());
51+
}
52+
53+
@Override
54+
public String toString() {
55+
return "CoalesceBooleanLazyEvaluator[values=" + childEvaluators + ']';
56+
}
57+
};
58+
}
6659

6760
protected final DriverContext driverContext;
6861
protected final List<EvalOperator.ExpressionEvaluator> evaluators;
@@ -144,13 +137,13 @@ public final void close() {
144137
* Evaluates {@code COALESCE} eagerly per position if entire-block evaluation fails.
145138
* First we evaluate all remaining evaluators, and then we pluck the first non-null
146139
* value from each one. This is <strong>much</strong> faster than
147-
* {@link CoalesceLazyEvaluator} but will include spurious warnings if any of the
140+
* {@link CoalesceBooleanLazyEvaluator} but will include spurious warnings if any of the
148141
* evaluators make them so we only use it for evaluators that are
149142
* {@link Factory#eagerEvalSafeInLazy safe} to evaluate eagerly
150143
* in a lazy environment.
151144
*/
152-
static final class CoalesceEagerEvaluator extends CoalesceBooleanEvaluator {
153-
CoalesceEagerEvaluator(DriverContext driverContext, List<EvalOperator.ExpressionEvaluator> evaluators) {
145+
static final class CoalesceBooleanEagerEvaluator extends CoalesceBooleanEvaluator {
146+
CoalesceBooleanEagerEvaluator(DriverContext driverContext, List<EvalOperator.ExpressionEvaluator> evaluators) {
154147
super(driverContext, evaluators);
155148
}
156149

@@ -192,8 +185,8 @@ protected BooleanBlock perPosition(Page page, BooleanBlock lastFullBlock, int fi
192185
* </li>
193186
* </ul>
194187
*/
195-
static final class CoalesceLazyEvaluator extends CoalesceBooleanEvaluator {
196-
CoalesceLazyEvaluator(DriverContext driverContext, List<EvalOperator.ExpressionEvaluator> evaluators) {
188+
static final class CoalesceBooleanLazyEvaluator extends CoalesceBooleanEvaluator {
189+
CoalesceBooleanLazyEvaluator(DriverContext driverContext, List<EvalOperator.ExpressionEvaluator> evaluators) {
197190
super(driverContext, evaluators);
198191
}
199192

‎x-pack/plugin/esql/src/main/generated-src/org/elasticsearch/xpack/esql/expression/function/scalar/nulls/CoalesceBytesRefEvaluator.java‎

Lines changed: 24 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,6 @@
1010
import org.apache.lucene.util.BytesRef;
1111
import org.elasticsearch.compute.data.Block;
1212
import org.elasticsearch.compute.data.BytesRefBlock;
13-
import org.elasticsearch.compute.data.ElementType;
1413
import org.elasticsearch.compute.data.Page;
1514
import org.elasticsearch.compute.operator.DriverContext;
1615
import org.elasticsearch.compute.operator.EvalOperator;
@@ -28,41 +27,36 @@
2827
* This class is generated. Edit {@code X-InEvaluator.java.st} instead.
2928
*/
3029
abstract sealed class CoalesceBytesRefEvaluator implements EvalOperator.ExpressionEvaluator permits
31-
CoalesceBytesRefEvaluator.CoalesceEagerEvaluator, //
32-
CoalesceBytesRefEvaluator.CoalesceLazyEvaluator {
33-
static ExpressionEvaluator.Factory toEvaluator(EvaluatorMapper.ToEvaluator toEvaluator, List<Expression> children) {
34-
List<ExpressionEvaluator.Factory> childEvaluators = children.stream().map(toEvaluator::apply).toList();
35-
if (childEvaluators.stream().allMatch(ExpressionEvaluator.Factory::eagerEvalSafeInLazy)) {
36-
return new ExpressionEvaluator.Factory() {
37-
@Override
38-
public ExpressionEvaluator get(DriverContext context) {
39-
return new CoalesceEagerEvaluator(
40-
context,
41-
childEvaluators.stream().map(x -> x.get(context)).toList()
42-
);
43-
}
30+
CoalesceBytesRefEvaluator.CoalesceBytesRefEagerEvaluator, //
31+
CoalesceBytesRefEvaluator.CoalesceBytesRefLazyEvaluator {
4432

45-
@Override
46-
public String toString() {
47-
return "CoalesceEagerEvaluator[values=" + childEvaluators + ']';
48-
}
49-
};
50-
}
33+
static ExpressionEvaluator.Factory toEvaluator(EvaluatorMapper.ToEvaluator toEvaluator, List<Expression> children) {
34+
List<ExpressionEvaluator.Factory> childEvaluators = children.stream().map(toEvaluator::apply).toList();
35+
if (childEvaluators.stream().allMatch(ExpressionEvaluator.Factory::eagerEvalSafeInLazy)) {
5136
return new ExpressionEvaluator.Factory() {
5237
@Override
5338
public ExpressionEvaluator get(DriverContext context) {
54-
return new CoalesceLazyEvaluator(
55-
context,
56-
childEvaluators.stream().map(x -> x.get(context)).toList()
57-
);
39+
return new CoalesceBytesRefEagerEvaluator(context, childEvaluators.stream().map(x -> x.get(context)).toList());
5840
}
5941

6042
@Override
6143
public String toString() {
62-
return "CoalesceLazyEvaluator[values=" + childEvaluators + ']';
44+
return "CoalesceBytesRefEagerEvaluator[values=" + childEvaluators + ']';
6345
}
6446
};
6547
}
48+
return new ExpressionEvaluator.Factory() {
49+
@Override
50+
public ExpressionEvaluator get(DriverContext context) {
51+
return new CoalesceBytesRefLazyEvaluator(context, childEvaluators.stream().map(x -> x.get(context)).toList());
52+
}
53+
54+
@Override
55+
public String toString() {
56+
return "CoalesceBytesRefLazyEvaluator[values=" + childEvaluators + ']';
57+
}
58+
};
59+
}
6660

6761
protected final DriverContext driverContext;
6862
protected final List<EvalOperator.ExpressionEvaluator> evaluators;
@@ -144,13 +138,13 @@ public final void close() {
144138
* Evaluates {@code COALESCE} eagerly per position if entire-block evaluation fails.
145139
* First we evaluate all remaining evaluators, and then we pluck the first non-null
146140
* value from each one. This is <strong>much</strong> faster than
147-
* {@link CoalesceLazyEvaluator} but will include spurious warnings if any of the
141+
* {@link CoalesceBytesRefLazyEvaluator} but will include spurious warnings if any of the
148142
* evaluators make them so we only use it for evaluators that are
149143
* {@link Factory#eagerEvalSafeInLazy safe} to evaluate eagerly
150144
* in a lazy environment.
151145
*/
152-
static final class CoalesceEagerEvaluator extends CoalesceBytesRefEvaluator {
153-
CoalesceEagerEvaluator(DriverContext driverContext, List<EvalOperator.ExpressionEvaluator> evaluators) {
146+
static final class CoalesceBytesRefEagerEvaluator extends CoalesceBytesRefEvaluator {
147+
CoalesceBytesRefEagerEvaluator(DriverContext driverContext, List<EvalOperator.ExpressionEvaluator> evaluators) {
154148
super(driverContext, evaluators);
155149
}
156150

@@ -193,8 +187,8 @@ protected BytesRefBlock perPosition(Page page, BytesRefBlock lastFullBlock, int
193187
* </li>
194188
* </ul>
195189
*/
196-
static final class CoalesceLazyEvaluator extends CoalesceBytesRefEvaluator {
197-
CoalesceLazyEvaluator(DriverContext driverContext, List<EvalOperator.ExpressionEvaluator> evaluators) {
190+
static final class CoalesceBytesRefLazyEvaluator extends CoalesceBytesRefEvaluator {
191+
CoalesceBytesRefLazyEvaluator(DriverContext driverContext, List<EvalOperator.ExpressionEvaluator> evaluators) {
198192
super(driverContext, evaluators);
199193
}
200194

‎x-pack/plugin/esql/src/main/generated-src/org/elasticsearch/xpack/esql/expression/function/scalar/nulls/CoalesceDoubleEvaluator.java‎

Lines changed: 24 additions & 31 deletions
Original file line numberDiff line numberDiff line change
@@ -7,10 +7,8 @@
77

88
package org.elasticsearch.xpack.esql.expression.function.scalar.nulls;
99

10-
import org.apache.lucene.util.BytesRef;
1110
import org.elasticsearch.compute.data.Block;
1211
import org.elasticsearch.compute.data.DoubleBlock;
13-
import org.elasticsearch.compute.data.ElementType;
1412
import org.elasticsearch.compute.data.Page;
1513
import org.elasticsearch.compute.operator.DriverContext;
1614
import org.elasticsearch.compute.operator.EvalOperator;
@@ -28,41 +26,36 @@
2826
* This class is generated. Edit {@code X-InEvaluator.java.st} instead.
2927
*/
3028
abstract sealed class CoalesceDoubleEvaluator implements EvalOperator.ExpressionEvaluator permits
31-
CoalesceDoubleEvaluator.CoalesceEagerEvaluator, //
32-
CoalesceDoubleEvaluator.CoalesceLazyEvaluator {
33-
static ExpressionEvaluator.Factory toEvaluator(EvaluatorMapper.ToEvaluator toEvaluator, List<Expression> children) {
34-
List<ExpressionEvaluator.Factory> childEvaluators = children.stream().map(toEvaluator::apply).toList();
35-
if (childEvaluators.stream().allMatch(ExpressionEvaluator.Factory::eagerEvalSafeInLazy)) {
36-
return new ExpressionEvaluator.Factory() {
37-
@Override
38-
public ExpressionEvaluator get(DriverContext context) {
39-
return new CoalesceEagerEvaluator(
40-
context,
41-
childEvaluators.stream().map(x -> x.get(context)).toList()
42-
);
43-
}
29+
CoalesceDoubleEvaluator.CoalesceDoubleEagerEvaluator, //
30+
CoalesceDoubleEvaluator.CoalesceDoubleLazyEvaluator {
4431

45-
@Override
46-
public String toString() {
47-
return "CoalesceEagerEvaluator[values=" + childEvaluators + ']';
48-
}
49-
};
50-
}
32+
static ExpressionEvaluator.Factory toEvaluator(EvaluatorMapper.ToEvaluator toEvaluator, List<Expression> children) {
33+
List<ExpressionEvaluator.Factory> childEvaluators = children.stream().map(toEvaluator::apply).toList();
34+
if (childEvaluators.stream().allMatch(ExpressionEvaluator.Factory::eagerEvalSafeInLazy)) {
5135
return new ExpressionEvaluator.Factory() {
5236
@Override
5337
public ExpressionEvaluator get(DriverContext context) {
54-
return new CoalesceLazyEvaluator(
55-
context,
56-
childEvaluators.stream().map(x -> x.get(context)).toList()
57-
);
38+
return new CoalesceDoubleEagerEvaluator(context, childEvaluators.stream().map(x -> x.get(context)).toList());
5839
}
5940

6041
@Override
6142
public String toString() {
62-
return "CoalesceLazyEvaluator[values=" + childEvaluators + ']';
43+
return "CoalesceDoubleEagerEvaluator[values=" + childEvaluators + ']';
6344
}
6445
};
6546
}
47+
return new ExpressionEvaluator.Factory() {
48+
@Override
49+
public ExpressionEvaluator get(DriverContext context) {
50+
return new CoalesceDoubleLazyEvaluator(context, childEvaluators.stream().map(x -> x.get(context)).toList());
51+
}
52+
53+
@Override
54+
public String toString() {
55+
return "CoalesceDoubleLazyEvaluator[values=" + childEvaluators + ']';
56+
}
57+
};
58+
}
6659

6760
protected final DriverContext driverContext;
6861
protected final List<EvalOperator.ExpressionEvaluator> evaluators;
@@ -144,13 +137,13 @@ public final void close() {
144137
* Evaluates {@code COALESCE} eagerly per position if entire-block evaluation fails.
145138
* First we evaluate all remaining evaluators, and then we pluck the first non-null
146139
* value from each one. This is <strong>much</strong> faster than
147-
* {@link CoalesceLazyEvaluator} but will include spurious warnings if any of the
140+
* {@link CoalesceDoubleLazyEvaluator} but will include spurious warnings if any of the
148141
* evaluators make them so we only use it for evaluators that are
149142
* {@link Factory#eagerEvalSafeInLazy safe} to evaluate eagerly
150143
* in a lazy environment.
151144
*/
152-
static final class CoalesceEagerEvaluator extends CoalesceDoubleEvaluator {
153-
CoalesceEagerEvaluator(DriverContext driverContext, List<EvalOperator.ExpressionEvaluator> evaluators) {
145+
static final class CoalesceDoubleEagerEvaluator extends CoalesceDoubleEvaluator {
146+
CoalesceDoubleEagerEvaluator(DriverContext driverContext, List<EvalOperator.ExpressionEvaluator> evaluators) {
154147
super(driverContext, evaluators);
155148
}
156149

@@ -192,8 +185,8 @@ protected DoubleBlock perPosition(Page page, DoubleBlock lastFullBlock, int firs
192185
* </li>
193186
* </ul>
194187
*/
195-
static final class CoalesceLazyEvaluator extends CoalesceDoubleEvaluator {
196-
CoalesceLazyEvaluator(DriverContext driverContext, List<EvalOperator.ExpressionEvaluator> evaluators) {
188+
static final class CoalesceDoubleLazyEvaluator extends CoalesceDoubleEvaluator {
189+
CoalesceDoubleLazyEvaluator(DriverContext driverContext, List<EvalOperator.ExpressionEvaluator> evaluators) {
197190
super(driverContext, evaluators);
198191
}
199192

0 commit comments

Comments
 (0)