Update code

beliefer · beliefer · commit 63d916864031 · 2021-11-29T18:57:28.000+08:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/DataSourceScanExec.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/DataSourceScanExec.scala
@@ -149,7 +149,7 @@ case class RowDataSourceScanExec(
         Map("PushedAggregates" -> seqToString(v.aggregateExpressions),
           "PushedGroupByColumns" -> seqToString(v.groupByColumns))} ++
       pushedDownOperators.limit.map(value => "PushedLimit" -> s"LIMIT $value") ++
-//      Map("PushedSortValues" -> seqToString(pushedDownOperators.sortValues)) ++
+      Map("PushedSortValues" -> seqToString(pushedDownOperators.sortValues)) ++
       pushedDownOperators.sample.map(v => "PushedSample" ->
         s"SAMPLE (${(v.upperBound - v.lowerBound) * 100}) ${v.withReplacement} SEED(${v.seed})"
       )

Original file line number	Diff line number	Diff line change
`@@ -149,7 +149,7 @@ case class RowDataSourceScanExec(`
`149`	`149`	`Map("PushedAggregates" -> seqToString(v.aggregateExpressions),`
`150`	`150`	`"PushedGroupByColumns" -> seqToString(v.groupByColumns))} ++`
`151`	`151`	`pushedDownOperators.limit.map(value => "PushedLimit" -> s"LIMIT $value") ++`
`152`		`-// Map("PushedSortValues" -> seqToString(pushedDownOperators.sortValues)) ++`
	`152`	`+ Map("PushedSortValues" -> seqToString(pushedDownOperators.sortValues)) ++`
`153`	`153`	`pushedDownOperators.sample.map(v => "PushedSample" ->`
`154`	`154`	`s"SAMPLE (${(v.upperBound - v.lowerBound) * 100}) ${v.withReplacement} SEED(${v.seed})"`
`155`	`155`	`)`