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 diff --git a/test/unit/org/apache/cassandra/pig/CqlTableDataTypeTest.java b/test/unit/org/apache/cassandra/pig/CqlTableDataTypeTest.java index 352b2e2edc..1ae9806e94 100644 --- a/test/unit/org/apache/cassandra/pig/CqlTableDataTypeTest.java +++ b/test/unit/org/apache/cassandra/pig/CqlTableDataTypeTest.java @@ -17,6 +17,27 @@ * under the License. */ package org.apache.cassandra.pig; +/* + * + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + * + */ + import java.io.IOException; import java.nio.charset.CharacterCodingException; diff --git a/test/unit/org/apache/cassandra/pig/ThriftColumnFamilyDataTypeTest.java b/test/unit/org/apache/cassandra/pig/ThriftColumnFamilyDataTypeTest.java index cc5462057f..7bccc23f42 100644 --- a/test/unit/org/apache/cassandra/pig/ThriftColumnFamilyDataTypeTest.java +++ b/test/unit/org/apache/cassandra/pig/ThriftColumnFamilyDataTypeTest.java @@ -17,6 +17,27 @@ * under the License. */ package org.apache.cassandra.pig; +/* + * + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + * + */ + import java.io.IOException; import java.nio.charset.CharacterCodingException;