SparkTimerExample.scala

import org.apache.spark.groupon.metrics.UserMetricsSystem
import org.apache.spark.groupon.metrics.SparkTimer
import org.apache.spark.rdd.RDD

class SparkTimerExample[T] {
  lazy val timer: SparkTimer = UserMetricsSystem.timer("BulkPutTimer")

  def bulkPut(rdd: RDD[T]) = {
    rdd.foreachPartition(partitionOfRecords => {
      val timerCtx = timer.time()
      // perform output operation
      timerCtx.stop()
    })
  }
}