Package org.apache.flink.test.util

Class AbstractTestBase

  • Direct Known Subclasses:
    JavaProgramTestBase, MultipleProgramsTestBase
    public abstract class AbstractTestBase
extends Object
    Base class for unit tests that run multiple tests and want to reuse the same Flink cluster. This saves a significant amount of time, since the startup and shutdown of the Flink clusters (including actor systems, etc) usually dominates the execution of the actual tests.

    To write a unit test against this test base, simply extend it and add one or more regular test methods and retrieve the StreamExecutionEnvironment from the context: 

       @Test
   public void someTest() {
       ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
       // test code
       env.execute();
   }

   @Test
   public void anotherTest() {
       StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
       // test code
       env.execute();
   }