Skip to content
Prev Previous commit
Next Next commit
addressed review comments
  • Loading branch information
kiszk committed Nov 7, 2016
commit 6a57ba564f81ba9f5f04a94f2ca516fa0c441fd0
Original file line number Diff line number Diff line change
Expand Up @@ -1743,6 +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
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

nit: Actually the hash computation is happened at HashAggregate.

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks. Updated the comment

val df = spark.sqlContext.sql("select * from wide_plus union select * from wide_plus2")
df.count
}
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think you need to revert this change.

Copy link
Member Author

@kiszk kiszk Nov 7, 2016

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Sorry for my typo. It is time for me to have to sleep.

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

No problem. Happens to us all :)

Expand Down