storm-core-1.2.2-sources.jar!/org/apache/storm/trident/topology/MasterBatchCoordinator.java

b-1主要是处理CombinerAggregator的init，它的parallelismHint为1，由于它的上游bolt有3个task，因而它的TridentBoltExecutor的tracked.condition.expectedTaskReports为3，它要等到这三个task的聚合数据都到了之后，才能finishBatch

storm-core-1.2.2-sources.jar!/org/apache/storm/trident/topology/MasterBatchCoordinator.java

storm-core-1.2.2-sources.jar!/org/apache/storm/trident/topology/TridentBoltExecutor.java

storm-core-1.2.2-sources.jar!/org/apache/storm/trident/windowing/WindowTridentProcessor.java

storm-core-1.2.2-sources.jar!/org/apache/storm/trident/topology/TridentBoltExecutor.java

storm-core-1.2.2-sources.jar!/org/apache/storm/trident/windowing/WindowTridentProcessor.java

storm-kafka-client-1.2.2-sources.jar!/org/apache/storm/kafka/spout/KafkaSpoutConfig.java

storm-1.2.2/storm-core/src/jvm/org/apache/storm/trident/topology/MasterBatchCoordinator.java

storm-core-1.2.2-sources.jar!/org/apache/storm/trident/TridentTopology.java

storm-2.0.0/storm-client/src/jvm/org/apache/storm/executor/ExecutorTransfer.java

storm-2.0.0/storm-server/src/main/java/org/apache/storm/metric/LoggingClusterMetricsConsumer.java

storm-2.0.0/storm-client/src/jvm/org/apache/storm/metric/LoggingMetricsConsumer.java

storm-2.0.0/storm-client/src/jvm/org/apache/storm/metric/IEventLogger.java

storm-core-1.2.2-sources.jar!/org/apache/storm/trident/operation/Function.java

storm-2.0.0/storm-client/src/jvm/org/apache/storm/trident/state/StateType.java

storm-2.0.0/storm-client/src/jvm/org/apache/storm/topology/TopologyBuilder.java

这里有两个相关的参数，分别是storm.messaging.netty.buffer.high.watermark以及storm.messaging.netty.buffer.low.watermark

序 本文主要研究一下storm的messageTimeout TOPOLOGY_MESSAGE_TIMEOUT_SECS storm-2.0.0/storm-client/src/jvm/org/apache/storm/Config.java {代码...} defaults.yaml中topology.enable.message.timeouts默认为true defaults.yaml中topology.message.timeout.secs默认为30 defaults.yaml中topology.tick.tuple.freq.sec...

TOPOLOGY_MAX_SPOUT_PENDING设置的是一个spout task已经emit等待ack的tuple的最大数量，该配置仅仅对于发射可靠tuple(设置msgId)的spout起作用

storm-2.0.0/storm-client/src/jvm/org/apache/storm/policy/IWaitStrategy.java

DRPCSpout的outputFields为Fields("args", "return-info")，ReturnResults接收的fields为Fields("result", "return-info")

这里在SplitStreamBolt里头将stream分为两个，之后有两个CountStreamBolt分别处理两个stream的数据，最后归到同一个stream由ReportBolt消费tuple

JoinBolt继承了BaseWindowedBolt，定义了Selector selectorType、LinkedHashMap<String, JoinInfo> joinCriteria、FieldSelector[] outputFields等属性，用于记录关联类型及关联关系

storm-2.0.0/storm-client/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java

序 本文主要研究一下storm的WindowedBolt 实例 {代码...} 这里主要设置了withWindow、withTimestampField、withWatermarkInterval、withLag SlidingWindowSumBolt {代码...} TupleWindow可以获取三类值，一类是当前窗口里头的所有数据，一类是上次窗口后新到达的数据，一类是过期的数据 WindowedBolt IWindowedBolt stor...

storm-2.0.0/storm-client/src/jvm/org/apache/storm/task/IErrorReporter.java

这里对supervisor配置drpc.servers及drpc.port、drpc.invocations.port，好让worker通过drpc.invocations.port去访问drpc节点

对于bolt来说，要做两件事情，一是要anchor，在emit的时候把输入及输出tuple连接起来，构建tuple tree；而要对处理完的tuple进行ack，失败进行fail操作

这里实例是重写getComponentConfiguration方法，直接new了一个conf，设置了Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS参数