Initial commit

{\rtf1\ansi\ansicpg1252\cocoartf1038\cocoasubrtf350

{\fonttbl\f0\fswiss\fcharset0 Helvetica;}

{\colortbl;\red255\green255\blue255;}

\margl1440\margr1440\vieww9000\viewh8400\viewkind0

\pard\tx720\tx1440\tx2160\tx2880\tx3600\tx4320\tx5040\tx5760\tx6480\tx7200\tx7920\tx8640\ql\qnatural\pardirnatural

\f0\fs24 \cf0 No work files for this lesson...}

 No newline at end of file

cities = load 'cities_small.txt' as (name:chararray, state:chararray, population:int);

-- # Project a smaller number of fields using Foreach

cities_name_and_state = foreach cities generate name, state;

-- # Use Foreach to transform data

-- # adjust populations by 1.15

cities_transform = foreach cities generate name, state, population * 1.15;

store cities_name_and_state into 'cities_name_and_state';

store cities_transform into 'cities_transform';

cities = load 'cities_small.txt' as (name:chararray, state:chararray, population:int);

cities_by_state= group cities by state;

city_count = FOREACH cities_by_state GENERATE group,COUNT(cities);

dump city_count;

-- #group all is available as well.;

-- #cities_all = GROUP cities ALL ;

-- #group all to count

cities = load 'cities_small.txt' as (name:chararray, state:chararray, population:int);

cities_by_state = GROUP cities by state;

-- # describe cities_by_state

-- # cities_by_state: {group: chararray,cities: {(name: chararray,state: chararray,population: int)}}

-- # create a small relation so I can display to screen

cities_by_state_small = limit cities_by_state 3;

dump cities_by_state_small;

 No newline at end of file

cities = load 'cities_small.txt' as (name:chararray, state:chararray, population:int);

cities_by_state = GROUP cities by state parallel 3;

store cities_by_state into 'cities_by_state';