             [onyx.api]))
 
 (def input
-  (map (fn [a]
-         (assoc a 
-                :randstuff
-                (repeatedly 40
-                            #(rand-int 256)))) 
-       (reduce into [] 
-               (repeat 30000
-                       [{:id 1  :age 21 :event-time #inst "2015-09-13T03:00:00.829-00:00"}
-                        {:id 2  :age 12 :event-time #inst "2015-09-13T03:04:00.829-00:00"}
-                        {:id 3  :age 3  :event-time #inst "2015-09-13T03:05:00.829-00:00"}
-                        {:id 4  :age 64 :event-time #inst "2015-09-13T03:06:00.829-00:00"}
-                        {:id 5  :age 53 :event-time #inst "2015-09-13T03:07:00.829-00:00"}
-                        {:id 6  :age 52 :event-time #inst "2015-09-13T03:08:00.829-00:00"}
-                        {:id 7  :age 24 :event-time #inst "2015-09-13T03:09:00.829-00:00"}
-                        {:id 8  :age 35 :event-time #inst "2015-09-13T03:15:00.829-00:00"}
-                        {:id 9  :age 49 :event-time #inst "2015-09-13T03:25:00.829-00:00"}
-                        {:id 10 :age 37 :event-time #inst "2015-09-13T03:45:00.829-00:00"}
-                        {:id 11 :age 15 :event-time #inst "2015-09-13T03:03:00.829-00:00"}
-                        {:id 12 :age 22 :event-time #inst "2015-09-13T03:56:00.829-00:00"}
-                        {:id 13 :age 83 :event-time #inst "2015-09-13T03:59:00.829-00:00"}
-                        {:id 14 :age 60 :event-time #inst "2015-09-13T03:32:00.829-00:00"}
-                        {:id 15 :age 35 :event-time #inst "2015-09-13T03:16:00.829-00:00"}]))))
+  [{:id 1  :age 21 :event-time #inst "2015-09-13T03:00:00.829-00:00"}
+   {:id 2  :age 12 :event-time #inst "2015-09-13T03:04:00.829-00:00"}
+   {:id 3  :age 3  :event-time #inst "2015-09-13T03:05:00.829-00:00"}
+   {:id 4  :age 64 :event-time #inst "2015-09-13T03:06:00.829-00:00"}
+   {:id 5  :age 53 :event-time #inst "2015-09-13T03:07:00.829-00:00"}
+   {:id 6  :age 52 :event-time #inst "2015-09-13T03:08:00.829-00:00"}
+   {:id 7  :age 24 :event-time #inst "2015-09-13T03:09:00.829-00:00"}
+   {:id 8  :age 35 :event-time #inst "2015-09-13T03:15:00.829-00:00"}
+   {:id 9  :age 49 :event-time #inst "2015-09-13T03:25:00.829-00:00"}
+   {:id 10 :age 37 :event-time #inst "2015-09-13T03:45:00.829-00:00"}
+   {:id 11 :age 15 :event-time #inst "2015-09-13T03:03:00.829-00:00"}
+   {:id 12 :age 22 :event-time #inst "2015-09-13T03:56:00.829-00:00"}
+   {:id 13 :age 83 :event-time #inst "2015-09-13T03:59:00.829-00:00"}
+   {:id 14 :age 60 :event-time #inst "2015-09-13T03:32:00.829-00:00"}
+   {:id 15 :age 35 :event-time #inst "2015-09-13T03:16:00.829-00:00"}])
 
 (def expected-windows
   [[1442113200000 1442113499999 

(ns onyx.windowing.aggregation-conj-test
  (:require [clojure.core.async :refer [chan >!! <!! close! sliding-buffer dropping-buffer]]
            [clojure.test :refer [deftest is]]
            [onyx.plugin.core-async :refer [take-segments!]]
            [schema.core :as s]

        [{:window/id :collect-segments
          :window/task :identity
          :window/type :fixed
          :window/aggregation :onyx.windowing.aggregation/conj
          :window/window-key :event-time
          :window/range [5 :minutes]}]
