org.apache.flink.api.common

Class ArchivedExecutionConfig

java.lang.Object

org.apache.flink.api.common.ArchivedExecutionConfig

All Implemented Interfaces:

Serializable

@Internal
public class ArchivedExecutionConfig
extends Object
implements Serializable

Serializable class which is created when archiving the job. It can be used to display job information on the web interface without having to keep the classloader around after job completion.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ArchivedExecutionConfig(ExecutionConfig ec)
ArchivedExecutionConfig(String executionMode, String restartStrategyDescription, int maxParallelism, int parallelism, boolean objectReuseEnabled, long periodicMaterializeIntervalMillis, Map<String,String> globalJobParameters)

Method Summary

Modifier and Type	Method and Description
String	getExecutionMode()
Map<String,String>	getGlobalJobParameters()
int	getMaxParallelism()
boolean	getObjectReuseEnabled()
int	getParallelism()
long	getPeriodicMaterializeIntervalMillis()
String	getRestartStrategyDescription()

Methods inherited from class java.lang.Object

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

Constructor Detail

ArchivedExecutionConfig

public ArchivedExecutionConfig(ExecutionConfig ec)

ArchivedExecutionConfig

public ArchivedExecutionConfig(String executionMode,
                               String restartStrategyDescription,
                               int maxParallelism,
                               int parallelism,
                               boolean objectReuseEnabled,
                               long periodicMaterializeIntervalMillis,
                               Map<String,String> globalJobParameters)

Method Detail

getExecutionMode

public String getExecutionMode()

getRestartStrategyDescription

public String getRestartStrategyDescription()

getMaxParallelism

public int getMaxParallelism()

getParallelism

public int getParallelism()

getObjectReuseEnabled

public boolean getObjectReuseEnabled()

getPeriodicMaterializeIntervalMillis

public long getPeriodicMaterializeIntervalMillis()

getGlobalJobParameters

public Map<String,String> getGlobalJobParameters()