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>())); | minDuration=Math.min(minDuration,run(2 * PARALLELISM_FACTOR,PARALLELISM_FACTOR,new DelayFn<Integer>())) | minDuration=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 |
---|
v2 | run(2 * PARALLELISM_FACTOR,PARALLELISM_FACTOR,new DelayFn<Integer>()) |
---|
| | TCIVar | minDuration |
---|
v2 | run(2 * PARALLELISM_FACTOR,PARALLELISM_FACTOR,new DelayFn<Integer>()) |
---|
| Uses | True |