我有一个从Kafka那里得到元组的拓扑结构。
拓扑结构大致如下所示。

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());

从文档中我了解到，在聚合器中，聚合方法是为每个元组调用的，完整方法是在处理所有元组时调用的。
我已经在init和aggregate方法中调试了sysout。当我启动拓扑时，我可以看到init和aggregate方法中的连续sysout。这种行为是预期的吗(注意，Kafka中没有数据）