   "Create a data processing function body for emitting data into a Java map."
   [input rules]
   (reduce
-    (java-map-out-reduce-fn)
+    (reduce-fn-java-map-out)
     '[doto (java.util.HashMap.)] rules))
 
-(defmacro clojure-map-out-reduce-fn
+(defmacro reduce-fn-clojure-map-out
   []
   `(fn [v# rule#]
      (conj v# `(assoc

  "Create a data processing function body for emitting data into a Clojure map."
  [input rules]
  (reduce
    (clojure-map-out-reduce-fn)
    '[-> {}] rules))

(defn create-proc-fn-body-csv-str-out

  "Create a data processing function body for incrementally emitting data into a Java map."
  [input output rules]
  (reduce
    (reduce-fn-java-map-out)
    '[doto ^java.util.Map output] rules))

(defn create-incremental-proc-fn-body-clj-map-out
  "Create a data processing function body for incrementally emitting data into a Clojure map."
  [input output rules]
  (reduce
    (reduce-fn-clojure-map-out)
    '[-> output] rules))

(defn create-incremental-proc-fn
