Permalink
Browse files

don't use recursive walk to stringify-keys

  • Loading branch information...
1 parent 7028d12 commit 139026a453e7da8fa9523ca377830b2ca5a4c0ff @schleyfox committed Jan 14, 2012
Showing with 4 additions and 2 deletions.
  1. +4 −2 src/clj/backtype/storm/clojure.clj
@@ -1,7 +1,6 @@
(ns backtype.storm.clojure
(:use [clojure.contrib.def :only [defnk defalias]])
(:use [backtype.storm bootstrap util])
- (:use [clojure walk])
(:import [backtype.storm StormSubmitter])
(:import [backtype.storm.generated StreamInfo])
(:import [backtype.storm.tuple Tuple])
@@ -161,7 +160,10 @@
[^OutputCollector collector stream values]
(if (map? values)
(let [ fields (.. collector getContext (getThisOutputFields stream) toList) ]
- (vec (map (stringify-keys values) fields)))
+ (vec (map (into
+ (empty values) (for [[k v] values]
+ [(if (keyword? k) (name k) k) v]))
+ fields)))
values))
(defnk emit-bolt! [^OutputCollector collector values

0 comments on commit 139026a

Please sign in to comment.