                                         ["count"])
                         (t/each ["count"] (FilterNull.))
                         (t/aggregate ["count"]
-                                      (Sum.)
-                                      ["sum"]))]
+                                      sum
+                                      ["sum"])
+                        (t/debug))]
     trident-topology))
 
 (defn run-local! []

                        (t/each ["sentence"]
                                 split-args
                                 ["word"])
                        (t/group-by ["word"])
                        (t/persistent-aggregate word-state-factory
                                                 ["word"]
                                                 (Count.)
                                                 ["count"])
                        (t/parallelism-hint 16))
        count-query (-> (t/drpc-stream trident-topology "words" drpc)
                        (t/each ["args"]
                                 split-args
                                 ["word"])
                        (t/group-by ["word"])
                        (t/state-query word-counts
                                        ["word"]

                     {}
                     (.build
                      (build-topology local-drpc)))
    (Thread/sleep 10000)
    (.execute local-drpc "words" "cat dog the man jumped")
    (.shutdown cluster)
    (System/exit 0)))

