Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/19871#discussion_r154580498
--- Diff:
sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveStrategies.scala ---
@@ -195,8 +195,18 @@ case class RelationConversions(
.convertToLogicalRelation(relation, options,
classOf[ParquetFileFormat], "parquet")
} else {
val options = relation.tableMeta.storage.properties
- sessionCatalog.metastoreCatalog
- .convertToLogicalRelation(relation, options,
classOf[OrcFileFormat], "orc")
+ if (conf.getConf(SQLConf.ORC_USE_NEW_VERSION)) {
+ sessionCatalog.metastoreCatalog.convertToLogicalRelation(
+ relation,
+ options,
+
classOf[org.apache.spark.sql.execution.datasources.orc.OrcFileFormat],
+ "orc")
+ } else {
+ sessionCatalog.metastoreCatalog.convertToLogicalRelation(
+ relation,
+ options,
+ classOf[org.apache.spark.sql.hive.orc.OrcFileFormat], "orc")
--- End diff --
indents.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
