We are using pig with elephant-bird thrift to process structured records.
And we were writing tons of UDFs in java before and we are trying to us
Jython UDF more since it is much easier to write and deliver(no need to
compile and package.)
But I am wondering how could I refer a field by name of a tuple in Jython
For example, I have a pig like following:
register 'jython_udf.py' using jython as jython;
raw_data = load '$INPUT' using
A = FOREACH raw_data GENERATE jython.get_name(some_field)
And some_field here is a thrift structure, which may have three fields like
'name', 'gender', 'age'.
I tried to write the jython udf as the following but failed:
Looks what I got is a tuple in jython. Is there any way I could get it
through field name rather than a number of index like input.getField(0)?