Class ParallelExecutionTests


  • public class ParallelExecutionTests
    extends Object
    • Constructor Detail

      • ParallelExecutionTests

        public ParallelExecutionTests()
    • Method Detail

      • testInvokeJobWithOnePartitionedStep

        public void testInvokeJobWithOnePartitionedStep()
                                                 throws Exception
        Throws:
        Exception
      • testInvokeJobWithOnePartitionedStepExitStatus

        public void testInvokeJobWithOnePartitionedStepExitStatus()
                                                           throws Exception
        Throws:
        Exception
      • testStopRunningPartitionedStep

        public void testStopRunningPartitionedStep()
                                            throws Exception
        Throws:
        Exception
      • testStopRestartRunningPartitionedStep

        public void testStopRestartRunningPartitionedStep()
                                                   throws Exception
        Throws:
        Exception
      • testInvokeJobSimpleSplit

        public void testInvokeJobSimpleSplit()
                                      throws Exception
        Throws:
        Exception
      • testPartitionedPlanCollectorAnalyzerReducerComplete

        public void testPartitionedPlanCollectorAnalyzerReducerComplete()
                                                                 throws Exception
        Throws:
        Exception
      • testZeroBasedPartitionedPlanCollectorAnalyzerReducerRollback

        public void testZeroBasedPartitionedPlanCollectorAnalyzerReducerRollback()
                                                                          throws Exception
        Throws:
        Exception
      • testPartitionedCollectorAnalyzerReducerChunkRestartItemCount10

        public void testPartitionedCollectorAnalyzerReducerChunkRestartItemCount10()
                                                                            throws Exception
        Throws:
        Exception
      • testPartitionedMapperOverrideFalseOnRestart

        public void testPartitionedMapperOverrideFalseOnRestart()
                                                         throws Exception
        Throws:
        Exception
      • testPartitionedMapperOverrideTrueDiffPartitionNumOnRestart

        public void testPartitionedMapperOverrideTrueDiffPartitionNumOnRestart()
                                                                        throws Exception
        Throws:
        Exception
      • testPartitionedMapperOverrideTrueSamePartitionNumOnRestart

        public void testPartitionedMapperOverrideTrueSamePartitionNumOnRestart()
                                                                        throws Exception
        Throws:
        Exception