Package 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	Description
ArchivedExecutionConfig(String restartStrategyDescription, int maxParallelism, int parallelism, boolean objectReuseEnabled, long periodicMaterializeIntervalMillis, Map<String,String> globalJobParameters)
ArchivedExecutionConfig(ExecutionConfig ec)

Method Summary

Modifier and Type	Method	Description
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 restartStrategyDescription,
                               int maxParallelism,
                               int parallelism,
                               boolean objectReuseEnabled,
                               long periodicMaterializeIntervalMillis,
                               Map<String,String> globalJobParameters)

Method Detail

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