setMapOutputKeyClass() and setMapOutputValueClass() are standard
Map/Reduce functionality.  If the Mapper you use/have created has
different output types than its input types then you need to set these on
your Jobs Configuration object.  Same applies should your Reducer have
different output types than its input types.

The filter configuration is also set on the Job Configuration e.g.

job.getConfiguration().set(RdfMapReduceConstants.FILTER_SUBJECT_URIS,
"http://example.org/instance,http://example.org/anotherInstance";);

The documentation has been updated to show examples of this

Rob


On 17/02/2015 09:18, "Carmen Manzulli" <[email protected]> wrote:

>Hi,
>i have a question about jena elephas and in particular about how to
>execute
>TripleFilterBySubjectUriMapper.class; for now I've created a project with
>jena elephas dependencies and i'm implementing the main class with all
>configuration options; my doubts are about  MapOutputkeyclass and
>MapOutputValue class  and also how to set
>rdf.mapreduce.filter.subject.uris.  is this last one a command
>parameter?if
>yes, i should write a command like:
>
>bin/hadoop jar <path to my jar>file.jar  mypackage --output <path output>
>--input-type triples <path input> rdf.mapreduce.filter.subject.uris uri1
>uri2 ...etc
>
>is it right?
>
>thanks in advance,
>Carmen




Reply via email to