       (.registerCoder clojure.lang.Keyword (make-transit-coder)))
     pipeline))
 
+;;;;;;;;;;;;;
+;; Text IO ;;
+;;;;;;;;;;;;;
+
 (defn write-text-file
   ([to options ^PCollection pcoll]
    (let [opts (assoc options :label :write-text-file)]

         (.apply (with-opts base-schema opts
                   (write-edn-file-transform to opts))))))
  ([to pcoll] (write-edn-file to {} pcoll)))

(defn make-keyed-pcollection-tuple
  [pcolls]

           [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
            BigQueryIO$Read BigQueryIO$Write]
           [com.google.api.services.bigquery.model TableRow]
           [com.google.cloud.dataflow.sdk.transforms
            DoFn DoFn$Context DoFn$ProcessContext ParDo DoFnTester Create PTransform
            SerializableFunction WithKeys GroupByKey RemoveDuplicates
