public class SchedulerUtils extends Object
Constructor and Description |
---|
SchedulerUtils() |
Modifier and Type | Method and Description |
---|---|
static String |
generateCapacitySchedulerXml(int numQueues,
double maximumCapacityPerQueue,
int maxRunningAppsPerQueue,
Set<String> labels) |
static String |
generateFairSchedulerXml(int maxRunningJobs,
int userMaxAppsDefault,
int maxRunningAppsPerQueue,
int numQueues,
String schedulingPolicy,
int minSharePreemptionTimeout,
Set<String> labels) |
static String |
generateNodeLabels(int numNodes,
Set<String> labels) |
static String |
generateProperty(String name,
String value) |
static void |
setScheduler(Path yarnSitePath,
String scheduler) |
public static String generateFairSchedulerXml(int maxRunningJobs, int userMaxAppsDefault, int maxRunningAppsPerQueue, int numQueues, String schedulingPolicy, int minSharePreemptionTimeout, Set<String> labels)
public static String generateCapacitySchedulerXml(int numQueues, double maximumCapacityPerQueue, int maxRunningAppsPerQueue, Set<String> labels)
public static void setScheduler(Path yarnSitePath, String scheduler) throws IOException
IOException
Copyright © 2018 Apache Software Foundation. All Rights Reserved.