@Internal public class ExecutionConfigAccessor extends Object
Configuration
.Modifier and Type | Method and Description |
---|---|
Configuration |
applyToConfiguration(Configuration baseConfiguration) |
static ExecutionConfigAccessor |
fromConfiguration(Configuration configuration)
Creates an
ExecutionConfigAccessor based on the provided Configuration . |
static <T> ExecutionConfigAccessor |
fromProgramOptions(ProgramOptions options,
List<T> jobJars)
Creates an
ExecutionConfigAccessor based on the provided ProgramOptions as
provided by the user through the CLI. |
List<URL> |
getClasspaths() |
boolean |
getDetachedMode() |
List<URL> |
getJars() |
int |
getParallelism() |
SavepointRestoreSettings |
getSavepointRestoreSettings() |
boolean |
isShutdownOnAttachedExit() |
public static ExecutionConfigAccessor fromConfiguration(Configuration configuration)
ExecutionConfigAccessor
based on the provided Configuration
.public static <T> ExecutionConfigAccessor fromProgramOptions(ProgramOptions options, List<T> jobJars)
ExecutionConfigAccessor
based on the provided ProgramOptions
as
provided by the user through the CLI.public Configuration applyToConfiguration(Configuration baseConfiguration)
public List<URL> getJars() throws MalformedURLException
MalformedURLException
public List<URL> getClasspaths() throws MalformedURLException
MalformedURLException
public int getParallelism()
public boolean getDetachedMode()
public SavepointRestoreSettings getSavepointRestoreSettings()
public boolean isShutdownOnAttachedExit()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.