.scala

def timePartition (
  data: DataFrame,
  timeCol : String,
  startTime : Long = 1404198000000L
) : Seq[DataFrame] = {
    val addTimeMilli : Long = 604800000L // Discretize time into weeks.
    val rightNowMilli : Long = new Date().getTime

    (1 to (rightNowMilli / addTimeMilli).toInt).map(k => new Timestamp(startTime + k.toLong * addTimeMilli))
    .map(time => data.filter(data(timeCol) < time))
}