This commit is contained in:
Yin Huai 2015-08-25 23:31:50 -07:00
parent 06eb11f326
commit f4e20af107

View File

@ -124,7 +124,7 @@ class Tables(sqlContext: SQLContext, dsdgenDir: String, scaleFactor: Int) extend
| $columnString
|FROM
| $tempTableName
|DISTRIBUTED BY
|DISTRIBUTE BY
| $partitionColumnString
""".stripMargin
val grouped = sqlContext.sql(query)