LOAD, FILTER, and STORE operations in Hadoop - Time & Space Complexity

Time Complexity: LOAD, FILTER, and STORE operations

O(n)

Understanding Time Complexity

We want to understand how the time needed changes when we load, filter, and store data in Hadoop.

How does the size of data affect the work done by these operations?

Scenario Under Consideration

Analyze the time complexity of the following code snippet.

data = LOAD 'input_data';
filtered = FILTER data BY some_condition;
STORE filtered INTO 'output_data';

This code loads data, filters rows based on a condition, then stores the filtered data.

Identify Repeating Operations

Look at what repeats as data size grows.

• Primary operation: Filtering each row to check the condition.
• How many times: Once for every row in the loaded data.

How Execution Grows With Input

As the number of rows increases, the filtering work grows too.

Input Size (n)	Approx. Operations
10	About 10 filter checks
100	About 100 filter checks
1000	About 1000 filter checks

Pattern observation: The work grows directly with the number of rows.

Final Time Complexity

Time Complexity: O(n)

This means the time grows in a straight line with the number of rows processed.

Common Mistake

[X] Wrong: "Filtering only takes constant time no matter how much data there is."

[OK] Correct: Each row must be checked, so more rows mean more work.

Interview Connect

Understanding how data size affects filtering helps you explain how Hadoop handles big data efficiently.

Self-Check

"What if we added a nested loop inside the filter condition? How would the time complexity change?"

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