@Override
  public boolean doBuild(TopologyBuilder bldr, Set<String> stageNames) {
    setDefaultNameIfNone(StreamletNamePrefix.CONSUMER, stageNames);
    bldr.setBolt(getName(), new ConsumerSink<>(consumer),
        getNumPartitions()).shuffleGrouping(parent.getName(), parent.getStreamId());
    return true;
  }
@ Override public boolean doBuild ( TopologyBuilder bldr , Set < String > stageNames ) { setDefaultNameIfNone ( StreamletNamePrefix . CONSUMER , stageNames ) ; bldr . setBolt ( getName ( ) , new ConsumerSink < > ( consumer ) , getNumPartitions ( ) ) . shuffleGrouping ( parent . getName ( ) , parent . getStreamId ( ) ) ; return true ; }
Connect this streamlet to TopologyBuilder.
@param bldr The TopologyBuilder for the topology
@param stageNames The existing stage names
@return True if successful