Skip to content

Commit 5a2f8b8

Browse files
committed
Update code
1 parent c440970 commit 5a2f8b8

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSourceStrategy.scala

+5-2
Original file line numberDiff line numberDiff line change
@@ -727,7 +727,7 @@ object DataSourceStrategy
727727
}
728728

729729
protected[sql] def translateSortOrders(sortOrders: Seq[SortOrder]): Seq[SortOrderV2] = {
730-
sortOrders.map {
730+
def translateOortOrder(sortOrder: SortOrder): Option[SortOrderV2] = sortOrder match {
731731
case SortOrder(PushableColumnWithoutNestedColumn(name), directionV1, nullOrderingV1, _) =>
732732
val directionV2 = directionV1 match {
733733
case Ascending => SortDirection.ASCENDING
@@ -737,8 +737,11 @@ object DataSourceStrategy
737737
case NullsFirst => NullOrdering.NULLS_FIRST
738738
case NullsLast => NullOrdering.NULLS_LAST
739739
}
740-
SortValue(FieldReference(name), directionV2, nullOrderingV2)
740+
Some(SortValue(FieldReference(name), directionV2, nullOrderingV2))
741+
case _ => None
741742
}
743+
744+
sortOrders.flatMap(translateOortOrder)
742745
}
743746

744747
/**

0 commit comments

Comments
 (0)