LOAD, FILTER, and STORE operations in Hadoop - Cheat Sheet & Quick Revision

Recall & Review

beginner

What does the LOAD operation do in Hadoop?

LOAD reads data from a file or source into Hadoop's processing environment so you can work with it.

beginner

Explain the FILTER operation in Hadoop.

FILTER selects only the data rows that meet a condition, like picking only apples from a basket of fruits.

beginner

What is the purpose of the STORE operation in Hadoop?

STORE saves the processed data back to a file or storage location so you can use it later or share it.

beginner

How would you describe the sequence of LOAD, FILTER, and STORE in a Hadoop job?

First, LOAD brings data in. Then FILTER picks the data you want. Finally, STORE saves the results.

beginner

Give a simple example of a FILTER condition in Hadoop.

For example, FILTER data where age > 30 means only keep rows where the age is more than 30.

What does the LOAD operation do in Hadoop?

A Filters data based on conditions

B Deletes data from Hadoop

C Reads data into Hadoop for processing

D Saves data to a file

LOAD reads data from a source into Hadoop so it can be processed.

Which operation selects data rows that meet a condition?

A FILTER

B LOAD

C STORE

D JOIN

FILTER picks only the rows that satisfy a condition.

What is the final step to save processed data in Hadoop?

A LOAD

B MAP

C FILTER

D STORE

STORE saves the processed data to storage.

If you want to keep only data where sales > 100, which operation do you use?

A FILTER

B REDUCE

C STORE

D LOAD

FILTER applies conditions like sales > 100 to select data.

What is the correct order of operations to process data in Hadoop?

A FILTER, LOAD, STORE

B LOAD, FILTER, STORE

C STORE, FILTER, LOAD

D FILTER, STORE, LOAD

First LOAD data, then FILTER it, then STORE the results.

Describe the roles of LOAD, FILTER, and STORE operations in a Hadoop data processing task.

Think about bringing data in, picking what you want, and saving it.

Explain why filtering data before storing it is useful in Hadoop workflows.

Consider what happens if you save everything versus only what you need.

Practice

1. What does the LOAD operation do in Hadoop data processing?

easy

A. Reads data from files into the system

B. Saves data back to storage

C. Filters rows based on a condition

D. Deletes data from storage

Solution

1. Step 1: Understand the purpose of LOAD

   The LOAD operation is used to bring data from external files into the Hadoop processing environment.

2. Step 2: Differentiate from FILTER and STORE

   FILTER selects data rows, and STORE saves data back, so LOAD must be the reading step.

3. Final Answer:

   Reads data from files into the system -> Option A

4. Quick Check:

   LOAD = Read data [OK]

Hint: LOAD means bring data in from files [OK]

Common Mistakes:

• Confusing LOAD with STORE operation
• Thinking LOAD filters data
• Assuming LOAD deletes data

2. Which of the following is the correct syntax to filter rows where age is greater than 30 in Hadoop Pig Latin?

easy

A. filtered_data = LOAD data FILTER age > 30;

B. filtered_data = FILTER data BY age > 30;

C. filtered_data = SELECT * FROM data WHERE age > 30;

D. filtered_data = FILTER data WHERE age > 30;

Solution

1. Step 1: Recall FILTER syntax in Pig Latin

   The correct syntax uses FILTER ... BY to select rows based on a condition.

2. Step 2: Check each option

   A mixes LOAD and FILTER incorrectly; B uses WHERE which is invalid in Pig; C is SQL syntax; D uses FILTER ... BY correctly.

3. Final Answer:

   filtered_data = FILTER data BY age > 30; -> Option B

4. Quick Check:

   FILTER ... BY is correct syntax [OK]

Hint: FILTER uses BY, not WHERE, in Pig Latin [OK]

Common Mistakes:

• Using WHERE instead of BY in FILTER
• Confusing Pig syntax with SQL
• Trying to filter during LOAD

3. Given the following Pig Latin code:

data = LOAD 'users.txt' USING PigStorage(',') AS (name:chararray, age:int);
adults = FILTER data BY age >= 18;
STORE adults INTO 'adult_users';

What will be the content of the 'adult_users' folder?

medium

