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

                         (fn [acc [k pview]]
                           (assoc! acc k (.sideInput context pview)))
                         (transient {}) side-inputs))]
          (println "dofn" without-coercion-to-clj)
          (binding [*context* context
                    *coerce-to-clj* (not without-coercion-to-clj)
                    *side-inputs* side-ins]

  "Get element from context in ParDo while applying relevent Clojure type conversions"
  [^DoFn$ProcessContext c]
  (let [element (.element c)]
    (if *coerce-to-clj*
      (if (instance? KV element)
        (kv->clj element)
