package com.github.dkanellis.skyspark.scala.api.helpers

import com.github.dkanellis.skyspark.scala.api.algorithms.Point
import org.apache.spark.SparkContext
import org.apache.spark.rdd.RDD

object TextFileToPointRdd {

  def convert(sparkContext: SparkContext, filePath: String, delimiter: String): RDD[Point] = {
    sparkContext.textFile(filePath)
      .map(pointFromTextLine(_, delimiter))
  }

  private def pointFromTextLine(textLine: String, delimiter: String) = {
    val numberArray = textLine
      .trim
      .split(delimiter)
      .map(_.toDouble)
    new Point(numberArray: _*)
  }
}

package com.github.dkanellis.skyspark.scala.api.helpers

import com.github.dkanellis.skyspark.scala.api.algorithms.Point
import org.apache.spark.SparkContext

object TextFileToPointRdd {

  def convert(sparkContext: SparkContext, filePath: String, delimiter: String) = {
    sparkContext.textFile(filePath)
      .map(pointFromTextLine(_, delimiter))
  }

  private def pointFromTextLine(textLine: String, delimiter: String) = {
    val numberArray = textLine
      .trim
      .split(delimiter)
      .map(_.toDouble)
    new Point(numberArray: _*)
  }
}

--- 
+++ 
@@ -2,10 +2,11 @@
 
 import com.github.dkanellis.skyspark.scala.api.algorithms.Point
 import org.apache.spark.SparkContext
+import org.apache.spark.rdd.RDD
 
 object TextFileToPointRdd {
 
-  def convert(sparkContext: SparkContext, filePath: String, delimiter: String) = {
+  def convert(sparkContext: SparkContext, filePath: String, delimiter: String): RDD[Point] = {
     sparkContext.textFile(filePath)
       .map(pointFromTextLine(_, delimiter))
   }
Add explicit return to file conversion
