apache-pig

    1

    1답변

    그래서 다음 입력을 사용하여 돼지로부터이 출력을 얻는 방법. 이는 내가 사용해야하는 명령 입력 : 10/3/2013 1200 10/4/2013 0000 예상 출력 : Monday Morning Tuesday Evening

    0

    1답변

    Apache Pig에서 Foreach 문을 사용하여 열이 생성되지 않도록하는 방법이 있습니까? 예 : part = FOREACH part GENERATE (NOT $3); 'part'라는 관계에 5라는 열이있는 경우 '$ 3'을 제외한 모든 열을 생성하고 싶습니다. 그런 식으로 있나요? 미리 감사드립니다.

    0

    1답변

    나는 두 개의 CSV 파일을했습니다와 돼지 두 관계에 참여하는 방법 : 1 Fertiltiy.csv : 2 생명 Expectency.csv : 을 결과가 다음과 같이되도록 돼지에 가입하고 싶습니다. 나는 돼지에 새로운 오전 , 나는 정답을 얻을 수 있지만, 여기에 내 코드 없습니다 : : 여기 fertility = LOAD 'fertility' USING

    0

    1답변

    문제가 발생했습니다. 기본 영역이 전역으로 실행되기 때문에 DataProcPigOperator 코드를 생성 할 것입니다.하지만 DataProcPigOperator가 글로벌 영역을 실행하는 기본 작업이기 때문에 asia-easth1 코드가 실행되지 않는 클러스터에서 정의 영역을 변경합니다. 어떤 해결책이 .. ?? t1 = DataProcPigOperator

    0

    1답변

    나는 보행자가 취한 총 스텝 수와 가장 높은 스텝 수를 세는 데 성공적인 스크립트를 작성했습니다. 내가 얻지 못하는 것은 돼지 산출물에 머리말을내는 것이므로 출력물이 깔끔하고 깨끗하게 보입니다. 출력을 쓰는 동안 헤더를 생성 할 수있는 방법이 있습니까? 내 코드는 다음, 내 출력 register 'piggybank-0.15.0.jar'; DEFINE CS

    0

    1답변

    돼지에 두 개의 데이터 객체가 있습니다. 데이터 1 : col_a: chararray, col_b: int, col_c: int, col_d: chararray 데이터 2 : 내가 두 사람을 가입하려는 col_a: chararray, col_b: chararray, col_c: int, col_d: int, col_e: int , 나는

    0

    1답변

    저는 redcount, greencount 및 bluecount의 세 변수가 있습니다 (이미 같은 돼지 프로그램에서 계산되었습니다). 그 값을 비교하고 세 가지 중 큰 것을 이름과 함께 표시하려고합니다. 기존 코드 countryflags = LOAD '/home/rahul/countryprojectdata/Country.txt' USING PigStorag

    0

    1답변

    나는 돼지 라틴어로 코드를 작성하고 출력을 하이브 테이블에 저장하려고합니다. 나는 스키마 create table pedestrian_count(sensor_id INT, sensor_name STRING, total_hourly_counts BIGINT, highest_count INT) ROW FORMAT DELIMITED FIELDS TERMINAT

    0

    1답변

    돼지 스크립트를 실행하는 동안 오류 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답변

    내가 작성한 돼지 스크립트는 4GB의 데이터를 로컬에서 실행하지만 EMR 클러스터에서 실행하려고하면 statement.Below가 특정 그룹에 걸려있다. 나는 점점 오전 오류 ... at org.apache.tez.dag.app.dag.impl.VertexImpl$NoOpVertexManager.onVertexStateUpdated(VertexImpl.ja