这是配置:
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")
?
1条答案
按热度按时间y0u0uwnf1#
字段分组:流按分组中指定的字段进行分区。例如,如果流按“user id”字段分组,则具有相同“user id”的元组将始终转到同一个任务,但是具有不同“user id”的元组可能转到不同的任务。
http://storm.apache.org/releases/1.0.0/concepts.html