define a new bolt in this topology with the specified amount of parallelism . concode_field_sep TopologyBuilder stormBuilder concode_elem_sep HashMap<String,IRichSpout> spouts concode_elem_sep HashMap<String,IRichBolt> bolts concode_field_sep SpoutDeclarer setSpout concode_elem_sep SpoutDeclarer setSpout concode_elem_sep FlinkTopology createTopology
BoltDeclarer function ( final String arg0 , final IRichBolt arg1 , final Number arg2 ) { final BoltDeclarer loc0 = this . stormBuilder . setBolt ( arg0 , arg1 , arg2 ) ; this . bolts . put ( arg0 , arg1 ) ; return loc0 ; }