@@ -7997,14 +7997,10 @@ public void testEqualsPushdownToDelegateTooBig() {
7997
7997
}
7998
7998
7999
7999
public void testNotEqualsPushdownToDelegate () {
8000
- var optimized = optimizedPlan (
8001
- physicalPlan (
8002
- """
8003
- FROM test
8004
- | WHERE job != "v"
8005
- """ , testDataLimitedRaw
8006
- ), SEARCH_STATS_SHORT_DELEGATES
8007
- );
8000
+ var optimized = optimizedPlan (physicalPlan ("""
8001
+ FROM test
8002
+ | WHERE job != "v"
8003
+ """ , testDataLimitedRaw ), SEARCH_STATS_SHORT_DELEGATES );
8008
8004
var limit = as (optimized , LimitExec .class );
8009
8005
var exchange = as (limit .child (), ExchangeExec .class );
8010
8006
var project = as (exchange .child (), ProjectExec .class );
@@ -8014,11 +8010,16 @@ public void testNotEqualsPushdownToDelegate() {
8014
8010
var extract2 = as (filter .child (), FieldExtractExec .class );
8015
8011
var query = as (extract2 .child (), EsQueryExec .class );
8016
8012
assertThat (
8017
- query .query (), equalTo (new BoolQueryBuilder ().filter (new SingleValueQuery (
8018
- new NotQuery (Source .EMPTY , new EqualsSyntheticSourceDelegate (Source .EMPTY , "job" , "v" )),
8019
- "job" ,
8020
- SingleValueQuery .UseSyntheticSourceDelegate .YES_NEGATED
8021
- ).toQueryBuilder ()))
8013
+ query .query (),
8014
+ equalTo (
8015
+ new BoolQueryBuilder ().filter (
8016
+ new SingleValueQuery (
8017
+ new NotQuery (Source .EMPTY , new EqualsSyntheticSourceDelegate (Source .EMPTY , "job" , "v" )),
8018
+ "job" ,
8019
+ SingleValueQuery .UseSyntheticSourceDelegate .YES_NEGATED
8020
+ ).toQueryBuilder ()
8021
+ )
8022
+ )
8022
8023
);
8023
8024
}
8024
8025
0 commit comments