| minDuration=Math.min(minDuration,run(2 * PARALLELISM_FACTOR,PARALLELISM_FACTOR,new DelayFn<Integer>())); | maxConcurrency=Math.max(maxConcurrency,run(2 * PARALLELISM_FACTOR,PARALLELISM_FACTOR,new DelayFn<Integer>())); | Math.min(minDuration,run(2 * PARALLELISM_FACTOR,PARALLELISM_FACTOR,new DelayFn<Integer>())) | Math.max(minDuration,run(2 * PARALLELISM_FACTOR,PARALLELISM_FACTOR,new DelayFn<Integer>())) | beam | 50721f5935b8ca06774daa2f1fdfc97b3810df09 | com.google.cloud.dataflow.sdk.transforms.IntraBundleParallelizationTest | | | _1 | minDuration |
|---|
| _2 | maxConcurrency |
|---|
| | TCIVar | minDuration |
|---|
| v1 | run(2 * PARALLELISM_FACTOR,PARALLELISM_FACTOR,new DelayFn<Integer>()) |
|---|
| | | TCIVar | minDuration |
|---|
| v1 | run(2 * PARALLELISM_FACTOR,PARALLELISM_FACTOR,new DelayFn<Integer>()) |
|---|
| Uses | True |