Github user MaxGekk commented on a diff in the pull request: https://github.com/apache/spark/pull/22979#discussion_r235618859 --- Diff: sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/csv/CSVExprUtils.scala --- @@ -79,4 +83,22 @@ object CSVExprUtils { throw new IllegalArgumentException(s"Delimiter cannot be more than one character: $str") } } + + def getDecimalParser(useLegacyParser: Boolean, locale: Locale): String => java.math.BigDecimal = { + if (useLegacyParser) { + (s: String) => new BigDecimal(s.replaceAll(",", "")) + } else { + val df = new DecimalFormat("", new DecimalFormatSymbols(locale)) --- End diff -- renamed
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org