Advertisement
Guest User

Untitled

a guest
Jul 7th, 2014
72
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.56 KB | None | 0 0
  1. (defbolt tokenizer ["tokenized"] [[[field unparsed-tweet] & rest :as tuple] collector]
  2. (let [tweet (safe-read unparsed-tweet)
  3. tokens (safe-tokenize tweet)
  4. x (do
  5. (log-message "XXXXXXXXXXXXXXX")
  6. (log-message (type tokens))
  7. (log-message (into-array tokens))
  8. nil)
  9. ]
  10. ; (emit-bolt! collector [(json/write-str (into tweet {:tokens tokens}))])
  11. (emit-bolt! collector [(json/write-str (into tweet {:tokens "tokens"}))])
  12. (ack! collector tuple)))
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement