File tree Expand file tree Collapse file tree
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -368,12 +368,11 @@ abstract class PartitioningAwareFileCatalog(
368368 if (partitionPruningPredicates.nonEmpty) {
369369 val predicate = partitionPruningPredicates.reduce(expressions.And )
370370
371- val boundPredicate = InterpretedPredicate .create(
372- predicate.transform {
373- case a : AttributeReference =>
374- val index = partitionColumns.indexWhere(a.name == _.name)
375- BoundReference (index, partitionColumns(index).dataType, nullable = true )
376- })
371+ val boundPredicate = InterpretedPredicate .create(predicate.transform {
372+ case a : AttributeReference =>
373+ val index = partitionColumns.indexWhere(a.name == _.name)
374+ BoundReference (index, partitionColumns(index).dataType, nullable = true )
375+ })
377376
378377 val selected = partitions.filter {
379378 case PartitionDirectory (values, _) => boundPredicate(values)
You can’t perform that action at this time.
0 commit comments