code: function executeJob (options, opType, callback) {
    var job = client.query(options.namespace, options.set, options.statement)
    var stream = job.execute()
    stream.on('data', function (record) {
      // count the records returned
      intervalData[opType][TPS]++
    })
    stream.on('error', function (error) {
      intervalData[opType][ERROR]++
      if (error.code === status.ERR_TIMEOUT) {
        intervalData[opType][TIMEOUT]++
      }
    })
    stream.on('end', function () {
      // update a stat for number of jobs completed.
      callback(options)
    })
  }
docs: /*
  Execute the long running job.