加载中
聊聊storm的OpaquePartitionedTridentSpoutExecutor

序 本文主要研究一下storm的OpaquePartitionedTridentSpoutExecutor TridentTopology.newStream storm-core-1.2.2-sources.jar!/org/apache/storm/trident/TridentTopology.java public Stre...

2018/11/20 09:58
637
聊聊storm的ICommitterTridentSpout

序 本文主要研究一下storm的ICommitterTridentSpout ICommitterTridentSpout storm-core-1.2.2-sources.jar!/org/apache/storm/trident/spout/ICommitterTridentSpout.java public interface...

2018/11/19 00:33
87
聊聊storm trident spout的_maxTransactionActive

序 本文主要研究一下storm trident spout的_maxTransactionActive MasterBatchCoordinator storm-core-1.2.2-sources.jar!/org/apache/storm/trident/topology/MasterBatchCoordinator.java ...

聊聊storm trident batch的分流与聚合

序 本文主要研究一下storm trident batch的分流与聚合 实例 TridentTopology topology = new TridentTopology(); topology.newStream("spout1", spout) .partitionBy(new Field......

2018/11/17 23:50
84
聊聊storm TridentBoltExecutor的finishBatch方法

序 本文主要研究一下storm TridentBoltExecutor的finishBatch方法 MasterBatchCoordinator.nextTuple storm-core-1.2.2-sources.jar!/org/apache/storm/trident/topology/MasterBatchCoordi...

2018/11/16 15:12
54
聊聊storm的AggregateProcessor的execute及finishBatch方法

序 本文主要研究一下storm的AggregateProcessor的execute及finishBatch方法 实例 TridentTopology topology = new TridentTopology(); topology.newStream("spout1", spout) .g......

2018/11/15 00:37
110
聊聊storm WindowTridentProcessor的FreshCollector

序 本文主要研究一下storm WindowTridentProcessor的FreshCollector 实例 TridentTopology topology = new TridentTopology(); topology.newStream("spout1", spout) .partition......

2018/11/14 13:52
97
聊聊storm TridentWindowManager的pendingTriggers

序 本文主要研究一下storm TridentWindowManager的pendingTriggers TridentBoltExecutor.finishBatch storm-core-1.2.2-sources.jar!/org/apache/storm/trident/topology/TridentBoltExecut...

2018/11/13 23:29
55
聊聊storm的window trigger

序 本文主要研究一下storm的window trigger WindowTridentProcessor.prepare storm-core-1.2.2-sources.jar!/org/apache/storm/trident/windowing/WindowTridentProcessor.java public void ...

2018/11/12 23:13
180
聊聊storm-kafka-client的ProcessingGuarantee

序 本文主要研究一下storm-kafka-client的ProcessingGuarantee ProcessingGuarantee storm-kafka-client-1.2.2-sources.jar!/org/apache/storm/kafka/spout/KafkaSpoutConfig.java /** * Th...

2018/11/11 22:25
154
聊聊storm trident的coordinator

序 本文主要研究一下storm trident的coordinator 实例 代码示例 @Test public void testDebugTopologyBuild(){ FixedBatchSpout spout = new FixedBatchSpout(new Fields("user", "score"),...

聊聊storm TridentTopology的构建

序 本文主要研究一下storm TridentTopology的构建 实例 @Test public void testDebugTopologyBuild(){ FixedBatchSpout spout = new FixedBatchSpout(new Fields("user", "score"), 3, ......

2018/11/09 10:14
43
聊聊storm tuple的序列化

序 本文主要研究一下storm tuple的序列化 ExecutorTransfer.tryTransfer storm-2.0.0/storm-client/src/jvm/org/apache/storm/executor/ExecutorTransfer.java // Every executor has an ins...

2018/11/08 16:13
99
聊聊storm的LoggingClusterMetricsConsumer

序 本文主要研究一下storm的LoggingClusterMetricsConsumer LoggingClusterMetricsConsumer storm-2.0.0/storm-server/src/main/java/org/apache/storm/metric/LoggingClusterMetricsConsume...

2018/11/07 09:32
124
聊聊storm的LoggingMetricsConsumer

序 本文主要研究一下storm的LoggingMetricsConsumer LoggingMetricsConsumer storm-2.0.0/storm-client/src/jvm/org/apache/storm/metric/LoggingMetricsConsumer.java public class Logging...

2018/11/06 14:36
66
聊聊storm的IEventLogger

序 本文主要研究一下storm的IEventLogger IEventLogger storm-2.0.0/storm-client/src/jvm/org/apache/storm/metric/IEventLogger.java /** EventLogger interface for logging the event in...

2018/11/05 09:12
155
聊聊storm trident的operations

序 本文主要研究一下storm trident的operations function filter projection Function storm-core-1.2.2-sources.jar!/org/apache/storm/trident/operation/Function.java public interface ...

聊聊storm trident的state

序 本文主要研究一下storm trident的state StateType storm-2.0.0/storm-client/src/jvm/org/apache/storm/trident/state/StateType.java public enum StateType { NON_TRANSACTIONAL, TRANS...

聊聊storm的CheckpointSpout

序 本文主要研究一下storm的CheckpointSpout TopologyBuilder storm-2.0.0/storm-client/src/jvm/org/apache/storm/topology/TopologyBuilder.java public StormTopology createTopology() {...

2018/11/02 09:43
178
聊聊storm client的netty buffer watermark

序 本文主要研究一下storm client的netty buffer watermark Config storm-2.0.0/storm-client/src/jvm/org/apache/storm/Config.java /** * Netty based messaging: The netty write buffer...

2018/11/01 09:25
149

没有更多内容

加载失败,请刷新页面

返回顶部
顶部