A. All users from 'users.txt' regardless of age

B. An empty folder because STORE is missing a format

C. Only users with age less than 18

D. Only users with age 18 or older

Solution

1. Step 1: Understand the FILTER condition

   The FILTER selects rows where age is 18 or more, so only adults remain.

2. Step 2: STORE saves filtered data

   The STORE command saves the filtered adults data into 'adult_users' folder.

3. Final Answer:

   Only users with age 18 or older -> Option D

4. Quick Check:

   FILTER age >= 18 then STORE = adults only [OK]

Hint: FILTER keeps only matching rows before STORE [OK]

Common Mistakes:

• Assuming STORE saves original data
• Thinking STORE needs format specified always
• Confusing FILTER condition direction

4. Identify the error in this Pig Latin code snippet:

data = LOAD 'data.txt' USING PigStorage(',');
filtered = FILTER data WHERE score > 50;
STORE filtered INTO 'high_scores';

medium

A. Missing AS clause in LOAD

B. STORE command syntax is incorrect

C. FILTER uses WHERE instead of BY

D. PigStorage should not have parameters

Solution

1. Step 1: Check FILTER syntax

   FILTER in Pig Latin requires BY keyword, not WHERE.

2. Step 2: Verify other parts

   LOAD can omit AS but then schema is unknown; STORE syntax is correct; PigStorage accepts parameters.

3. Final Answer:

   FILTER uses WHERE instead of BY -> Option C

4. Quick Check:

   FILTER ... BY is correct, not WHERE [OK]

Hint: FILTER always uses BY, never WHERE [OK]

Common Mistakes:

• Using WHERE in FILTER
• Thinking AS is mandatory in LOAD
• Misunderstanding PigStorage parameters

5. You have a dataset 'sales.csv' with columns (product, quantity, price). You want to load this data, filter only rows where quantity is greater than 10 and price less than 100, then store the result in 'filtered_sales'. Which Pig Latin code correctly performs this?

hard

A. sales = LOAD 'sales.csv' USING PigStorage(',') AS (product:chararray, quantity:int, price:int); filtered = FILTER sales BY quantity > 10 AND price < 100; STORE filtered INTO 'filtered_sales';

B. sales = LOAD 'sales.csv' USING PigStorage(','); filtered = FILTER sales WHERE quantity > 10 AND price < 100; STORE filtered INTO 'filtered_sales';

C. sales = LOAD 'sales.csv' USING PigStorage(',') AS (product, quantity, price); filtered = FILTER sales BY quantity > 10 OR price < 100; STORE filtered INTO 'filtered_sales';

D. sales = LOAD 'sales.csv' USING PigStorage(',') AS (product:chararray, quantity:int, price:int); filtered = FILTER sales BY quantity > 10 OR price < 100; STORE filtered INTO 'filtered_sales';

Solution

1. Step 1: Load with schema and correct syntax

   sales = LOAD 'sales.csv' USING PigStorage(',') AS (product:chararray, quantity:int, price:int); filtered = FILTER sales BY quantity > 10 AND price < 100; STORE filtered INTO 'filtered_sales'; loads with schema and uses PigStorage correctly.

2. Step 2: Filter with correct condition and operator

   We want quantity > 10 AND price < 100, so AND is correct, not OR.

3. Step 3: STORE command is correct

   sales = LOAD 'sales.csv' USING PigStorage(',') AS (product:chararray, quantity:int, price:int); filtered = FILTER sales BY quantity > 10 AND price < 100; STORE filtered INTO 'filtered_sales'; uses STORE correctly to save filtered data.

4. Final Answer:

   Correct load, filter with AND, and store commands -> Option A

5. Quick Check:

   LOAD with schema + FILTER with AND + STORE = sales = LOAD 'sales.csv' USING PigStorage(',') AS (product:chararray, quantity:int, price:int); filtered = FILTER sales BY quantity > 10 AND price < 100; STORE filtered INTO 'filtered_sales'; [OK]

Hint: Use AND for both conditions, FILTER ... BY, and STORE properly [OK]

Common Mistakes:

• Using WHERE instead of BY in FILTER
• Using OR instead of AND for filtering
• Omitting schema in LOAD causing errors