在Storm中是什么意思?

brqmpdu1  于 2021-06-21  发布在  Storm
关注(0)|答案(1)|浏览(513)

这是配置:

TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("1", new Produce(), 1);  
builder.setBolt("2", new Output(), 4).shuffleGrouping("1");
builder.setBolt("3", new Writer(), 8).fieldsGrouping("2", new Fields("ahah","bb"));

# And tuple "ahah" include{"aaa","bbb","ccc","ddd"}

# tuple "bb" include {"ee","ff","gg","kk"}

3个螺栓有8个螺纹,分组为 fieldsGrouping ,字段包括“ahah”和“bb”。
我不知道3个螺栓的8个螺纹是怎么工作的?
同一个元组是什么意思?菲尔德的 name("ahah","bb") ? 或者菲尔德的 content("aaa","bbb","ccc","ddd","ee","ff","gg","kk") ?

y0u0uwnf

y0u0uwnf1#

字段分组:流按分组中指定的字段进行分区。例如,如果流按“user id”字段分组,则具有相同“user id”的元组将始终转到同一个任务,但是具有不同“user id”的元组可能转到不同的任务。
http://storm.apache.org/releases/1.0.0/concepts.html

相关问题