Skip to content

Commit dcff9bd

Browse files
Cleanups.
1 parent 84301a4 commit dcff9bd

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveMetastoreCatalog.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -271,6 +271,7 @@ private[hive] case class MetastoreRelation
271271

272272
// TODO: are there any stats in hiveQlTable.getSkewedInfo that we can use?
273273
@transient override lazy val estimates = new Estimates {
274+
// TODO: check if this estimate is valid for tables after partition pruning.
274275
// Size getters adapted from SizeBasedBigTableSelectorForAutoSMJ.java in Hive (version 0.13).
275276
override lazy val sizeInBytes: Long =
276277
maybeGetSize(hiveConf, hiveQlTable.getProperty("totalSize"), path)

sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -17,14 +17,11 @@
1717

1818
package org.apache.spark.sql.hive.execution
1919

20-
import org.apache.spark.sql.execution.{BuildRight, BroadcastHashJoin}
21-
2220
import scala.util.Try
2321

24-
import org.apache.spark.sql.{SchemaRDD, Row}
25-
import org.apache.spark.sql.hive.MetastoreRelation
2622
import org.apache.spark.sql.hive.test.TestHive
2723
import org.apache.spark.sql.hive.test.TestHive._
24+
import org.apache.spark.sql.{Row, SchemaRDD}
2825

2926
case class TestData(a: Int, b: String)
3027

0 commit comments

Comments
 (0)