Skip to content

Commit

Permalink
[DOC] Correct method name
Browse files Browse the repository at this point in the history
MR Job class provides a `setOutputFormatClass` not `setOutputFormat` method
Fix #324
  • Loading branch information
costin committed Dec 10, 2014
1 parent e5fb74b commit 989eb8c
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions README.md
Expand Up @@ -124,7 +124,7 @@ Configuration conf = new Configuration();
conf.set("es.resource", "radio/artists");
conf.set("es.query", "?q=me*"); // replace this with the relevant query
Job job = new Job(conf)
job.setInputFormat(EsInputFormat.class);
job.setInputFormatClass(EsInputFormat.class);
...
job.waitForCompletion(true);
```
Expand All @@ -133,7 +133,7 @@ job.waitForCompletion(true);
Configuration conf = new Configuration();
conf.set("es.resource", "radio/artists"); // index or indices used for storing data
Job job = new Job(conf)
job.setOutputFormat(EsOutputFormat.class);
job.setOutputFormatClass(EsOutputFormat.class);
...
job.waitForCompletion(true);
```
Expand Down
4 changes: 2 additions & 2 deletions docs/src/reference/asciidoc/core/mr.adoc
Expand Up @@ -177,7 +177,7 @@ conf.setBoolean("mapred.reduce.tasks.speculative.execution", false); <2>
conf.set("es.nodes", "es-server:9200");
conf.set("es.resource", "radio/artists"); <3>
Job job = new Job(conf);
job.setOutputFormat(EsOutputFormat.class);
job.setOutputFormatClass(EsOutputFormat.class);
job.setMapOutputValueClass(MapWritable.class); <4>
...
job.waitForCompletion(true);
Expand Down Expand Up @@ -320,7 +320,7 @@ Configuration conf = new Configuration();
conf.set("es.resource", "radio/artists/"); <1>
conf.set("es.query", "?q=me*"); <2>
Job job = new Job(conf);
job.setInputFormat(EsInputFormat.class);
job.setInputFormatClass(EsInputFormat.class);
job.setMapOutputKeyClass(Text.class);
job.setMapOutputValueClass(MapWritable.class); <3>
...
Expand Down

0 comments on commit 989eb8c

Please sign in to comment.