Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- (defbolt tokenizer ["tokenized"] [[[field unparsed-tweet] & rest :as tuple] collector]
- (let [tweet (safe-read unparsed-tweet)
- tokens (safe-tokenize tweet)
- x (do
- (log-message "XXXXXXXXXXXXXXX")
- (log-message (type tokens))
- (log-message (into-array tokens))
- nil)
- ]
- ; (emit-bolt! collector [(json/write-str (into tweet {:tokens tokens}))])
- (emit-bolt! collector [(json/write-str (into tweet {:tokens "tokens"}))])
- (ack! collector tuple)))
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement