pig-udf

1열

1답변

Pig UDF Throwing 새 튜플을 생성 할 때 NullPointerException

일부 데이터를 수집 한 후 최소한의 방법으로 해당 데이터를 변환하려고하는 Pig UDF가 있습니다. my_data = LOAD 'path/to/data' USING SomeCustomLoader(); my_other_data = FOREACH my_data GENERATE MyUDF(COL_1, COL_2, $param1, $param2) as outpu

3열

2답변

다른 필드에 대해 컬럼을 카테고리 화하기 위해 돼지에서 UDF를 작성하는 방법

돼지의 UDF를 사용하여 다른 컬럼에 대해 하나의 컬럼을 카테고리 화하려고합니다. 데이터는 내가이 Id,name,age 1,jhon,31 2,adi,15 3,sam,25 4,lina,28 예상 출력 1,jhon,31,30-35 2,adi,15,10-15 3,sam,25,20-25 4,lina,28,25-30 당신은 UDF없이이 작업을 수

-1열

1답변

python에서 pigutil에서 outputSchema를 가져올 수 없습니다.

이것은 아주 기본적인 질문 일 수 있습니다. 저는 돼지와 파이썬 영역에 익숙하지 않을 수 있습니다. pigutil에서 outputSchema를 가져 오려고합니다. outputSchema는 파이썬 UDF 내에서 다음과 같이 사용됩니다 : - @outputSchema('HistorySchema:bag{t:(SomeKey:int,ScdColumnNew:chara

0열

1답변

돼지에서 UDF를 사용하는 중에 오류 1070이 발생합니다.

돼지 스크립트를 실행하는 동안 오류 2017-10-29 03:34:22,212 [main] ERROR org.apache.pig.tools.grunt.Grunt - ERROR 1200: <line 6, column 13> Syntax error, unexpected symbol at or near ''/home/harsh/Hunny/HadoopPractic

0열

1답변

돼지는 키 변경 열을 생성합니다 - 이전 레코드와 현재 레코드가 다른 열을 비교합니다

입력 한 데이터는 아래 형식으로되어 있습니다. col1 col2 col3 effective date expiry date 1 Q1 A1 Value1 01/01 01/02 2 Q1 A1 Value1 01/02 01/03 3 Q1 A1 Value1 01/03 01/05 4 Q1 A1 Value2 01/05 01/06 5 Q1 A