Modifier and Type | Method and Description |
---|---|
PipelineExecutorServiceLoader |
ExecutionEnvironment.getExecutorServiceLoader() |
Constructor and Description |
---|
ExecutionEnvironment(PipelineExecutorServiceLoader executorServiceLoader,
Configuration configuration,
ClassLoader userClassloader)
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) |
Constructor and Description |
---|
ContextEnvironmentFactory(PipelineExecutorServiceLoader executorServiceLoader,
Configuration configuration,
ClassLoader userCodeClassLoader) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultExecutorServiceLoader
The default implementation of the
PipelineExecutorServiceLoader . |
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 . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.