       (.getValue elt))
     (val elt)))
 
-(defn make-keyed-pcollection-tuple
-  [pcolls]
-  (let [empty-kpct (KeyedPCollectionTuple/empty (.getPipeline (first pcolls)))]
-    (reduce
-     (fn [coll-tuple [idx pcoll]]
-       (let [tag (TupleTag. (str idx))
-             new-coll-tuple (.and coll-tuple tag pcoll)]
-         new-coll-tuple))
-     empty-kpct (map-indexed (fn [idx v] [idx v]) pcolls))))
-
 (def ^{:dynamic true :no-doc true} *coerce-to-clj* true)
 (def ^{:dynamic true :no-doc true} *context* nil)
 (def ^{:dynamic true :no-doc true} *side-inputs* {})

          base-schema)
   :added "0.1.0"}
  ([coll options ^Pipeline p]
   (let [opts (assoc options :label :generate-input)
         ptrans (Create/of (seq coll))]
     (apply-transform p ptrans base-schema opts)))
  ([coll p] (generate-input coll {} p)))

          base-schema text-reader-schema)
   :added "0.1.0"}
  ([from options ^Pipeline p]
   (let [opts (assoc options
                     :label (str "read-edn-file-from-"
                                 (clean-filename from))
                     :coder (or (:coder options) (make-nippy-coder)))]
     (apply-transform p (read-edn-file-transform from opts)
                      (merge base-schema text-reader-schema) opts)))
  ([from p] (read-edn-file from {} p)))
