From 5f79f5321bbbbac383b727fbbf60891b4c5e4136 Mon Sep 17 00:00:00 2001 From: Brandon Williams Date: Wed, 20 Nov 2013 10:19:17 -0600 Subject: [PATCH] update pig example scripts Patch by Jeremy Hanna, reviewed by brandonwilliams for CASSANDRA-6239 --- examples/pig/example-script-cql.pig | 11 +++++++++++ examples/pig/example-script.pig | 14 +------------- 2 files changed, 12 insertions(+), 13 deletions(-) create mode 100644 examples/pig/example-script-cql.pig 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