register s3n://uw-cse344-code/myudfs.jar
-- load the test file into Pig
--raw = LOAD 's3n://uw-cse344-test/cse344-test-file' USING TextLoader as (line:chararray);
-- later you will load to other files, example:
raw = LOAD 's3n://uw-cse344/btc-2010-chunk-000' USING TextLoader as (line:chararray);
-- parse each line into ntriples
ntriples = foreach raw generate FLATTEN(myudfs.RDFSplit3(line)) as (subject:chararray,predicate:chararray,object:chararray);
--filter 1
subjects1 = filter ntriples by subject matches '.*rdfabout\\.com.*' PARALLEL 50;
--filter 2
subjects2 = subjects1;
을하고 싶으면 어떻게 설정합니까하지만 오류를 얻을 :
2012-03-10 01 : 19 : 18,039 [주] 오류 org.apache.pig.tools.grunt.Grunt - 오류 1200 : 일치하지 않는 입력 ';' 예상 LEFT_PAREN 로그 파일의 세부 정보 : /home/hadoop/pig_1331342327467.log
돼지는 그렇게 생각하지 않습니다. 어떻게해야합니까?