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


Hi,

I have three constant udfs in jython:

@outputSchema("m:map[bag{tuple()}]")
def dummy1():
    return {"key":[("value1", "value2")]}

@outputSchema("m:map[tuple()]")
def dummy2():
    return {"key":("value1", "value2")}

# doesn't work!
@outputSchema("m:map[bag{}]")
def dummy3():
    return {"key":["value1", "value2"]}
The first two are fine. The last one which returns a map whose values
are lists does not work.  (I am getting ClassCastException:
java.lang.String cannot be cast to org.apache.pig.data.Tuple).
Could somebody explain why?

Thanks,

stan
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