eyalgo
3/11/2016 - 10:57 AM

blog-applift-upgrading-spark-whitelist-get-writer.scala

def getRecordWriter(job: TaskAttemptContext) =
  format.getRecordWriter(job)