Skip to content

Commit c4a1de0

Browse files
committed
Don't inherit from csv.CsvContext.
1 parent 674672d commit c4a1de0

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/scala/com/databricks/spark/csv/rdd/package.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ import org.apache.spark.sql.catalyst.ScalaReflection
66
import org.apache.spark.sql.types.StructType
77

88
package object rdd {
9-
implicit class CsvContextRDD(sqlContext: SQLContext) extends CsvContext(sqlContext) {
9+
implicit class CsvContextRDD(sqlContext: SQLContext) {
1010
def csvFileToRDD[T: scala.reflect.runtime.universe.TypeTag : scala.reflect.ClassTag](
1111
filePath: String,
1212
useHeader: Boolean = true,
@@ -19,7 +19,7 @@ package object rdd {
1919
throw new IllegalArgumentException(s"permissive mode is invalid for this method")
2020

2121
val schema = ScalaReflection.schemaFor[T].dataType.asInstanceOf[StructType]
22-
val df = csvFile(filePath, useHeader, delimiter, quote, escape, mode, Some(schema))
22+
val df = new CsvContext(sqlContext).csvFile(filePath, useHeader, delimiter, quote, escape, mode, Some(schema))
2323
df.mapPartitions[T] { iter =>
2424
val rowConverter = RowConverter[T]()
2525
iter.map { row => rowConverter.convert(row) }

0 commit comments

Comments
 (0)