diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/sources/SimpleTextRelation.scala b/sql/hive/src/test/scala/org/apache/spark/sql/sources/SimpleTextRelation.scala index 6a5e7fbf35d69..8801aba2f64c3 100644 --- a/sql/hive/src/test/scala/org/apache/spark/sql/sources/SimpleTextRelation.scala +++ b/sql/hive/src/test/scala/org/apache/spark/sql/sources/SimpleTextRelation.scala @@ -122,20 +122,4 @@ class SimpleTextRelation( }: _*) } } - -// override def buildScan( -// requiredColumns: Array[String], -// filters: Array[Filter], -// inputPaths: Array[String]): RDD[Row] = { -// val fields = dataSchema.fields -// sparkContext.textFile(inputPaths.mkString(",")).map { record => -// val valueMap = record.split(",").zip(fields).map { -// case (value, StructField(name, dataType, _, _)) => -// name -> Cast(Literal(value), dataType).eval() -// }.toMap -// -// // This mocks a simple projection -// Row.fromSeq(requiredColumns.map(valueMap).toSeq) -// } -// } }