本文主要研究一下storm的OpaquePartitionedTridentSpoutExecutor

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

本文主要研究一下storm的AggregateProcessor的execute及finishBatch方法

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

本文主要研究一下storm TridentWindowManager的pendingTriggers

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