Skip to content

Instantly share code, notes, and snippets.

What would you like to do?
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout(1, new KestrelSpout("",
new StringScheme()));
builder.setBolt(2, new SplitSentence(), 10)
builder.setBolt(3, new WordCount(), 20)
.fieldsGrouping(2, new Fields("word"));
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.