请问是谁使用storm ieventlogger接口记录事件值的。我不明白,它是如何在一些定制的java应用程序中使用的。它将使用一些线程还是与线程的应用程序?我们需要如何获取/设置风暴配置和拓扑上下文。。。等。http://storm.apache.org/releases/1.0.3/eventlogging.html (扩展事件日志记录)
5kgi1eie1#
设置拓扑时,可以在配置中注册它。https://github.com/apache/storm/blob/80cc88112bf4fab34571ebff03782b759d112288/storm-core/src/jvm/org/apache/storm/config.java#l2412编辑:为了提供更多细节,您的事件记录器将作为eventloggerbolt的一部分运行(https://github.com/apache/storm/blob/1.x-branch/storm-core/src/jvm/org/apache/storm/metric/eventloggerbolt.java)如果将topology.eventlogger.executors设置为非0值,则该风暴会自动添加到拓扑中。如您所见,bolt将调用事件记录器上的prepare方法,因此您将有机会从中获取拓扑配置和上下文。编辑2:我注意到你正在使用Storm1.0.3。您需要升级到更高的storm版本,我引用的方法在该版本中不存在。
1条答案
按热度按时间5kgi1eie1#
设置拓扑时,可以在配置中注册它。https://github.com/apache/storm/blob/80cc88112bf4fab34571ebff03782b759d112288/storm-core/src/jvm/org/apache/storm/config.java#l2412
编辑:为了提供更多细节,您的事件记录器将作为eventloggerbolt的一部分运行(https://github.com/apache/storm/blob/1.x-branch/storm-core/src/jvm/org/apache/storm/metric/eventloggerbolt.java)如果将topology.eventlogger.executors设置为非0值,则该风暴会自动添加到拓扑中。如您所见,bolt将调用事件记录器上的prepare方法,因此您将有机会从中获取拓扑配置和上下文。
编辑2:我注意到你正在使用Storm1.0.3。您需要升级到更高的storm版本,我引用的方法在该版本中不存在。