이 게시물에는 Apache Pig에서 UDF를 만드는 데 필요한 단계가 포함되어 있습니다. 모든 UDF는 Filter 함수를 확장해야하며 Tuple을 포함하는 exec라는 메서드를 포함해야합니다. 여기에 적용된 논리는 Tuple이 null이거나 0이면 True 또는 False와 같은 부울 값을 제공한다는 것입니다. 그리고‘IsofAge’는 주어진 나이가 맞는지 확인하는 것입니다. 사용자 정의 함수의 논리는 JAR 파일이 생성 된 다음 내보내지는 Java 코드로 작성됩니다. JAR 파일은 나중에 등록됩니다. 이러한 JAR 파일은로드시 Apache Pig의 라이브러리 파일에서 찾을 수 있습니다.
자바에서 오버로딩 및 오버로딩
공용 클래스 IsOfAge extends FilterFunc { @우세하다 publicBoolean exec (Tuple tuple) throwsIOException { if (tuple == null || tuple.size () == 0) { returnfalse } 시험{ 객체 객체 = tuple.get (0) if (object == null) { returnfalse } inti = (Integer) 객체 if (i == 18 || i == 19 || i == 21 || i == 23 || i == 27) { returntrue } else { returnfalse }} catch (ExecExceptione) { thrownewIOException (e) }}}Pig UDF를 호출하는 방법?
UDF가 생성되면 다음 명령을 사용하여 JAR 파일을 등록해야합니다.
myudf.jar 등록 X = IsOfAge (age)로 필터 A
Pig에서 UDF를 만드는 단계 :
Apache Pig에는 미리 정의 된 여러 함수가 있습니다. 또한 사용자 정의 함수 (UDF)라는 자체 함수를 생성하는 기능도 있습니다. Pig UDF는 Java로 작성되었으며 미리 정의 된 클래스를 사용하려면 Pig 라이브러리가 필요합니다. Apache Pig 라이브러리 돼지 -0.8.0-cdh3u0-core.jar 다운로드 가능 인터넷에서.
HDFS 모드에서 UDF를 사용하여 Pig 스크립트를 만드는 단계를 보려면 여기를 클릭하십시오.
질문이 있으십니까? 댓글 섹션에 언급하시면 다시 연락 드리겠습니다.
관련 게시물:
프로그램 자바를 종료하는 방법
HDFS 모드에서 UDF를 사용하는 Apache Pig 스크립트
Apache Pig의 연산자 : 파트 1- 관계형 연산자
Apache Pig의 연산자 : 2 부 – 진단 연산자