public class FairSchedulableBuilder extends Object implements SchedulableBuilder, Logging
Constructor and Description |
---|
FairSchedulableBuilder(Pool rootPool,
SparkConf conf) |
Modifier and Type | Method and Description |
---|---|
void |
addTaskSetManager(Schedulable manager,
java.util.Properties properties) |
void |
buildPools() |
int |
DEFAULT_MINIMUM_SHARE() |
String |
DEFAULT_POOL_NAME() |
String |
DEFAULT_SCHEDULER_FILE() |
scala.Enumeration.Value |
DEFAULT_SCHEDULING_MODE() |
int |
DEFAULT_WEIGHT() |
String |
FAIR_SCHEDULER_PROPERTIES() |
String |
MINIMUM_SHARES_PROPERTY() |
String |
POOL_NAME_PROPERTY() |
String |
POOLS_PROPERTY() |
Pool |
rootPool() |
scala.Option<String> |
schedulerAllocFile() |
String |
SCHEDULING_MODE_PROPERTY() |
String |
WEIGHT_PROPERTY() |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
public Pool rootPool()
rootPool
in interface SchedulableBuilder
public scala.Option<String> schedulerAllocFile()
public String DEFAULT_SCHEDULER_FILE()
public String FAIR_SCHEDULER_PROPERTIES()
public String DEFAULT_POOL_NAME()
public String MINIMUM_SHARES_PROPERTY()
public String SCHEDULING_MODE_PROPERTY()
public String WEIGHT_PROPERTY()
public String POOL_NAME_PROPERTY()
public String POOLS_PROPERTY()
public scala.Enumeration.Value DEFAULT_SCHEDULING_MODE()
public int DEFAULT_MINIMUM_SHARE()
public int DEFAULT_WEIGHT()
public void buildPools()
buildPools
in interface SchedulableBuilder
public void addTaskSetManager(Schedulable manager, java.util.Properties properties)
addTaskSetManager
in interface SchedulableBuilder