Package org.apache.flink.runtime.jobmaster

Class JobMasterConfiguration

java.lang.Object

org.apache.flink.runtime.jobmaster.JobMasterConfiguration

public class JobMasterConfiguration
extends Object

Configuration for the JobMaster.

Constructor Summary

Constructors

Constructor	Description
JobMasterConfiguration(org.apache.flink.api.common.time.Time rpcTimeout, org.apache.flink.api.common.time.Time slotRequestTimeout, String tmpDirectory, RetryingRegistrationConfiguration retryingRegistrationConfiguration, org.apache.flink.configuration.Configuration configuration)

Method Summary

Modifier and Type	Method	Description
static JobMasterConfiguration	fromConfiguration(org.apache.flink.configuration.Configuration configuration)
org.apache.flink.configuration.Configuration	getConfiguration()
RetryingRegistrationConfiguration	getRetryingRegistrationConfiguration()
org.apache.flink.api.common.time.Time	getRpcTimeout()
org.apache.flink.api.common.time.Time	getSlotRequestTimeout()
String	getTmpDirectory()

Methods inherited from class java.lang.Object

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

Constructor Detail

JobMasterConfiguration

public JobMasterConfiguration(org.apache.flink.api.common.time.Time rpcTimeout,
                              org.apache.flink.api.common.time.Time slotRequestTimeout,
                              String tmpDirectory,
                              RetryingRegistrationConfiguration retryingRegistrationConfiguration,
                              org.apache.flink.configuration.Configuration configuration)

Method Detail

getRpcTimeout

public org.apache.flink.api.common.time.Time getRpcTimeout()

getSlotRequestTimeout

public org.apache.flink.api.common.time.Time getSlotRequestTimeout()

getTmpDirectory

public String getTmpDirectory()

getRetryingRegistrationConfiguration

public RetryingRegistrationConfiguration getRetryingRegistrationConfiguration()

getConfiguration

public org.apache.flink.configuration.Configuration getConfiguration()

fromConfiguration

public static JobMasterConfiguration fromConfiguration(org.apache.flink.configuration.Configuration configuration)