How to translate Apache Pig FILTER statement to Spark?

[User15787040559]

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"))