java – 在storm中使用字段分组时,已知字段值或超时是否有限制?
作者:互联网
我使用Apache Storm进行字段分组,效果很好.
但是如果我有无数个字段值,那就意味着风暴必须在其螺栓中跟踪无限数量的值!否则,某些值将转到错误的螺栓,它将破坏任何缓存技术.
我想在螺栓的某个地方有一个缓存,它有一个到期系统或/和对字段值数量的限制,以检查螺栓字段分组.是否可以调整/覆盖它?
解决方法:
您不需要缓存,fieldsGrouping使用mod哈希函数来确定要发送元组的任务,因此您可以确保将在正确的任务中处理.
标签:java,apache-storm 来源: https://codeday.me/bug/20190624/1277368.html