分类： storm

storm-2.0.0/storm-client/src/jvm/org/apache/storm/task/…

这里对supervisor配置drpc.servers及drpc.port、drpc.invocations.…

对spout来说，需要在emit的时候要指定msgId，然后需要缓存数据，在ack时删除，在fail的时候重新…

这里实例是重写getComponentConfiguration方法，直接new了一个conf，设置了Conf…

direct grouping是一种特殊的grouping，它是由上游的producer直接指定下游哪个tas…

storm-2.0.0/storm-client/src/jvm/org/apache/storm/group…

值得注意的是在wordCount的bolt使用PartialKeyGrouping，同一个单词不再固定发给相同…

storm-2.0.0/storm-server/src/main/java/org/apache/storm…

storm-core-1.2.2-sources.jar!/org/apache/storm/metrics2…