1. 程式人生 > >spark日期格式轉換

spark日期格式轉換

object FilterUtilsV4{

  //如果object使用了成員變數,那麼會出現執行緒安全問題,因為object是一個單例,多執行緒可以同時呼叫這個方法
  //E代表星期幾
  //val dateFormat = new SimpleDateFormat("yyyy年MM月dd日,E,HH:mm:ss")
  //FastDateFormat是執行緒安全的
  val dateFormat = FastDateFormat.getInstance("yyyy年MM月dd日,E,HH:mm:ss")

  def filterByTime(fields: Array[String], startTime: Long, endTime: Long) = {
    val time = fields(1)
    val timeLong = dateFormat.parse(time).getTime
    timeLong >= startTime && timeLong < endTime
  }
}