viirya commented on a change in pull request #34857:
URL: https://github.com/apache/spark/pull/34857#discussion_r767322823
##########
File path:
sql/core/src/test/scala/org/apache/spark/sql/connector/DataSourceV2SQLSuite.scala
##########
@@ -407,6 +407,44 @@ class DataSourceV2SQLSuite
}
}
+ test("SPARK-34857: CreateTableAsSelect partitions can be specified using " +
+ "PARTITIONED BY and/or CLUSTERED BY") {
+ val identifier = "testcat.table_name"
+ withTable(identifier) {
+ spark.sql(s"CREATE TABLE $identifier USING foo PARTITIONED BY (id) " +
+ s"CLUSTERED BY (data) INTO 4 BUCKETS AS SELECT * FROM source")
+ val describe = spark.sql(s"DESCRIBE $identifier")
+ val part1 = describe
+ .filter("col_name = 'Part 0'")
+ .select("data_type").head.getString(0)
+ assert(part1 === "id")
+ val part2 = describe
+ .filter("col_name = 'Part 1'")
+ .select("data_type").head.getString(0)
+ assert(part2 === "bucket(4, data)")
+ }
+ }
+
+ test("SPARK-34857: ReplaceTableAsSelect partitions can be specified using " +
Review comment:
SPARK-34857?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
