Skip to content

Commit b838ff8

Browse files
authored
Wildcard queries now parse the * character correctly. Update tests. (#1458)
1 parent 3b7380d commit b838ff8

File tree

2 files changed

+0
-30
lines changed

2 files changed

+0
-30
lines changed

spark/sql-13/src/itest/scala/org/elasticsearch/spark/integration/AbstractScalaEsSparkSQL.scala

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -998,11 +998,6 @@ class AbstractScalaEsScalaSparkSQL(prefix: String, readMetadata: jl.Boolean, pus
998998
val df = esDataSource("pd_starts_with")
999999
var filter = df.filter(df("airport").startsWith("O"))
10001000

1001-
if (strictPushDown) {
1002-
assertEquals(0, filter.count())
1003-
return
1004-
}
1005-
10061001
if (!keepHandledFilters) {
10071002
// term query pick field with multi values
10081003
assertEquals(2, filter.count())
@@ -1019,11 +1014,6 @@ class AbstractScalaEsScalaSparkSQL(prefix: String, readMetadata: jl.Boolean, pus
10191014
val df = esDataSource("pd_ends_with")
10201015
var filter = df.filter(df("airport").endsWith("O"))
10211016

1022-
if (strictPushDown) {
1023-
assertEquals(0, filter.count())
1024-
return
1025-
}
1026-
10271017
if (!keepHandledFilters) {
10281018
// term query pick field with multi values
10291019
assertEquals(2, filter.count())
@@ -1048,11 +1038,6 @@ class AbstractScalaEsScalaSparkSQL(prefix: String, readMetadata: jl.Boolean, pus
10481038
val df = esDataSource("pd_and")
10491039
var filter = df.filter(df("reason").isNotNull.and(df("airport").endsWith("O")))
10501040

1051-
if (strictPushDown) {
1052-
assertEquals(0, filter.count())
1053-
return
1054-
}
1055-
10561041
assertEquals(1, filter.count())
10571042
assertEquals("jan", filter.select("tag").take(1)(0)(0))
10581043
}

spark/sql-20/src/itest/scala/org/elasticsearch/spark/integration/AbstractScalaEsSparkSQL.scala

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -1055,11 +1055,6 @@ class AbstractScalaEsScalaSparkSQL(prefix: String, readMetadata: jl.Boolean, pus
10551055
val df = esDataSource("pd_starts_with")
10561056
var filter = df.filter(df("airport").startsWith("O"))
10571057

1058-
if (strictPushDown) {
1059-
assertEquals(0, filter.count())
1060-
return
1061-
}
1062-
10631058
if (!keepHandledFilters) {
10641059
// term query pick field with multi values
10651060
assertEquals(2, filter.count())
@@ -1076,11 +1071,6 @@ class AbstractScalaEsScalaSparkSQL(prefix: String, readMetadata: jl.Boolean, pus
10761071
val df = esDataSource("pd_ends_with")
10771072
var filter = df.filter(df("airport").endsWith("O"))
10781073

1079-
if (strictPushDown) {
1080-
assertEquals(0, filter.count())
1081-
return
1082-
}
1083-
10841074
if (!keepHandledFilters) {
10851075
// term query pick field with multi values
10861076
assertEquals(2, filter.count())
@@ -1105,11 +1095,6 @@ class AbstractScalaEsScalaSparkSQL(prefix: String, readMetadata: jl.Boolean, pus
11051095
val df = esDataSource("pd_and")
11061096
var filter = df.filter(df("reason").isNotNull.and(df("airport").endsWith("O")))
11071097

1108-
if (strictPushDown) {
1109-
assertEquals(0, filter.count())
1110-
return
1111-
}
1112-
11131098
assertEquals(1, filter.count())
11141099
assertEquals("jan", filter.select("tag").take(1)(0)(0))
11151100
}

0 commit comments

Comments
 (0)