@Test(expected = AllocationConfigurationException.class) public void testOnlyGPU() throws Exception { parseResourceConfigValue("1024gcores"); }
public static Resource parseResourceConfigValue(String val) throws AllocationConfigurationException { try { val = StringUtils.toLowerCase(val); int memory = findResource(val, "mb"); int vcores = findResource(val, "vcores"); int gcores = findResource(val, "gcores"); return BuilderUtils.newResource(memory, vcores, gcores); } catch (AllocationConfigurationException ex) { throw ex; } catch (Exception ex) { throw new AllocationConfigurationException( "Error reading resource config", ex); } }
FairSchedulerConfiguration extends Configuration { public static Resource parseResourceConfigValue(String val) throws AllocationConfigurationException { try { val = StringUtils.toLowerCase(val); int memory = findResource(val, "mb"); int vcores = findResource(val, "vcores"); int gcores = findResource(val, "gcores"); return BuilderUtils.newResource(memory, vcores, gcores); } catch (AllocationConfigurationException ex) { throw ex; } catch (Exception ex) { throw new AllocationConfigurationException( "Error reading resource config", ex); } } }
FairSchedulerConfiguration extends Configuration { public static Resource parseResourceConfigValue(String val) throws AllocationConfigurationException { try { val = StringUtils.toLowerCase(val); int memory = findResource(val, "mb"); int vcores = findResource(val, "vcores"); int gcores = findResource(val, "gcores"); return BuilderUtils.newResource(memory, vcores, gcores); } catch (AllocationConfigurationException ex) { throw ex; } catch (Exception ex) { throw new AllocationConfigurationException( "Error reading resource config", ex); } } FairSchedulerConfiguration();  FairSchedulerConfiguration(Configuration conf); }
FairSchedulerConfiguration extends Configuration { public static Resource parseResourceConfigValue(String val) throws AllocationConfigurationException { try { val = StringUtils.toLowerCase(val); int memory = findResource(val, "mb"); int vcores = findResource(val, "vcores"); int gcores = findResource(val, "gcores"); return BuilderUtils.newResource(memory, vcores, gcores); } catch (AllocationConfigurationException ex) { throw ex; } catch (Exception ex) { throw new AllocationConfigurationException( "Error reading resource config", ex); } } FairSchedulerConfiguration();  FairSchedulerConfiguration(Configuration conf); Resource getMinimumAllocation(); Resource getMaximumAllocation(); Resource getIncrementAllocation(); float getLocalityThresholdNode(); float getLocalityThresholdRack(); boolean isContinuousSchedulingEnabled(); int getContinuousSchedulingSleepMs(); long getLocalityDelayNodeMs(); long getLocalityDelayRackMs(); boolean getPreemptionEnabled(); float getPreemptionUtilizationThreshold(); boolean getAssignMultiple(); int getMaxAssign(); boolean getSizeBasedWeight(); boolean isEventLogEnabled(); String getEventlogDir(); int getPreemptionInterval(); int getWaitTimeBeforeKill(); boolean getUsePortForNodeName(); static Resource parseResourceConfigValue(String val); long getUpdateInterval(); }
FairSchedulerConfiguration extends Configuration { public static Resource parseResourceConfigValue(String val) throws AllocationConfigurationException { try { val = StringUtils.toLowerCase(val); int memory = findResource(val, "mb"); int vcores = findResource(val, "vcores"); int gcores = findResource(val, "gcores"); return BuilderUtils.newResource(memory, vcores, gcores); } catch (AllocationConfigurationException ex) { throw ex; } catch (Exception ex) { throw new AllocationConfigurationException( "Error reading resource config", ex); } } FairSchedulerConfiguration();  FairSchedulerConfiguration(Configuration conf); Resource getMinimumAllocation(); Resource getMaximumAllocation(); Resource getIncrementAllocation(); float getLocalityThresholdNode(); float getLocalityThresholdRack(); boolean isContinuousSchedulingEnabled(); int getContinuousSchedulingSleepMs(); long getLocalityDelayNodeMs(); long getLocalityDelayRackMs(); boolean getPreemptionEnabled(); float getPreemptionUtilizationThreshold(); boolean getAssignMultiple(); int getMaxAssign(); boolean getSizeBasedWeight(); boolean isEventLogEnabled(); String getEventlogDir(); int getPreemptionInterval(); int getWaitTimeBeforeKill(); boolean getUsePortForNodeName(); static Resource parseResourceConfigValue(String val); long getUpdateInterval(); static final Log LOG; static final String RM_SCHEDULER_INCREMENT_ALLOCATION_MB; static final int DEFAULT_RM_SCHEDULER_INCREMENT_ALLOCATION_MB; static final String RM_SCHEDULER_INCREMENT_ALLOCATION_VCORES; static final int DEFAULT_RM_SCHEDULER_INCREMENT_ALLOCATION_VCORES; static final String RM_SCHEDULER_INCREMENT_ALLOCATION_GCORES; static final int DEFAULT_RM_SCHEDULER_INCREMENT_ALLOCATION_GCORES; static final String ALLOCATION_FILE; static final String EVENT_LOG_ENABLED; static final boolean DEFAULT_EVENT_LOG_ENABLED; static final String ASSIGN_MULTIPLE; static final String UPDATE_INTERVAL_MS; static final int DEFAULT_UPDATE_INTERVAL_MS; }