Package | Description |
---|---|
org.apache.flink.streaming.util | |
org.apache.flink.test.util |
Modifier and Type | Field and Description |
---|---|
protected static LocalFlinkMiniCluster |
StreamingMultipleProgramsTestBase.cluster |
Modifier and Type | Method and Description |
---|---|
static void |
TestStreamEnvironment.setAsContext(LocalFlinkMiniCluster 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(LocalFlinkMiniCluster executor,
int parallelism) |
Modifier and Type | Field and Description |
---|---|
protected static LocalFlinkMiniCluster |
MultipleProgramsTestBase.cluster |
protected LocalFlinkMiniCluster |
AbstractTestBase.executor
The mini cluster that runs the test programs
|
Modifier and Type | Method and Description |
---|---|
static LocalFlinkMiniCluster |
TestBaseUtils.startCluster(Configuration config,
boolean singleActorSystem) |
static LocalFlinkMiniCluster |
TestBaseUtils.startCluster(int numTaskManagers,
int taskManagerNumSlots,
boolean startWebserver,
boolean startZooKeeper,
boolean singleActorSystem) |
Modifier and Type | Method and Description |
---|---|
static void |
TestBaseUtils.stopCluster(LocalFlinkMiniCluster executor,
scala.concurrent.duration.FiniteDuration timeout) |
Constructor and Description |
---|
TestEnvironment(LocalFlinkMiniCluster executor,
int parallelism) |
TestEnvironment(LocalFlinkMiniCluster executor,
int parallelism,
boolean isObjectReuseEnabled) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.