                        (SlidingWindows/of)
                        (.every  (->duration step))
                        (Window/into))]
-     (apply-transform pcoll transform named-schema options)))
+     (apply-transform pcoll transform window-schema options)))
   ([width step ^PCollection pcoll] (sliding-windows width step {} pcoll)))
 
 (defn session-windows

   (let [transform (-> (->duration gap)
                       (Sessions/withGapDuration)
                       (Window/into))]
     (apply-transform pcoll transform named-schema options)))
  ([gap ^PCollection pcoll] (sliding-windows gap {} pcoll)))

   {:trigger {:docstr "Adds a Trigger to the Window."
              :action (fn [transform ^Trigger t] (.triggering transform t))}
    :with-allowed-lateness {:docstr "Allow late data. Mandatory for custom trigger"
                            :action (fn [transform d] (.withAllowedLateness transform (->duration d)))}
    :accumulate-mode {:docstr "Accumulate mode when a Trigger is fired (accumulate or discard)"
                      :action (fn [transform acc] ((get accumulation-mode-enum acc) transform))}}))

