     (conj! v (untuple t2))
     (persistent! v)))
 
-(defn ftruthy? [f]
+(defn ftruthy?
+  [f]
   (sparkop [x] (u/truthy? (f x))))
 
 ;; ## RDD construction

                     :memory-and-disk-ser-2 StorageLevels/MEMORY_AND_DISK_SER_2
                     :disk-only-2 StorageLevels/DISK_ONLY_2})

(defmacro sparkop [& body]
  `(sfn/fn ~@body))

(defmacro defsparkfn [name & body]
  `(def ~name
     (sparkop ~@body)))


     (log/debug "JavaSparkContext" master app-name)
     (JavaSparkContext. master app-name)))

(defn local-spark-context
  [app-name]
  (let [conf (-> (conf/spark-conf)
                 (conf/master "local[*]")
                 (conf/app-name app-name))]
    (spark-context conf)))

(defn jar-of-ns
  [ns]
  (let [clazz (Class/forName (clojure.string/replace (str ns) #"-" "_"))]
    (JavaSparkContext/jarOfClass clazz)))

