public interface FlinkTestBase
extends org.scalatest.BeforeAndAfter
ExecutionEnvironment
.
This mixin starts a ForkableFlinkMiniCluster with one TaskManager and a number of slots given by parallelism. This value can be overridden in a sub class in order to start the cluster with a different number of slots.
The cluster is started once before starting the tests and is re-used for the individual tests. After all tests have been executed, the cluster is shutdown.
The cluster is used by obtaining the default ExecutionEnvironment
.
Modifier and Type | Method and Description |
---|---|
scala.Option<ForkableFlinkMiniCluster> |
cluster() |
int |
parallelism() |
after, before, org$scalatest$BeforeAndAfter$_setter_$org$scalatest$BeforeAndAfter$$afterFunctionAtomic_$eq, org$scalatest$BeforeAndAfter$_setter_$org$scalatest$BeforeAndAfter$$beforeFunctionAtomic_$eq, org$scalatest$BeforeAndAfter$$afterFunctionAtomic, org$scalatest$BeforeAndAfter$$beforeFunctionAtomic, org$scalatest$BeforeAndAfter$$runHasBeenInvoked_$eq, org$scalatest$BeforeAndAfter$$runHasBeenInvoked, org$scalatest$BeforeAndAfter$$super$run, org$scalatest$BeforeAndAfter$$super$runTest, run, runTest
scala.Option<ForkableFlinkMiniCluster> cluster()
int parallelism()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.