Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Plain View
Avro >> mail # user >> Re: 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
+
DSuiter RDX 2013-10-23, 18:59
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB