@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 ExecutionConfigAccessor |
fromProgramOptions(ProgramOptions options,
List<URL> 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 ExecutionConfigAccessor fromProgramOptions(ProgramOptions options, List<URL> jobJars)
ExecutionConfigAccessor
based on the provided ProgramOptions
as provided by the user through the CLI.public Configuration applyToConfiguration(Configuration baseConfiguration)
public int getParallelism()
public boolean getDetachedMode()
public SavepointRestoreSettings getSavepointRestoreSettings()
public boolean isShutdownOnAttachedExit()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.