Skip to content

Commit 3b2e2b6

Browse files
committed
support table.star
1 parent bdc5c16 commit 3b2e2b6

File tree

2 files changed

+11
-0
lines changed

2 files changed

+11
-0
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/SqlParser.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -365,6 +365,7 @@ class SqlParser extends AbstractSparkSQLParser with DataTypeParser {
365365

366366
protected lazy val baseExpression: Parser[Expression] =
367367
( "*" ^^^ UnresolvedStar(None)
368+
| ident <~ "." ~ "*" ^^ { case tableName => UnresolvedStar(Option(tableName)) }
368369
| primary
369370
)
370371

sql/core/src/test/scala/org/apache/spark/sql/SQLQuerySuite.scala

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,16 @@ class SQLQuerySuite extends QueryTest with BeforeAndAfterAll {
4646
Row("1", 1) :: Row("2", 1) :: Row("3", 1) :: Nil)
4747
}
4848

49+
test("support table.star") {
50+
checkAnswer(
51+
sql(
52+
"""
53+
|SELECT r.*
54+
|FROM testData l join testData2 r on (l.key = r.a)
55+
""".stripMargin),
56+
Row(1, 1) :: Row(1, 2) :: Row(2, 1) :: Row(2, 2) :: Row(3, 1) :: Row(3, 2) :: Nil)
57+
}
58+
4959
test("self join with alias in agg") {
5060
Seq(1,2,3)
5161
.map(i => (i, i.toString))

0 commit comments

Comments
 (0)