@Test public void testKryoRegistrations() { Config stormConfig = mock(Config.class); SpoutOutputBatcher.registerKryoClasses(stormConfig); verify(stormConfig).registerSerialization(Batch.class); verify(stormConfig).registerSerialization(BatchColumn.class); }
public static void registerKryoClasses(Config stormConfig) { AbstractBatchCollector.registerKryoClasses(stormConfig); }
SpoutOutputBatcher implements IRichSpout { public static void registerKryoClasses(Config stormConfig) { AbstractBatchCollector.registerKryoClasses(stormConfig); } }
SpoutOutputBatcher implements IRichSpout { public static void registerKryoClasses(Config stormConfig) { AbstractBatchCollector.registerKryoClasses(stormConfig); } SpoutOutputBatcher(IRichSpout spout, int batchSize);  SpoutOutputBatcher(IRichSpout spout, Map<String, Integer> batchSizes); }
SpoutOutputBatcher implements IRichSpout { public static void registerKryoClasses(Config stormConfig) { AbstractBatchCollector.registerKryoClasses(stormConfig); } SpoutOutputBatcher(IRichSpout spout, int batchSize);  SpoutOutputBatcher(IRichSpout spout, Map<String, Integer> batchSizes); @Override void open(@SuppressWarnings("rawtypes") Map conf, TopologyContext context, SpoutOutputCollector collector); @Override void close(); @Override void activate(); @Override void deactivate(); @Override void nextTuple(); @Override void ack(Object msgId); @Override void fail(Object msgId); @Override void declareOutputFields(OutputFieldsDeclarer declarer); @Override Map<String, Object> getComponentConfiguration(); static void registerKryoClasses(Config stormConfig); }
SpoutOutputBatcher implements IRichSpout { public static void registerKryoClasses(Config stormConfig) { AbstractBatchCollector.registerKryoClasses(stormConfig); } SpoutOutputBatcher(IRichSpout spout, int batchSize);  SpoutOutputBatcher(IRichSpout spout, Map<String, Integer> batchSizes); @Override void open(@SuppressWarnings("rawtypes") Map conf, TopologyContext context, SpoutOutputCollector collector); @Override void close(); @Override void activate(); @Override void deactivate(); @Override void nextTuple(); @Override void ack(Object msgId); @Override void fail(Object msgId); @Override void declareOutputFields(OutputFieldsDeclarer declarer); @Override Map<String, Object> getComponentConfiguration(); static void registerKryoClasses(Config stormConfig);  }