I'm trying to write a simple filter function (to be used with the FILTER operator) in python, but I don't seem to find the right way to specify its schema. I'm using pig 0.9.2.
The filter's code is (trivially):
What's the right way of annotating it so that pig understands it returns a boolean?
I've tried with:
- @outputSchema("b:boolean") but this causes :
ERROR 1200: <line 1, column 2> Syntax error, unexpected symbol at or near 'boolean
- @outputSchema("b:int") is also rejected (as expected):
<file pdns-long-nxdomains.pig, line 9, column 17> Filter's condition must evaluate to boolean. Found: int