public class TaskManagerConfiguration extends Object implements scala.Product, scala.Serializable
Constructor and Description |
---|
TaskManagerConfiguration(String[] tmpDirPaths,
long cleanupInterval,
scala.concurrent.duration.FiniteDuration timeout,
scala.Option<scala.concurrent.duration.FiniteDuration> maxRegistrationDuration,
int numberOfSlots,
Configuration configuration) |
TaskManagerConfiguration(String[] tmpDirPaths,
long cleanupInterval,
scala.concurrent.duration.FiniteDuration timeout,
scala.Option<scala.concurrent.duration.FiniteDuration> maxRegistrationDuration,
int numberOfSlots,
Configuration configuration,
scala.concurrent.duration.FiniteDuration initialRegistrationPause,
scala.concurrent.duration.FiniteDuration maxRegistrationPause,
scala.concurrent.duration.FiniteDuration refusedRegistrationPause) |
Modifier and Type | Method and Description |
---|---|
long |
cleanupInterval() |
Configuration |
configuration() |
scala.concurrent.duration.FiniteDuration |
initialRegistrationPause() |
scala.Option<scala.concurrent.duration.FiniteDuration> |
maxRegistrationDuration() |
scala.concurrent.duration.FiniteDuration |
maxRegistrationPause() |
int |
numberOfSlots() |
scala.concurrent.duration.FiniteDuration |
refusedRegistrationPause() |
scala.concurrent.duration.FiniteDuration |
timeout() |
String[] |
tmpDirPaths() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public TaskManagerConfiguration(String[] tmpDirPaths, long cleanupInterval, scala.concurrent.duration.FiniteDuration timeout, scala.Option<scala.concurrent.duration.FiniteDuration> maxRegistrationDuration, int numberOfSlots, Configuration configuration, scala.concurrent.duration.FiniteDuration initialRegistrationPause, scala.concurrent.duration.FiniteDuration maxRegistrationPause, scala.concurrent.duration.FiniteDuration refusedRegistrationPause)
public TaskManagerConfiguration(String[] tmpDirPaths, long cleanupInterval, scala.concurrent.duration.FiniteDuration timeout, scala.Option<scala.concurrent.duration.FiniteDuration> maxRegistrationDuration, int numberOfSlots, Configuration configuration)
public String[] tmpDirPaths()
public long cleanupInterval()
public scala.concurrent.duration.FiniteDuration timeout()
public scala.Option<scala.concurrent.duration.FiniteDuration> maxRegistrationDuration()
public int numberOfSlots()
public Configuration configuration()
public scala.concurrent.duration.FiniteDuration initialRegistrationPause()
public scala.concurrent.duration.FiniteDuration maxRegistrationPause()
public scala.concurrent.duration.FiniteDuration refusedRegistrationPause()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.