Modifier and Type | Method and Description |
---|---|
PipelineExecutorServiceLoader |
ExecutionEnvironment.getExecutorServiceLoader()
Deprecated.
|
Constructor and Description |
---|
ExecutionEnvironment(PipelineExecutorServiceLoader executorServiceLoader,
Configuration configuration,
ClassLoader userClassloader)
Deprecated.
Creates a new
ExecutionEnvironment that will use the given Configuration to
configure the PipelineExecutor . |
Modifier and Type | Method and Description |
---|---|
static void |
ClientUtils.executeProgram(PipelineExecutorServiceLoader executorServiceLoader,
Configuration configuration,
PackagedProgram program,
boolean enforceSingleJobExecution,
boolean suppressSysout) |
Modifier and Type | Class and Description |
---|---|
class |
EmbeddedExecutorServiceLoader
A
PipelineExecutorServiceLoader that always returns an EmbeddedExecutorFactory . |
class |
WebSubmissionExecutorServiceLoader
A
PipelineExecutorServiceLoader that always returns an WebSubmissionExecutorFactory . |
Modifier and Type | Method and Description |
---|---|
static void |
ContextEnvironment.setAsContext(PipelineExecutorServiceLoader executorServiceLoader,
Configuration configuration,
ClassLoader userCodeClassLoader,
boolean enforceSingleJobExecution,
boolean suppressSysout) |
static void |
StreamContextEnvironment.setAsContext(PipelineExecutorServiceLoader executorServiceLoader,
Configuration clusterConfiguration,
ClassLoader userCodeClassLoader,
boolean enforceSingleJobExecution,
boolean suppressSysout) |
Constructor and Description |
---|
ContextEnvironment(PipelineExecutorServiceLoader executorServiceLoader,
Configuration configuration,
ClassLoader userCodeClassLoader,
boolean enforceSingleJobExecution,
boolean suppressSysout) |
StreamContextEnvironment(PipelineExecutorServiceLoader executorServiceLoader,
Configuration configuration,
ClassLoader userCodeClassLoader,
boolean enforceSingleJobExecution,
boolean suppressSysout) |
StreamContextEnvironment(PipelineExecutorServiceLoader executorServiceLoader,
Configuration clusterConfiguration,
Configuration configuration,
ClassLoader userCodeClassLoader,
boolean enforceSingleJobExecution,
boolean suppressSysout,
boolean programConfigEnabled,
Collection<String> programConfigWildcards) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultExecutorServiceLoader
The default implementation of the
PipelineExecutorServiceLoader . |
Modifier and Type | Method and Description |
---|---|
static void |
ExecutionContextEnvironment.setAsContext(PipelineExecutorServiceLoader executorServiceLoader,
Configuration clusterConfiguration,
ClassLoader userCodeClassLoader) |
Constructor and Description |
---|
ExecutionContextEnvironment(PipelineExecutorServiceLoader executorServiceLoader,
Configuration configuration,
ClassLoader userCodeClassLoader) |
Constructor and Description |
---|
RemoteStreamEnvironment(PipelineExecutorServiceLoader executorServiceLoader,
String host,
int port,
Configuration clientConfiguration,
String[] jarFiles,
URL[] globalClasspaths,
SavepointRestoreSettings savepointRestoreSettings) |
StreamExecutionEnvironment(PipelineExecutorServiceLoader executorServiceLoader,
Configuration configuration,
ClassLoader userClassloader)
Creates a new
StreamExecutionEnvironment that will use the given Configuration to configure the PipelineExecutor . |
Modifier and Type | Class and Description |
---|---|
class |
MiniClusterPipelineExecutorServiceLoader
A
PipelineExecutorServiceLoader that is hardwired to return PipelineExecutors that use a given MiniCluster . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.