Fields Grouping
2021SC@SDUSC
以代码为例:
public class Toplogy {
public static void main(String[] args) {
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("spout", new Spot(), 1);
builder.setBolt("bolt",new Bolt() , 3).fieldsGrouping("spout", new Fields("field0"));
Config conf = new Config();
conf.setDebug(false);
LocalCluster cluster = new LocalCluster();
cluster.submitTopology("toplogy", conf, bu
共有 0 条评论