Skip to content

Instantly share code, notes, and snippets.

@takeru
Created September 10, 2010 04:50
Show Gist options
  • Select an option

  • Save takeru/573115 to your computer and use it in GitHub Desktop.

Select an option

Save takeru/573115 to your computer and use it in GitHub Desktop.
% diff -r elastic-mapreduce-ruby elastic-mapreduce-ruby.ORIG
diff -r elastic-mapreduce-ruby/elastic-mapreduce elastic-mapreduce-ruby.ORIG/elastic-mapreduce
308,309c308
< #set_step_opt_value.call( "--input INPUT", "Input to the steps, e.g. s3n://mybucket/input", :input, ['streaming'])
< set_step_opt_append.call("--input INPUT", "Input to the steps, e.g. s3n://mybucket/input", :input, ['streaming'])
---
> set_step_opt_value.call( "--input INPUT", "Input to the steps, e.g. s3n://mybucket/input", :input, ['streaming'])
316,317c315
< set_step_opt_value.call( "--partitioner PARTITIONER", "Specify partitioner", :partitioner, ['streaming'])
<
---
>
771,775d768
< if step_options[:input] then
< for i in step_options[:input] do
< stream_options << "-input" << i
< end
< end
799c792
< # "-input", step_options[:input] || "s3n://elasticmapreduce/samples/wordcount/input",
---
> "-input", step_options[:input] || "s3n://elasticmapreduce/samples/wordcount/input",
806,808d798
< if step_options[:partitioner]
< step["HadoopJarStep"]["Args"] += ["-partitioner", step_options[:partitioner]]
< end
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment