File tree Expand file tree Collapse file tree 2 files changed +2
-3
lines changed
main/scala/org/apache/spark/sql/catalyst/expressions
test/scala/org/apache/spark/sql/catalyst/csv Expand file tree Collapse file tree 2 files changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -78,8 +78,7 @@ case class CsvToStructs(
78
78
@ transient
79
79
lazy val converter = (rows : Iterator [InternalRow ]) => {
80
80
if (rows.hasNext) {
81
- rows.next()
82
- val result = rows.next
81
+ val result = rows.next()
83
82
// CSV's parser produces one record only.
84
83
assert(! rows.hasNext)
85
84
result
Original file line number Diff line number Diff line change @@ -19,7 +19,7 @@ package org.apache.spark.sql.catalyst.csv
19
19
20
20
import org .apache .spark .SparkFunSuite
21
21
22
- class CSVExpressionUtilsSuite extends SparkFunSuite {
22
+ class CSVExprUtilsSuite extends SparkFunSuite {
23
23
test(" Can parse escaped characters" ) {
24
24
assert(CSVExprUtils .toChar(""" \t""" ) === '\t ' )
25
25
assert(CSVExprUtils .toChar(""" \r""" ) === '\r ' )
You can’t perform that action at this time.
0 commit comments