apache-pig

0열

1답변

두 데이터 세트, data1 및 data2이 있습니다. data2 가지고 다음 데이터 a1:u:11#eve:f:6 a1:u:12#eve:f:6 a1:u2:13#eve:f:3 a1:u1:12#eve:s:6 a1:u1:11#eve:f:6 여기 :뿐만 아니라 #는 분리된다. 내가 data1와 data2에 가입 할 때 나는 아무것도 얻을, 지금, LOA

0열

1답변

돼지 및/또는 하이브에서 Chararray와 Bytearray의 차이점은 무엇입니까?

자바 char []와 byte []가 완벽하게 변환되어 동일한 권한으로 취급 될 수 있다고 가정합니까?

0열

1답변

돼지 작업을 트리거하는 셸 스크립트에서 PIG_HEAPSIZE 값을 설정하는 방법

또한이 값에 대해 최대 값을 설정할 수 있습니다. 이 플래그를 설정하는 동안 고려해야 할 전제 조건을 알려주십시오. 감사합니다.

0열

1답변

은 CSV 형식 HDFS (푸른 HDInsight)의 I 데이터를 돼지, 하이브 Sqoop을

과정을 자동화. 나는 사용하고있다 돼지 to 과정이 데이터. 처리 후 돼지요약 데이터가 하이브에 저장됩니다. 그리고 하이브 테이블은 Sqoop을 사용하여 RDBMS로 내보내집니다. 지금 나는 이 모든 과정을 자동화해야합니다. 이 모든 가능한 3 가지 작업에 대한 특정 메서드를 MapReduce에 작성한 다음 MapReduce 작업을 실행하면 이러한 작업이

0열

1답변

PIG 스크립트를 사용하여 하나의 파일을 여러 파일로 분할하십시오.

나는 파이프로 구분 된 텍스트 파일에 abc.txt를 말합니다. 다른 레코드의 열 수가 다릅니다. 레코드의 열 수는 100,80,70,60이 될 수 있습니다. 세 번째 열 값을 기준으로 abc.txt를 분할해야합니다. 세 번째 열의 값이 "A"이면 "B", B.txt 인 경우 해당 레코드는 A.txt로 이동합니다. PIG 스크립트를 작성해야합니다.

0열

1답변

돼지에서 데이터를로드하고 돼지를 사용하여 HDFS에 avro로 저장합니다.

HDFS에서 보내야하는 ElasticSearch에 대한 데이터가 있습니다. 돼지를 사용하려고하는데 (처음 사용하는 경우), 데이터에 올바른 스키마를 정의하는 데 문제가 있습니다. 모든 첫째, 나는 org.elasticsearch.hadoop.pig.EsStorage와 옵션 'es.output.json=true'을 사용하여 JSON을로드 시도하고 HDFS에

0열

1답변

돼지와 함께 hbase에 바이너리 파일을 저장하십시오.

".spc"패턴을 가진 바이너리 파일이 있습니다.이 파일을 돼지 매퍼 작업과 함께 HBase에 저장하고 싶습니다. 행키는 파일 이름입니다. 여기 내가 사용하는 명령은 다음과 같습니다 A = LOAD 'hdfs-directory/sampleID-uvvis.spc' USING BinStorage(); B = FOREACH A GENERATE $0 AS ro

0열

1답변

하이브 테이블에서로드 된 "a, b, c"형식의 단일 열을 어떻게 그룹화 할 수 있습니까?

저는 확실히 초보자입니다. 쉬운 대답이있을 것입니다. 내 코드는 다음과 같습니다는 B= GROUP A BY location; C= FOREACH B GENERATE group as location, SUM(rating) as RatingSum, AVG(rating) as RatingAverage, MIN(rating)

0열

1답변

중간에 와일드 카드로 Pig에 일치 식을 쓰려면 어떻게해야합니까?

예를 들어 SQL LIKE 표현식 '% blah % zoop %'을 (를) 갖고 있다면 어떻게 돼지에 쓸 수 있습니까? . * 대신 %. *을 사용합니까?

0열

1답변

돼지의 열에서 최대 값을 얻는 방법은 무엇입니까?

테이블이 있는데 열의 합계 값을 쿼리하고 싶습니다. grunt>teams_raw = load '/usr/input/Teams.csv' using org.apache.pig.piggybank.storage.CSVExcelStorage(',', 'NO_MULTILINE', 'UNIX', 'SKIP_INPUT_HEADER'); grunt>teams = fore