gistfile1.clj

(defmacro mk-property-tap [property-class property-id property-name]
  (let [md (thrift-meta-data (str property-class "Value"))
        taps (for [f (.keySet md)]
               (let [val-id (.getThriftFieldId f)
                     val-name (.getFieldName f)]
                  `(defn ~(symbol (str property-name "-" val-name "-tap")) [source-dir#]
                     (let [tap# (split-data-tap source-dir# [~property-id ~val-id])]
                       (<- [?id ?property ?pedigree]
                           (tap# _ ?data)
                           (expand-data ?data :> ?pedigree ?du)
                           (expand-property ?du :> ?id ?property))))))]
    `(do ~@taps)))

(defn bootstrap-schema []
  (let [md (thrift-meta-data ybot.schema.DataUnit)]
    (for [f (.keySet md)]
      (let [id (.getThriftFieldId f)
            name (.getFieldName f)
            class-name (-> (.get md f) (.valueMetaData) (.structClass) (.getName))]
        (mk-property-tap class-name id name)))))