diff --git a/examples/pig/example-script-cql.pig b/examples/pig/example-script-cql.pig new file mode 100644 index 0000000000..63656a748d --- /dev/null +++ b/examples/pig/example-script-cql.pig @@ -0,0 +1,11 @@ +-- CqlStorage +libdata = LOAD 'cql://libdata/libout' USING CqlStorage(); +book_by_mail = FILTER libdata BY C_OUT_TY == 'BM'; + +libdata_buildings = FILTER libdata BY SQ_FEET > 0; +state_flat = FOREACH libdata_buildings GENERATE STABR AS State,SQ_FEET AS SquareFeet; +state_grouped = GROUP state_flat BY State; +state_footage = FOREACH state_grouped GENERATE group AS State, SUM(state_flat.SquareFeet) AS TotalFeet:int; + +insert_format= FOREACH state_footage GENERATE TOTUPLE(TOTUPLE('year',2011),TOTUPLE('state',State)),TOTUPLE(TotalFeet); +STORE insert_format INTO 'cql://libdata/libsqft?output_query=UPDATE%20libdata.libsqft%20SET%20sqft%20%3D%20%3F' USING CqlStorage; \ No newline at end of file diff --git a/examples/pig/example-script.pig b/examples/pig/example-script.pig index 8b69b995a5..d47fc28849 100644 --- a/examples/pig/example-script.pig +++ b/examples/pig/example-script.pig @@ -6,16 +6,4 @@ namegroups = GROUP colnames BY (chararray) $0; namecounts = FOREACH namegroups GENERATE COUNT($1), group; orderednames = ORDER namecounts BY $0 DESC; topnames = LIMIT orderednames 50; -dump topnames; - --- CqlStorage -libdata = LOAD 'cql://libdata/libout' USING CqlStorage(); -book_by_mail = FILTER libdata BY C_OUT_TY == 'BM'; - -libdata_buildings = FILTER libdata BY SQ_FEET > 0; -state_flat = FOREACH libdata_buildings GENERATE STABR AS State,SQ_FEET AS SquareFeet; -state_grouped = GROUP state_flat BY State; -state_footage = FOREACH state_grouped GENERATE GROUP AS State, SUM(state_flat.SquareFeet) AS TotalFeet:int; - -insert_format= FOREACH state_footage GENERATE TOTUPLE(TOTUPLE('year',2011),TOTUPLE('state',State)),TOTUPLE(TotalFeet); -STORE insert_format INTO 'cql://libdata/libsqft?output_query=UPDATE%20libdata.libsqft%20SET%20sqft%20%3D%20%3F' USING CqlStorage; \ No newline at end of file +dump topnames; \ No newline at end of file