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 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
>
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