From edf49e7a0e779badd72e28e9533461ca0e53568b Mon Sep 17 00:00:00 2001 From: Cheng Lian Date: Sun, 10 May 2015 17:52:51 +0800 Subject: [PATCH] Removed commented stale code block --- .../spark/sql/sources/SimpleTextRelation.scala | 16 ---------------- 1 file changed, 16 deletions(-) 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) -// } -// } }