Data : 123456A89,[datatype#int,length#10] PIG Script: REGISTER /u/******/UDF_Jars/pigUdf.jar; DEFINE validateInput mypackage.PigUDF; std = LOAD '/user/******/input1.csv' USING PigStorage(',') AS (name:chararray,val:map[]); std_exception = FOREACH std GENERATE validateInput(name,val); STORE std_exception into 'results3'; UDF exec declaration: public class PigUDF extends EvalFunc<DataBag> { @Override public DataBag exec(Tuple tuple) throws IOException { // TODO Auto-generated method stub Map<String,Object> v = (Map<String,Object>)tuple.get(1); here v is populating as null instead of {datatype=int,length=10} it works for single key-value pair. ... View more

Hi, I am able to create a table having column name with white spaces. CREATE EXTERNAL TABLE IF NOT EXISTS EXT_MILOGS(`Country of Visits` string); But when I try same thing with struct datatype CREATE EXTERNAL TABLE IF NOT EXISTS EXT_MILOGS(dimensions struct<`Country of Visits`: string>); I am not able to create the same. Am I missing something here? Thanks, Amol ... View more

hive> SELECT reflect('org.apache.commons.codec.digest.DigestUtils', 'md5Hex', '9SH305EIT'); OK e9b9227eb2983499216f76b75e5233de SELECT reflect('org.apache.commons.codec.digest.DigestUtils', 'md5Hex', col1) from table1 ; OK Failed with exception java.io.IOException:org.apache.hadoop.hive.ql.metadata.HiveException: UDFReflect getMethod ... View more