class Hodor::Oozie::HadoopJob

Attributes

id[R]
parent_id[R]
rest_call[R]

Public Class Methods

default_columns() click to toggle source
# File lib/hodor/api/oozie/hadoop_job.rb, line 8
def default_columns
  [:index, :id]
end
new(parent_id, job_id) click to toggle source
Calls superclass method
# File lib/hodor/api/oozie/hadoop_job.rb, line 13
def initialize(parent_id, job_id)
  super()
  @id = job_id
  @parent_id = parent_id
  session.verbose = true # force verbosity for hadoop jobs
end

Public Instance Methods

log() click to toggle source
# File lib/hodor/api/oozie/hadoop_job.rb, line 20
def log
  hadoop_id = @id.sub('job_','')
  trash = hadoop_id.index(/[^0-9_]/)
  hadoop_id = hadoop_id[0..trash-1] if trash
  session.env.ssh "mapred job -logs job_#{hadoop_id} attempt_#{hadoop_id}_m_000000_0"
end