gistfile1.clj

(defmacro mk-property-tap [property-id property-name val-id val-name]
  `(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)))))

(defn bootstrap-schema []
  (let [md (thrift-meta-data ybot.schema.DataUnit)]
    (doseq [f (.keySet md)]
      (let [id (.getThriftFieldId f)
            name (.getFieldName f)
            class-name (-> (.get md f) (.valueMetaData) (.structClass) (.getName))]
        (if (.endsWith name "property")
          (doseq [v (.keySet (thrift-meta-data (str class-name "Value")))]
            (let [val-id (.getThriftFieldId v)
                  value-name (.getFieldName v)]
              (mk-property-tap id name val-id val-name)))
          nil)))))