Package | Description |
---|---|
org.apache.flink.streaming.util | |
org.apache.flink.test.util |
Modifier and Type | Field and Description |
---|---|
protected static ForkableFlinkMiniCluster |
StreamingMultipleProgramsTestBase.cluster |
Modifier and Type | Method and Description |
---|---|
static void |
TestStreamEnvironment.setAsContext(ForkableFlinkMiniCluster cluster,
int parallelism)
Sets the streaming context environment to a TestStreamEnvironment that runs its programs on
the given cluster with the given default parallelism.
|
Constructor and Description |
---|
TestStreamEnvironment(ForkableFlinkMiniCluster executor,
int parallelism) |
Modifier and Type | Field and Description |
---|---|
protected static ForkableFlinkMiniCluster |
MultipleProgramsTestBase.cluster |
protected ForkableFlinkMiniCluster |
AbstractTestBase.executor
The mini cluster that runs the test programs
|
Modifier and Type | Method and Description |
---|---|
static ForkableFlinkMiniCluster |
TestBaseUtils.startCluster(Configuration config,
boolean singleActorSystem) |
static ForkableFlinkMiniCluster |
TestBaseUtils.startCluster(int numTaskManagers,
int taskManagerNumSlots,
boolean startWebserver,
boolean startZooKeeper,
boolean singleActorSystem) |
ForkableFlinkMiniCluster |
ForkableFlinkMiniCluster$.startCluster(int numSlots,
int numTaskManagers,
String timeout) |
static ForkableFlinkMiniCluster |
ForkableFlinkMiniCluster.startCluster(int numSlots,
int numTaskManagers,
String timeout) |
Modifier and Type | Method and Description |
---|---|
static void |
TestBaseUtils.stopCluster(ForkableFlinkMiniCluster executor,
scala.concurrent.duration.FiniteDuration timeout) |
Constructor and Description |
---|
TestEnvironment(ForkableFlinkMiniCluster executor,
int parallelism) |
TestEnvironment(ForkableFlinkMiniCluster executor,
int parallelism,
boolean isObjectReuseEnabled) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.