            [datasplash.vals ClojureVal]
            [datasplash.coders ClojureCoder])
   (:gen-class))
+
+(def ops-counter (atom 0))
 
 (defn dofn
   [f & {:keys [start-bundle finish-bundle] :as opts}]

  [& 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"})
                   (write-text-file "tee"))]

    (.run p)))

            [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]
