I hereby claim:
- I am sjoerdmulder on github.
- I am sjoerd (https://keybase.io/sjoerd) on keybase.
- I have a public key whose fingerprint is F474 721C D279 B422 8386 88A3 84C3 D5C7 A0BB B263
To claim this, I am signing this object:
I hereby claim:
To claim this, I am signing this object:
user1 5130a539e4b07596b7b71df8 1 | |
user2 5130a539e4b07596b7b71df9 1 | |
12312312312 5130a539e4b07596b7b71dfa 1 | |
asdf_asdf 5130a539e4b07596b7b71dfb 1 | |
42651178-7d78-42ae-8972-4ed7492c8bb4 5130a539e4b07596b7b71dfc 0 | |
8212c2e8-8c31-4f38-a541-036f0de773f1 5130a539e4b07596b7b71dfd 3 | |
… | |
bb913d0c-f32d-42c9-a27a-dc8fecdf93db 5130a539e4b07596b7b71e02 3 | |
3948fc98-8f55-4097-a695-4c776ef01271 5130a539e4b07596b7b71e03 0 | |
6a204bd89f3c8348afd5c77c717a097a 5130a539e4b07596b7b71e07 2 |
import backtype.storm.Config; | |
import backtype.storm.LocalCluster; | |
import backtype.storm.spout.SpoutOutputCollector; | |
import backtype.storm.task.TopologyContext; | |
import backtype.storm.topology.OutputFieldsDeclarer; | |
import backtype.storm.topology.base.BaseRichSpout; | |
import backtype.storm.tuple.Fields; | |
import backtype.storm.tuple.Values; | |
import backtype.storm.utils.Utils; | |
import storm.trident.TridentTopology; |