@Test public void testKryoRegistrations() { Config stormConfig = mock(Config.class); AbstractBatchCollector.registerKryoClasses(stormConfig); verify(stormConfig).registerSerialization(Batch.class); verify(stormConfig).registerSerialization(BatchColumn.class); }
public static void registerKryoClasses(Config stormConfig) { stormConfig.registerSerialization(Batch.class); stormConfig.registerSerialization(BatchColumn.class); }
AbstractBatchCollector { public static void registerKryoClasses(Config stormConfig) { stormConfig.registerSerialization(Batch.class); stormConfig.registerSerialization(BatchColumn.class); } }
AbstractBatchCollector { public static void registerKryoClasses(Config stormConfig) { stormConfig.registerSerialization(Batch.class); stormConfig.registerSerialization(BatchColumn.class); } AbstractBatchCollector(TopologyContext context, int batchSize);  AbstractBatchCollector(TopologyContext context, Map<String, Integer> batchSizes); private  AbstractBatchCollector(TopologyContext context, HashMap<String, Integer> batchSizes); }
AbstractBatchCollector { public static void registerKryoClasses(Config stormConfig) { stormConfig.registerSerialization(Batch.class); stormConfig.registerSerialization(BatchColumn.class); } AbstractBatchCollector(TopologyContext context, int batchSize);  AbstractBatchCollector(TopologyContext context, Map<String, Integer> batchSizes); private  AbstractBatchCollector(TopologyContext context, HashMap<String, Integer> batchSizes); List<Integer> tupleEmit(String streamId, Collection<Tuple> anchors, List<Object> tuple, Object messageId); void tupleEmitDirect(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple, Object messageId); void flush(); static void registerKryoClasses(Config stormConfig); }
AbstractBatchCollector { public static void registerKryoClasses(Config stormConfig) { stormConfig.registerSerialization(Batch.class); stormConfig.registerSerialization(BatchColumn.class); } AbstractBatchCollector(TopologyContext context, int batchSize);  AbstractBatchCollector(TopologyContext context, Map<String, Integer> batchSizes); private  AbstractBatchCollector(TopologyContext context, HashMap<String, Integer> batchSizes); List<Integer> tupleEmit(String streamId, Collection<Tuple> anchors, List<Object> tuple, Object messageId); void tupleEmitDirect(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple, Object messageId); void flush(); static void registerKryoClasses(Config stormConfig);  }