Reusing your fns as Clojure serialized fns to use in Flambo (Spark wrapper for Clojure)

clojure-serialized-fns-flambo-spark.clj

(require '[clj-time.core :as t])
(require '[flambo.api :as f])

(defn date-filter-fn
  "Given a LocalDate, returns a serializable fn that takes a DateTime
  object and returns true if the DateTime fields match those of the
  provided LocalDate, else returns false."
  [local-date]
  ;; returning a serializable fn to be used with Flambo/Spark's filter operation
  (f/fn
    [date-time]
    (boolean
     (and
       (= (t/day local-date)   (t/day date-time)))
       (= (t/month local-date) (t/month date-time))
       (= (t/year local-date)  (t/year date-time))))))