blob: 1b250ecb00c7cee4b74fd7bf97d25af1608d10ad [file] [log] [blame]
/**
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
* <p/>
* http://www.apache.org/licenses/LICENSE-2.0
* <p/>
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.myriad.executor;
import java.util.Map;
/**
* Node Manger Task Configuration
*/
public class NMTaskConfig {
private String yarnHome;
private Long advertisableCpus;
private Long advertisableMem;
private String jvmOpts;
private Boolean cgroups;
private Long rpcPort;
private Long localizerPort;
private Long webAppHttpPort;
private Long shufflePort;
private Map<String, String> yarnEnvironment;
public String getYarnHome() {
return yarnHome;
}
public void setYarnHome(String yarnHome) {
this.yarnHome = yarnHome;
}
public Long getAdvertisableCpus() {
return advertisableCpus;
}
public void setAdvertisableCpus(Long advertisableCpus) {
this.advertisableCpus = advertisableCpus;
}
public Long getAdvertisableMem() {
return advertisableMem;
}
public void setAdvertisableMem(Long advertisableMem) {
this.advertisableMem = advertisableMem;
}
public String getJvmOpts() {
return jvmOpts;
}
public void setJvmOpts(String jvmOpts) {
this.jvmOpts = jvmOpts;
}
public Boolean getCgroups() {
return cgroups;
}
public void setCgroups(Boolean cgroups) {
this.cgroups = cgroups;
}
public Map<String, String> getYarnEnvironment() {
return yarnEnvironment;
}
public void setYarnEnvironment(Map<String, String> yarnEnvironment) {
this.yarnEnvironment = yarnEnvironment;
}
public Long getRpcPort() {
return rpcPort;
}
public void setRpcPort(long port) {
rpcPort = port;
}
public Long gettWebAppHttpPort() {
return webAppHttpPort;
}
public void setWebAppHttpPort(Long port) {
webAppHttpPort = port;
}
public Long getLocalizerPort() {
return localizerPort;
}
public void setLocalizerPort(Long localizerPort) {
this.localizerPort = localizerPort;
}
public Long getShufflePort() {
return shufflePort;
}
public void setShufflePort(Long shufflePort) {
this.shufflePort = shufflePort;
}
}