Database Reference
In-Depth Information
[-- snip --]
2013-07-22 14:12:50,464 [main] INFO
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher
- Processing aliases cnt,cols,grps,rows,vals
2013-07-22 14:12:50,464 [main] INFO
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher
- detailed locations: M:
rows[6,7],cols[7,7],vals[8,7],cnt[10,6],grps[9,7] C:
cnt[10,6],grps[9,7] R: cnt[10,6]
[-- snip --]
2013-07-22 14:13:45,626 [main] INFO
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher
- 97% complete
2013-07-22 14:13:49,669 [main] INFO
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher
- 100% complete
[-- snip --]
Input(s):
Successfully read 6 records (360 bytes) from:
"cassandra://testks/dataCF"
Output(s):
Successfully stored 4440 records in: "cassandra://testks/
result1CF"
[-- snip --]
2013-07-22 14:13:49,693 [main] INFO
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher
- Success!
Let's look at the result that is stored in result1CF and
compare it with the previous result.
cqlsh> use testks;
cqlsh:testks> select * from result1CF where key = 'the';
KEY | count
-----+-------
the | 1666
cqlsh:testks> select * from resultCF where key = 'Alice';
KEY | count
