org.apache.flink.client.cli

Class ExecutionConfigAccessor

java.lang.Object

org.apache.flink.client.cli.ExecutionConfigAccessor

@Internal
public class ExecutionConfigAccessor
extends Object

Accessor that exposes config settings that are relevant for execution from an underlying Configuration.

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

fromConfiguration

public static ExecutionConfigAccessor fromConfiguration(Configuration configuration)

Creates an ExecutionConfigAccessor based on the provided Configuration.

fromProgramOptions

public 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.

applyToConfiguration

public Configuration applyToConfiguration(Configuration baseConfiguration)

getJars

public List<URL> getJars()
                  throws MalformedURLException

Throws:

MalformedURLException

getClasspaths

public List<URL> getClasspaths()
                        throws MalformedURLException

Throws:

MalformedURLException

getParallelism

public int getParallelism()

getDetachedMode

public boolean getDetachedMode()

getSavepointRestoreSettings

public SavepointRestoreSettings getSavepointRestoreSettings()

isShutdownOnAttachedExit

public boolean isShutdownOnAttachedExit()