object JobRunner

Helper for running a job and reporting back status

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. JobRunner
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. def monitor(job: Job, reporter: StatusCallback, mapCounters: ⇒ Seq[(String, Long)], reduceCounters: ⇒ Seq[(String, Long)]): JobResult

    Monitor a job that has already been submitted

    Monitor a job that has already been submitted

    job

    job

    reporter

    status callback

    mapCounters

    map status counters

    reduceCounters

    reduce status counters (will be added to map phase if no reduce phase)

    returns

    result

  2. def run(job: Job, reporter: StatusCallback, mapCounters: ⇒ Seq[(String, Long)], reduceCounters: ⇒ Seq[(String, Long)]): JobResult

    Submit and monitor a job

    Submit and monitor a job

    job

    job

    reporter

    status callback

    mapCounters

    map status counters

    reduceCounters

    reduce status counters (will be added to map phase if no reduce phase)

    returns

    result

  3. def submit(job: Job): Unit

    Run a job asynchronously

    Run a job asynchronously

    job

    job