cancel
Turn on suggestions
Auto-suggest helps you quickly narrow down your search results by suggesting possible matches as you type.
Showing results for 
Search instead for 
Did you mean: 
Help
Data Engineering
Join discussions on data engineering best practices, architectures, and optimization strategies within the Databricks Community. Exchange insights and solutions with fellow data engineers.
cancel
Turn on suggestions
Auto-suggest helps you quickly narrow down your search results by suggesting possible matches as you type.
Showing results for 
Search instead for 
Did you mean: 

How to translate Apache Pig FILTER statement to Spark?

User15787040559
Databricks Employee
Databricks Employee

‎06-18-2021 09:52 AM

If you have the following Apache Pig FILTER statement:

XCOCD_ACT_Y = FILTER XCOCD BY act_ind == 'Y';

the equivalent code in Apache Spark is:

XCOCD_ACT_Y_DF = (XCOCD_DF
    .filter(col("act_ind") == "Y"))

Labels:
0 Kudos
0 REPLIES 0

Join Us as a Local Community Builder!

Passionate about hosting events and connecting people? Help us grow a vibrant local community—sign up today to get started!

Sign Up Now
Announcements