AggregationClassifierBolt extends BaseRichBolt { @SuppressWarnings("rawtypes") @Override public void prepare(Map stormConf, TopologyContext context, OutputCollector collector) { this.collector = collector; this.gson = new Gson(); }  @SuppressWarnings("rawtypes") @Override void prepare(Map stormConf, TopologyContext context, OutputCollector collector); @Override void execute(Tuple tuple); @Override void declareOutputFields(OutputFieldsDeclarer declarer);  }
@Test public void testPrepare() { AggregationClassifierBolt bolt = new AggregationClassifierBolt(); Map<String, String> conf = new HashMap<>(); bolt.prepare(conf, null, collector); assertNotNull(bolt.getGson()); assertNotNull(bolt.getCollector()); }