It seems you want to group your data, then feed this group into the UDF for processing. Look at SUM and AVG, I think, for examples?
Russell Jurney http://datasyndrome.com On May 9, 2012, at 7:01 PM, DIPESH KUMAR SINGH <[email protected]> wrote: > MapReduce job runs now, but string output of UDF is not coming. It shows > something > like this: > > (Jeff,13,) > (John,12,) > > May be something needs to be changed in output schema, i was passing > earlier: > > @Override > public Schema outputSchema(Schema input) { > return new Schema(new > Schema.FieldSchema(getSchemaName(this.getClass().getName().toLowerCase(), > input), DataType.CHARARRAY)); > } > > Thanks, > Dipesh > > On Thu, May 10, 2012 at 7:09 AM, Prashant Kommireddi > <[email protected]>wrote: > >> public List<FuncSpec> getArgToFuncMapping() throws FrontendException >> needs to be modified accordingly, since you are now passing your UDF >> the entire tuple. You don't really need to implement it if there is no >> overloaded function. >> >> Sent from my iPhone >> >> On May 9, 2012, at 6:19 PM, DIPESH KUMAR SINGH <[email protected]> >> wrote: >> >>> public List<FuncSpec> getArgToFuncMapping() throws FrontendException >> > > > > -- > Dipesh Kr. Singh
