class Commands::PigScriptCommand

Public Instance Methods

reorder_steps(jobflow, sc) click to toggle source
# File lib/commands.rb, line 365
def reorder_steps(jobflow, sc)
  return ensure_install_cmd(jobflow, sc, PigInteractiveCommand)
end
steps() click to toggle source
# File lib/commands.rb, line 348
def steps
  mandatory_args = [ "--run-pig-script", "--args", "-f" ]
  if @arg then
    mandatory_args << @arg
  end
  step = {
    "Name"            => get_field(:step_name, "Run Pig Script"),
    "ActionOnFailure" => get_field(:step_action, "CANCEL_AND_WAIT"),
    "HadoopJarStep"   => {
      "Jar" => get_field(:script_runner_path),
      "Args" => get_field(:pig_cmd) + mandatory_args + @args
    }
  }
  return [ step ]
end