public class ParallelMergeReduceTest
extends java.lang.Object
构造器和说明 |
---|
ParallelMergeReduceTest() |
限定符和类型 | 方法和说明 |
---|---|
void |
parallelReduceFull() |
void |
reduceFull() |
void |
scanInnerSubscriber() |
void |
scanMainSubscriber() |
void |
scanMainSubscriberError() |
void |
scanOperator() |
@Test public void reduceFull()
@Test public void parallelReduceFull()
@Test public void scanOperator()
@Test public void scanMainSubscriber()
@Test public void scanMainSubscriberError()
@Test public void scanInnerSubscriber()