Skip to content
Prev Previous commit
Next Next commit
addressed review comments
  • Loading branch information
kiszk committed Nov 7, 2016
commit e96742ed925549be8a297376da3de6b7b9856e2b
Original file line number Diff line number Diff line change
Expand Up @@ -1743,7 +1743,7 @@ class DataFrameSuite extends QueryTest with SharedSQLContext {
val widePlus2 = widePlus.withColumn("d_rank", lit(0))
widePlus2.createOrReplaceTempView("wide_plus2")

// union operation in this SQL involves computation of hash for a row
// HashAggregate operation in this SQL union operator involves computation of hash for a row
val df = spark.sqlContext.sql("select * from wide_plus union select * from wide_plus2")
df.count
}
Expand Down