   [& args]
   (let [p (make-pipeline args)
         final (->> p
-                   (generate-input (range 10000) {:named "gengen"})
-                   (dmap inc {:named "map"})
-                   (dfilter even? {:named "filter"})
-                   (to-edn {:named "edn"})
+                   (generate-input (range 10000) {:name "gengen"})
+                   (dmap inc {:name "map"})
+                   (dfilter even? {:name "filter"})
+                   (to-edn {:name "edn"})
                    (write-text-file "tee"))]
 
     (.run p)))

        result (pr-str elt)]
    (.output c result)))

(def to-edn (partial (map-op identity (StringUtf8Coder/of)) to-edn*))

(defn make-pipeline
  [str-args]

            [cognitect.transit :as transit])
  (:import [datasplash.fns ClojureDoFn]
           [java.io InputStream OutputStream]
           [java.util UUID]
           [com.google.cloud.dataflow.sdk.options PipelineOptionsFactory]
           [com.google.cloud.dataflow.sdk Pipeline]
           [com.google.cloud.dataflow.sdk.io TextIO$Read TextIO$Write]
