   ;(let [pig-field (format-field field)
   ;      pig-schema (str " AS " alias)]
   ;  [nil (str pig-field pig-schema)])
-  (println "flowdef" flowdef)
-  ;(update-in flowdef [:pipes pipe :fields] (fn [fields] (assoc fields field alias))))
-  (println "updated" (update-in flowdef [:pipes pipe] #(Each. % (Identity.))))
-  (println "x" x)
-  (println "pipe" (get-in flowdef [:pipes pipe]))
+  ;(println "flowdef" flowdef)
+  ;(println "updated" (update-in flowdef [:pipes pipe] #(Each. % (Identity.))))
+  ;(println "x" x)
+  ;(println "pipe" (get-in flowdef [:pipes pipe]))
   (update-in flowdef [:pipes pipe] #(Each. % (Identity.))))
 
 (defmethod command->flowdef :group

  (println "keys" keys)
  (println "ancestors" ancestors)
  (println "join-types" join-types)
  (update-in flowdef [:pipes] (partial merge {id (Pipe. (str id))})))

(defmethod command->flowdef :projection-flat
           [{:keys [code alias pipe]} flowdef]

(ns pigpen.cascading
  (:import (cascading.tap.hadoop Hfs)
           (cascading.scheme.hadoop TextLine)
           (cascading.pipe Pipe Each CoGroup)
           (cascading.flow.hadoop HadoopFlowConnector)
           (pigpen.cascading PigPenFunction)
           (cascading.tuple Fields)
