 (require '[clj-time.core :as time])
 (ds/sliding-windows (time/minutes 30) (time/seconds 5) pcoll)
 ```"
-          named-schema)
+          window-schema)
    :added "0.4.1"}
   ([width step options ^PCollection pcoll]
    (let [transform (-> (->duration width)

           [java.util UUID]
           [org.joda.time DateTimeUtils DateTimeZone]
           [org.joda.time.format DateTimeFormat DateTimeFormatter]
           [com.google.cloud.dataflow.sdk.transforms.windowing Window FixedWindows SlidingWindows Sessions]
           [org.joda.time Duration]))

(def required-ns (atom #{}))

  (ds/map (fn [e] (ds/with-timestamp (clj-time.core/now) (* 2 e)) pcoll))
  ```"
  [timestamp result]
  (->TimeStamped timestamp result))

(defn output-value!
  [^DoFn$ProcessContext context entity bindings]
