1

カフカからタプルを取得するトポロジがあります。

トポロジーは大まかにこんな感じです。

topology.newStream("kafkaSpout", spout)
            .shuffle()
            .each(new Fields("str"), new Filter())
            .parallelismHint(5)
            .each(new Fields("str"), new Function(),
                  new Fields("some fields"))
            .parallelismHint(5)
            .partitionBy(new Fields("some field"))
            .partitionAggregate(new Fields("some fields"), 
                                new SomeAggregator(), 
                                new Fields(""some fields""))
            .parallelismHint(5)
            .partitionPersist(new StateFactory(),
                              new Fields("some filed"),
                              new StateUpdater());

ドキュメントから私が理解しているのは、アグリゲーターではすべてのタプルに対して集約メソッドが呼び出され、すべてのタプルが処理されると完全なメソッドが呼び出されるということです。

初期化および集約メソッドにデバッグ sysout を入れました。トポロジーを開始すると、init および aggregate メソッドからの連続した sysout を確認できます。この動作は予期されたものですか? (Kafka にはデータがないことに注意してください)

4

0 に答える 0