蜂巢入门到剖析(二)

　　

import org.apache.Hadoop.hive.ql.exec.UDF  
　　,,,public  class  Helloword , extends  UDF {,,
　　,,,,,public  Stringevaluate () {,,
　　,,,,,,,,,,返回“hello 世界!”,,,
　　,,,,},,
　　,
　　,,,,,public  Stringevaluate (String  str) {,,
　　,,,,,,,,,,返回“世界:hello ”, +, str,,,
　　,,,,},,
　　}

<强>

<强>

<强>

<强>

<强>

<强> <强>

public  class  MyAvg  extends  UDAF  { 　　, 　　public  static  class  AvgEvaluator  implements  UDAFEvaluator  { 　　} 　　public  void  init (), {} 　　public  boolean 迭代(Double  o), {} 　　public  AvgState  terminatePartial (), {} 　　public  boolean  terminatePartial (Double  o), {,} 　　public  Double 终止(),{} 　　, 　　}

<强>

<强>

<强>

<强>

<强>

SELECT  pageid,, adid 得到pageAds  LATERAL  VIEWexplode (adid_list), adTable  AS 去;

<强>

public  class  MyUDTF  extends  GenericUDTF { 　　public  StructObjectInspector 初始化(ObjectInspector [], args), {} 　　public  void 过程(对象[],args), throws  HiveException  {,} 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null

蜂巢入门到剖析(二)