@Test public void testKryoRegistrations() { Config stormConfig = mock(Config.class); BoltOutputBatcher.registerKryoClasses(stormConfig); verify(stormConfig).registerSerialization(Batch.class); verify(stormConfig).registerSerialization(BatchColumn.class); }
public static void registerKryoClasses(Config stormConfig) { AbstractBatchCollector.registerKryoClasses(stormConfig); }
BoltOutputBatcher implements IRichBolt { public static void registerKryoClasses(Config stormConfig) { AbstractBatchCollector.registerKryoClasses(stormConfig); } }
BoltOutputBatcher implements IRichBolt { public static void registerKryoClasses(Config stormConfig) { AbstractBatchCollector.registerKryoClasses(stormConfig); } BoltOutputBatcher(IRichBolt bolt, int batchSize);  BoltOutputBatcher(IRichBolt bolt, Map<String, Integer> batchSizes); }
BoltOutputBatcher implements IRichBolt { public static void registerKryoClasses(Config stormConfig) { AbstractBatchCollector.registerKryoClasses(stormConfig); } BoltOutputBatcher(IRichBolt bolt, int batchSize);  BoltOutputBatcher(IRichBolt bolt, Map<String, Integer> batchSizes); @Override void prepare(@SuppressWarnings("rawtypes") Map stormConf, TopologyContext context, OutputCollector collector); @Override void execute(Tuple input); @Override void cleanup(); @Override void declareOutputFields(OutputFieldsDeclarer declarer); @Override Map<String, Object> getComponentConfiguration(); static void registerKryoClasses(Config stormConfig); }
BoltOutputBatcher implements IRichBolt { public static void registerKryoClasses(Config stormConfig) { AbstractBatchCollector.registerKryoClasses(stormConfig); } BoltOutputBatcher(IRichBolt bolt, int batchSize);  BoltOutputBatcher(IRichBolt bolt, Map<String, Integer> batchSizes); @Override void prepare(@SuppressWarnings("rawtypes") Map stormConf, TopologyContext context, OutputCollector collector); @Override void execute(Tuple input); @Override void cleanup(); @Override void declareOutputFields(OutputFieldsDeclarer declarer); @Override Map<String, Object> getComponentConfiguration(); static void registerKryoClasses(Config stormConfig);  }