@@ -324,7 +324,7 @@ public void testStatsWithoutAggsOrGroup() {
324
324
}
325
325
326
326
public void testAggsWithGroupKeyAsAgg () {
327
- var queries = new String []{ """
327
+ var queries = new String [] { """
328
328
row a = 1, b = 2
329
329
| stats a by a
330
330
""" , """
@@ -337,7 +337,7 @@ public void testAggsWithGroupKeyAsAgg() {
337
337
""" , """
338
338
row a = 1, b = 2
339
339
| stats x = a by a
340
- """ };
340
+ """ };
341
341
342
342
for (String query : queries ) {
343
343
expectVerificationError (query , "grouping key [a] already specified in the STATS BY clause" );
@@ -683,16 +683,16 @@ public void testInvalidQuotingAsLookupIndexPattern() {
683
683
}
684
684
685
685
public void testIdentifierAsFieldName () {
686
- String [] operators = new String []{ "==" , "!=" , ">" , "<" , ">=" , "<=" };
687
- Class <?>[] expectedOperators = new Class <?>[]{
686
+ String [] operators = new String [] { "==" , "!=" , ">" , "<" , ">=" , "<=" };
687
+ Class <?>[] expectedOperators = new Class <?>[] {
688
688
Equals .class ,
689
689
Not .class ,
690
690
GreaterThan .class ,
691
691
LessThan .class ,
692
692
GreaterThanOrEqual .class ,
693
- LessThanOrEqual .class };
694
- String [] identifiers = new String []{ "abc" , "`abc`" , "ab_c" , "a.b.c" , "@a" , "a.@b" , "`a@b.c`" };
695
- String [] expectedIdentifiers = new String []{ "abc" , "abc" , "ab_c" , "a.b.c" , "@a" , "a.@b" , "a@b.c" };
693
+ LessThanOrEqual .class };
694
+ String [] identifiers = new String [] { "abc" , "`abc`" , "ab_c" , "a.b.c" , "@a" , "a.@b" , "`a@b.c`" };
695
+ String [] expectedIdentifiers = new String [] { "abc" , "abc" , "ab_c" , "a.b.c" , "@a" , "a.@b" , "a@b.c" };
696
696
LogicalPlan where ;
697
697
for (int i = 0 ; i < operators .length ; i ++) {
698
698
for (int j = 0 ; j < identifiers .length ; j ++) {
@@ -848,7 +848,7 @@ public void testSingleLineComments() {
848
848
}
849
849
850
850
public void testNewLines () {
851
- String [] delims = new String []{ "" , "\r " , "\n " , "\r \n " };
851
+ String [] delims = new String [] { "" , "\r " , "\n " , "\r \n " };
852
852
Function <String , String > queryFun = d -> d + "from " + d + " foo " + d + "| eval " + d + " x = concat(bar, \" baz\" )" + d ;
853
853
LogicalPlan reference = statement (queryFun .apply (delims [0 ]));
854
854
for (int i = 1 ; i < delims .length ; i ++) {
@@ -2722,13 +2722,13 @@ public void testNamedFunctionArgumentNotInMap() {
2722
2722
2723
2723
public void testNamedFunctionArgumentNotConstant () {
2724
2724
Map <String , String []> commands = Map .ofEntries (
2725
- Map .entry ("eval x = {}" , new String []{ "31" , "35" }),
2726
- Map .entry ("where {}" , new String []{ "28" , "32" }),
2727
- Map .entry ("stats {}" , new String []{ "28" , "32" }),
2728
- Map .entry ("stats agg() by {}" , new String []{ "37" , "41" }),
2729
- Map .entry ("sort {}" , new String []{ "27" , "31" }),
2730
- Map .entry ("dissect {} \" %{bar}\" " , new String []{ "30" , "34" }),
2731
- Map .entry ("grok {} \" %{WORD:foo}\" " , new String []{ "27" , "31" })
2725
+ Map .entry ("eval x = {}" , new String [] { "31" , "35" }),
2726
+ Map .entry ("where {}" , new String [] { "28" , "32" }),
2727
+ Map .entry ("stats {}" , new String [] { "28" , "32" }),
2728
+ Map .entry ("stats agg() by {}" , new String [] { "37" , "41" }),
2729
+ Map .entry ("sort {}" , new String [] { "27" , "31" }),
2730
+ Map .entry ("dissect {} \" %{bar}\" " , new String [] { "30" , "34" }),
2731
+ Map .entry ("grok {} \" %{WORD:foo}\" " , new String [] { "27" , "31" })
2732
2732
);
2733
2733
2734
2734
for (Map .Entry <String , String []> command : commands .entrySet ()) {
@@ -3091,7 +3091,7 @@ public void testInvalidFork() {
3091
3091
}
3092
3092
3093
3093
public void testFieldNamesAsCommands () throws Exception {
3094
- String [] keywords = new String []{
3094
+ String [] keywords = new String [] {
3095
3095
"dissect" ,
3096
3096
"drop" ,
3097
3097
"enrich" ,
@@ -3104,7 +3104,7 @@ public void testFieldNamesAsCommands() throws Exception {
3104
3104
"mv_expand" ,
3105
3105
"rename" ,
3106
3106
"sort" ,
3107
- "stats" };
3107
+ "stats" };
3108
3108
for (String keyword : keywords ) {
3109
3109
var plan = statement ("FROM test | STATS avg(" + keyword + ")" );
3110
3110
var aggregate = as (plan , Aggregate .class );
@@ -3154,7 +3154,7 @@ public void testValidRrf() {
3154
3154
}
3155
3155
3156
3156
public void testUnclosedParenthesis () {
3157
- String [] queries = { "row a = )" , "row ]" , "from source | eval x = [1,2,3]]" };
3157
+ String [] queries = { "row a = )" , "row ]" , "from source | eval x = [1,2,3]]" };
3158
3158
for (String q : queries ) {
3159
3159
expectError (q , "Invalid query" );
3160
3160
}
0 commit comments