spark-core-filter-01-complete.scala

val orders = sc.textFile("/public/retail_db/orders")

// Get COMPLETE orders
orders.
  filter(o => o.split(",")(3) == "COMPLETE").
  take(10).
  foreach(println)

spark-core-filter-02-complete-or-closed.scala

// Get COMPLETE or CLOSED orders
orders.
  filter(o => o.split(",")(3) == "COMPLETE" || o.split(",")(3) == "CLOSED").
  take(10).
  foreach(println)
  
orders.
  filter(o => List("COMPLETE", "CLOSED").contains(o.split(",")(3))).
  take(10).
  foreach(println)

spark-core-filter-03-complete-or-closed-or-pending.scala

// Get COMPLETE or CLOSED or any PENDING type orders
orders.
  filter(o => {
    List("COMPLETE", "CLOSED").
      contains(o.split(",")(3)) || 
    o.split(",")(3).contains("PENDING")
  }).
  take(10).
  foreach(println)

spark-core-filter-04-complete-or-closed-and-2013-08-15.scala

// Get all the COMPLETE or CLOSED orders placed on 2013 August 15
orders.
  filter(o => {
    List("COMPLETE", "CLOSED").
      contains(o.split(",")(3)) && 
    o.split(",")(1).startsWith("2013-08-15")
  }).
  take(10).
  foreach(println)