Package | Description |
---|---|
org.apache.flink.runtime.minicluster | |
org.apache.flink.streaming.util | |
org.apache.flink.test.util |
Modifier and Type | Interface and Description |
---|---|
interface |
JobExecutorService
Interface to control
JobExecutor . |
Modifier and Type | Class and Description |
---|---|
class |
MiniCluster
MiniCluster to execute Flink jobs locally.
|
Modifier and Type | Method and Description |
---|---|
static void |
TestStreamEnvironment.setAsContext(JobExecutor jobExecutor,
int parallelism)
Sets the streaming context environment to a TestStreamEnvironment that runs its programs on
the given cluster with the given default parallelism.
|
static void |
TestStreamEnvironment.setAsContext(JobExecutor jobExecutor,
int parallelism,
Collection<Path> jarFiles,
Collection<URL> classpaths)
Sets the streaming context environment to a TestStreamEnvironment that runs its programs on
the given cluster with the given default parallelism and the specified jar files and class
paths.
|
Constructor and Description |
---|
TestStreamEnvironment(JobExecutor jobExecutor,
int parallelism) |
TestStreamEnvironment(JobExecutor jobExecutor,
int parallelism,
Collection<Path> jarFiles,
Collection<URL> classPaths) |
Modifier and Type | Method and Description |
---|---|
static void |
TestEnvironment.setAsContext(JobExecutor jobExecutor,
int parallelism)
Sets the current
ExecutionEnvironment to be a TestEnvironment . |
static void |
TestEnvironment.setAsContext(JobExecutor jobExecutor,
int parallelism,
Collection<Path> jarFiles,
Collection<URL> classPaths)
Sets the current
ExecutionEnvironment to be a TestEnvironment . |
Constructor and Description |
---|
TestEnvironment(JobExecutor executor,
int parallelism,
boolean isObjectReuseEnabled) |
TestEnvironment(JobExecutor jobExecutor,
int parallelism,
boolean isObjectReuseEnabled,
Collection<Path> jarFiles,
Collection<URL> classPaths) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.