public LoadCompConf scaleParallel(double v) {
        return setParallel(Math.max(1, (int) Math.ceil(parallelism * v)));
    }
@Test
    public void scaleParallel() {
        LoadCompConf orig = new LoadCompConf.Builder()
            .withId("SOME_SPOUT")
            .withParallelism(1)
            .withStream(new OutputStream("default", new NormalDistStats(500.0, 100.0, 300.0, 600.0), false))
            .build();
        assertEquals(500.0, orig.getAllEmittedAggregate(), 0.001);
        LoadCompConf scaled = orig.scaleParallel(2);
        //Parallelism is double
        assertEquals(2, scaled.parallelism);
        assertEquals("SOME_SPOUT", scaled.id);
        //But throughput is the same
        assertEquals(500.0, scaled.getAllEmittedAggregate(), 0.001);
    }