Skip to content

Commit 1828571

Browse files
committed
Update comments and rename files.
1 parent fcb2ccb commit 1828571

File tree

6 files changed

+16
-18
lines changed

6 files changed

+16
-18
lines changed

sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/orc/OrcFilterSuite.scala

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,10 @@ import org.apache.spark.sql.types._
3434

3535
/**
3636
* A test suite that tests Apache ORC filter API based filter pushdown optimization.
37+
* OrcFilterSuite and HiveOrcFilterSuite is logically duplicated to provide the same test coverage.
38+
* The difference are the packages containing 'Predicate' and 'SearchArgument' classes.
39+
* - OrcFilterSuite uses 'org.apache.orc.storage.ql.io.sarg' package.
40+
* - HiveOrcFilterSuite uses 'org.apache.hadoop.hive.ql.io.sarg' package.
3741
*/
3842
class OrcFilterSuite extends OrcTest with SharedSQLContext {
3943

@@ -287,11 +291,6 @@ class OrcFilterSuite extends OrcTest with SharedSQLContext {
287291

288292
test("filter pushdown - combinations with logical operators") {
289293
withOrcDataFrame((1 to 4).map(i => Tuple1(Option(i)))) { implicit df =>
290-
// Because `ExpressionTree` is not accessible at Hive 1.2.x, this should be checked
291-
// in string form in order to check filter creation including logical operators
292-
// such as `and`, `or` or `not`. So, this function uses `SearchArgument.toString()`
293-
// to produce string expression and then compare it to given string expression below.
294-
// This might have to be changed after Hive version is upgraded.
295294
checkFilterPredicate(
296295
'_1.isNotNull,
297296
"leaf-0 = (IS_NULL _1), expr = (not leaf-0)"

sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/orc/OrcTest.scala

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -31,16 +31,16 @@ import org.apache.spark.sql.test.SQLTestUtils
3131
/**
3232
* OrcTest
3333
* -> OrcSuite
34-
* -> OrcSourceSuite
35-
* -> HiveOrcSourceSuite
34+
* -> org.apache.spark.sql.execution.datasources.orc.OrcSourceSuite
35+
* -> org.apache.spark.sql.hive.orc.OrcSourceSuite
3636
* -> OrcQueryTests
37-
* -> OrcQuerySuite
38-
* -> HiveOrcQuerySuite
37+
* -> org.apache.spark.sql.execution.datasources.orc.OrcQuerySuite
38+
* -> org.apache.spark.sql.hive.orc.OrcQuerySuite
3939
* -> OrcPartitionDiscoveryTest
40-
* -> OrcPartitionDiscoverySuite
41-
* -> HiveOrcPartitionDiscoverySuite
42-
* -> OrcFilterSuite
43-
* -> HiveOrcFilterSuite
40+
* -> org.apache.spark.sql.execution.datasources.orc.OrcPartitionDiscoverySuite
41+
* -> org.apache.spark.sql.hive.orc.OrcPartitionDiscoverySuite
42+
* -> org.apache.spark.sql.execution.datasources.orc.OrcFilterSuite
43+
* -> org.apache.spark.sql.hive.orc.OrcFilterSuite
4444
*/
4545
abstract class OrcTest extends QueryTest with SQLTestUtils with BeforeAndAfterAll {
4646
import testImplicits._

sql/hive/src/test/scala/org/apache/spark/sql/hive/orc/HiveOrcFilterSuite.scala renamed to sql/hive/src/test/scala/org/apache/spark/sql/hive/orc/OrcFilterSuite.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,13 +31,12 @@ import org.apache.spark.sql.catalyst.planning.PhysicalOperation
3131
import org.apache.spark.sql.execution.datasources.{DataSourceStrategy, HadoopFsRelation, LogicalRelation}
3232
import org.apache.spark.sql.execution.datasources.orc.OrcTest
3333
import org.apache.spark.sql.hive.test.TestHiveSingleton
34-
import org.apache.spark.sql.internal.SQLConf.ORC_IMPLEMENTATION
3534
import org.apache.spark.sql.types._
3635

3736
/**
3837
* A test suite that tests Hive ORC filter API based filter pushdown optimization.
3938
*/
40-
class HiveOrcFilterSuite extends OrcTest with TestHiveSingleton {
39+
class OrcFilterSuite extends OrcTest with TestHiveSingleton {
4140

4241
override val orcImp: String = "hive"
4342

sql/hive/src/test/scala/org/apache/spark/sql/hive/orc/HiveOrcPartitionDiscoverySuite.scala renamed to sql/hive/src/test/scala/org/apache/spark/sql/hive/orc/OrcPartitionDiscoverySuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,6 @@ package org.apache.spark.sql.hive.orc
2020
import org.apache.spark.sql.execution.datasources.orc.OrcPartitionDiscoveryTest
2121
import org.apache.spark.sql.hive.test.TestHiveSingleton
2222

23-
class HiveOrcPartitionDiscoverySuite extends OrcPartitionDiscoveryTest with TestHiveSingleton {
23+
class OrcPartitionDiscoverySuite extends OrcPartitionDiscoveryTest with TestHiveSingleton {
2424
override val orcImp: String = "hive"
2525
}

sql/hive/src/test/scala/org/apache/spark/sql/hive/orc/HiveOrcQuerySuite.scala renamed to sql/hive/src/test/scala/org/apache/spark/sql/hive/orc/OrcQuerySuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ import org.apache.spark.sql.hive.HiveUtils
2525
import org.apache.spark.sql.hive.test.TestHiveSingleton
2626
import org.apache.spark.sql.internal.SQLConf
2727

28-
class HiveOrcQuerySuite extends OrcQueryTest with TestHiveSingleton {
28+
class OrcQuerySuite extends OrcQueryTest with TestHiveSingleton {
2929
import testImplicits._
3030

3131
override val orcImp: String = "hive"

sql/hive/src/test/scala/org/apache/spark/sql/hive/orc/HiveOrcSourceSuite.scala renamed to sql/hive/src/test/scala/org/apache/spark/sql/hive/orc/OrcSourceSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ import org.apache.spark.sql.execution.datasources.orc.OrcSuite
2424
import org.apache.spark.sql.hive.test.TestHiveSingleton
2525
import org.apache.spark.util.Utils
2626

27-
class HiveOrcSourceSuite extends OrcSuite with TestHiveSingleton {
27+
class OrcSourceSuite extends OrcSuite with TestHiveSingleton {
2828

2929
override val orcImp: String = "hive"
3030

0 commit comments

Comments
 (0)