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

Switch to Threaded View
Pig >> mail # user >> InputSplit in UDF


Copy link to this message
-
Re: InputSplit in UDF
Try:

     PigSplit pigSplit ((PigSplit)((Context)PigMapReduce.sJobContext).getInputSplit());
     InputSplit is = pigSplit.getWrappedSplit();

Ashutosh

On Tue, Mar 30, 2010 at 13:52, Sandesh Devaraju <[EMAIL PROTECTED]> wrote:
> Hi All,
>
> Is there a way to get current InputSplit in a UDF (more specifically,
> a filter function)?
>
> I have a filter function that validates input rows according to
> certain criteria and I would like to report the source of failures (if
> any).
>
> Thanks in advance.
>
> - Sandesh
>