CREATE EXTERNAL TABLE tandem.hbaselogparsed(

host string,

action string,

scope string,

request string,

status string,

user string,

timestamp string,

client string

)

STORED AS TEXTFILE

LOCATION '/data/camus/topics/xxxxx';

add jar /xxx/xx/xxx/transform.jar;

insert overwrite table tandem.hbaselogparsed SELECT TRANSFORM(log) USING "java -cp transform.jar com.yhd.LogMapper" AS host,action,scope,request,status,user,timestamp,client from tandem.hbase_log;