Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Avro >> mail # user >> Avro Input > Text output MapReduce new Avro API


Copy link to this message
-
Re: Avro Input > Text output MapReduce new Avro API
DSuiter RDX <[EMAIL PROTECTED]> writes:

> protected void map(AvroKey<Event> key, Iterable<NullWritable> values,
> Context context) throws IOException, InterruptedException {

It looks like your `map()` method doesn’t have the right type signature,
seemingly following what’s necessary for `Reducer#reduce()` instead.
Without an `@Override` annotation, I believe this is silently defining a
separate `map()` method with a different type signature, leaving the
default pass-through `Mapper#map()` as-in.

-Marshall