Skip to content

Commit 5598efc

Browse files
committed
Uses ParquetInputFormat[InternalRow] instead of ParquetInputFormat[Row]
1 parent ff32cd0 commit 5598efc

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/parquet/newParquet.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -308,7 +308,7 @@ private[sql] class ParquetRelation2(
308308

309309
// Overridden so we can inject our own cached files statuses.
310310
override def getPartitions: Array[SparkPartition] = {
311-
val inputFormat = new ParquetInputFormat[Row] {
311+
val inputFormat = new ParquetInputFormat[InternalRow] {
312312
override def listStatus(jobContext: JobContext): JList[FileStatus] = {
313313
if (cacheMetadata) cachedStatuses else super.listStatus(jobContext)
314314
}

0 commit comments

Comments
 (0)