gistfile1.clj

(defn mk-edge-tap [id name class-name]
  (let [md (thrift-meta-data class-name)
        fields (for [f (.keySet md)]
                 [f (.getFieldName f)])
        vars (vec (map #(symbol (str "?" (second %))) fields))
        out-vars (conj vars (symbol "?pedigree"))]
    `(defn ~(symbol (str name "-tap")) [source-dir#]
       (let [tap# (split-data-tap source-dir# [~id])]
         (<- ~out-vars
             (tap# _ ?data)
             (expand-data ?data :> ?pedigree ?du)
             (expand-all ?du ~md :> ~@vars))))))