Skip to content

Commit 7d0f7a2

Browse files
committed
Fixes Metastore Parquet table conversion
1 parent a1896c7 commit 7d0f7a2

File tree

6 files changed

+288
-131
lines changed

6 files changed

+288
-131
lines changed

sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -303,8 +303,9 @@ class SQLContext(@transient val sparkContext: SparkContext)
303303
*
304304
* @group userf
305305
*/
306-
def parquetFile(path: String): DataFrame =
307-
baseRelationToDataFrame(parquet.ParquetRelation2(path, Map("path" -> path))(this))
306+
@scala.annotation.varargs
307+
def parquetFile(paths: String*): DataFrame =
308+
baseRelationToDataFrame(parquet.ParquetRelation2(paths, Map.empty)(this))
308309

309310
/**
310311
* Loads a JSON file (one object per line), returning the result as a [[DataFrame]].

0 commit comments

Comments
 (0)