Skip to content

Commit

Permalink
Removed commented stale code block
Browse files Browse the repository at this point in the history
  • Loading branch information
liancheng committed May 12, 2015
1 parent 348a922 commit edf49e7
Showing 1 changed file with 0 additions and 16 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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)
// }
// }
}

0 comments on commit edf49e7

Please sign in to comment.