Thanks Prashant, Russel. I was PigStorage while loading tab delimited file. Now its running fine.
Regards, Dipesh On May 10, 2012 11:00 AM, "Prashant Kommireddi" <[email protected]> wrote: > I messed up, your original UDF does not need to be changed. > > Just pass in all fields (*) as I suggested in my previous email, and access > them the way you were doing it before: > String query = (String)input.get(0); > String query1 = (String)input.get(1); > > That should work. > > -Prashant > > > On Wed, May 9, 2012 at 7:00 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 > > >
