public class ContextEnvironmentFactory extends Object implements ExecutionEnvironmentFactory
Constructor and Description |
---|
ContextEnvironmentFactory(ClusterClient client,
List<URL> jarFilesToAttach,
List<URL> classpathsToAttach,
ClassLoader userCodeClassLoader,
int defaultParallelism,
boolean isDetached,
SavepointRestoreSettings savepointSettings) |
Modifier and Type | Method and Description |
---|---|
ExecutionEnvironment |
createExecutionEnvironment()
Creates an ExecutionEnvironment from this factory.
|
ExecutionEnvironment |
getLastEnvCreated() |
public ContextEnvironmentFactory(ClusterClient client, List<URL> jarFilesToAttach, List<URL> classpathsToAttach, ClassLoader userCodeClassLoader, int defaultParallelism, boolean isDetached, SavepointRestoreSettings savepointSettings)
public ExecutionEnvironment createExecutionEnvironment()
ExecutionEnvironmentFactory
createExecutionEnvironment
in interface ExecutionEnvironmentFactory
public ExecutionEnvironment getLastEnvCreated()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.