本文整理汇总了Java中org.apache.mesos.Protos.SlaveInfo类的典型用法代码示例。如果您正苦于以下问题：Java SlaveInfo类的具体用法？Java SlaveInfo怎么用？Java SlaveInfo使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
SlaveInfo类属于org.apache.mesos.Protos包，在下文中一共展示了SlaveInfo类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: registered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
@Override
public void registered(ExecutorDriver driver, ExecutorInfo executorInfo, FrameworkInfo frameworkInfo, SlaveInfo slaveInfo) {
LOG.info("Received executor data <{}>", executorInfo.getData().toStringUtf8());
Map ids = (Map) JSONValue.parse(executorInfo.getData().toStringUtf8());
_executorId = executorInfo.getExecutorId().getValue();
_supervisorId = (String) ids.get(MesosCommon.SUPERVISOR_ID);
_assignmentId = (String) ids.get(MesosCommon.ASSIGNMENT_ID);
LOG.info("Registered supervisor with Mesos: {}, {} ", _supervisorId, _assignmentId);
// Completed registration, let anything waiting for us to do so continue
_registeredLatch.countDown();
}
开发者ID:PacktPublishing，项目名称:Mastering-Mesos，代码行数:13，代码来源:MesosSupervisor.java
示例2: registered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
@Override
public void registered(ExecutorDriver driver, ExecutorInfo executorInfo,
FrameworkInfo frameworkInfo, SlaveInfo slaveInfo) {
System.out.println("Registered the Exectutor");
System.out.println("Executor : " + executorInfo);
System.out.println("Framework : " + frameworkInfo);
System.out.println("SlaveInfo : " + slaveInfo);
}
开发者ID:WTIGER001，项目名称:Brigade，代码行数:10，代码来源:MyExecutor.java
示例3: registered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
@Override
public void registered(ExecutorDriver executorDriver, ExecutorInfo executorInfo,
FrameworkInfo frameworkInfo, SlaveInfo slaveInfo) {
log.debug("executor registered with framework:"+frameworkInfo.getName()+":on slave:"+slaveInfo.getHostname());
this.executorInfo = executorInfo;
this.executorDriver = executorDriver;
}
开发者ID:mohitsoni，项目名称:compose-executor，代码行数:8，代码来源:DockerComposeExecutor.java
示例4: registered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
/**
* Register the framework with the executor.
*/
@Override
public void registered(ExecutorDriver driver, ExecutorInfo executorInfo,
FrameworkInfo frameworkInfo, SlaveInfo slaveInfo) {
// Set up data dir
setUpDataDir();
if (!hbaseFrameworkConfig.usingNativeHadoopBinaries()) {
createSymbolicLink();
}
log.info("Executor registered with the slave");
}
开发者ID:jan-zajic，项目名称:mesos-hbase，代码行数:14，代码来源:AbstractNodeExecutor.java
示例5: registered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
@Override
public void registered(ExecutorDriver driver, ExecutorInfo executorInfo, FrameworkInfo frameworkInfo, SlaveInfo slaveInfo) {
LOG.info("Received executor data <" + executorInfo.getData().toStringUtf8() + ">");
Map ids = (Map) JSONValue.parse(executorInfo.getData().toStringUtf8());
_id = (String) ids.get(MesosCommon.SUPERVISOR_ID);
_assignmentId = (String) ids.get(MesosCommon.ASSIGNMENT_ID);
LOG.info("Registered supervisor with Mesos: " + _id + ", " + _assignmentId);
initter.release();
}
开发者ID:deric，项目名称:storm-mesos，代码行数:10，代码来源:MesosSupervisor.java
示例6: registered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
@Override
public void registered(final ExecutorDriver driver,
final ExecutorInfo executorInfo,
final FrameworkInfo frameworkInfo,
final SlaveInfo slaveInfo) {
LOG.log(Level.FINEST, "Executor registered. driver: {0} executorInfo: {1} frameworkInfo: {2} slaveInfo {3}",
new Object[]{driver, executorInfo, frameworkInfo, slaveInfo});
}
开发者ID:apache，项目名称:reef，代码行数:9，代码来源:REEFExecutor.java
示例7: registered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
@Override
public void registered(ExecutorDriver arg0, ExecutorInfo arg1,
FrameworkInfo arg2, SlaveInfo arg3) {
System.out.println("Do-Wah-Do-Wah");
str.println(id+"Registered, Huzzah!");
}
开发者ID:apache，项目名称:oodt，代码行数:8，代码来源:ResourceExecutor.java
示例8: reregistered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
@Override
public void reregistered(ExecutorDriver driver, SlaveInfo slaveInfo) {
LOG.info("executor has reregistered with the mesos-slave");
}
开发者ID:PacktPublishing，项目名称:Mastering-Mesos，代码行数:5，代码来源:MesosSupervisor.java
示例9: reregistered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
@Override
public void reregistered(ExecutorDriver driver, SlaveInfo slaveInfo) {
System.out.println("Reregistered the Exectutor");
}
开发者ID:WTIGER001，项目名称:Brigade，代码行数:5，代码来源:MyExecutor.java
示例10: registered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
@Override
public void registered(ExecutorDriver arg0, ExecutorInfo arg1, FrameworkInfo arg2, SlaveInfo arg3) {
// TODO Auto-generated method stub
}
开发者ID:lhzsantana，项目名称:federator，代码行数:6，代码来源:FederatorExecutor.java
示例11: reregistered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
@Override
public void reregistered(ExecutorDriver arg0, SlaveInfo arg1) {
// TODO Auto-generated method stub
}
开发者ID:lhzsantana，项目名称:federator，代码行数:6，代码来源:FederatorExecutor.java
示例12: reregistered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
@Override
public void reregistered(ExecutorDriver executorDriver, SlaveInfo slaveInfo) {
log.debug("executor reregistered on slave:"+slaveInfo.getHostname());
this.executorDriver = executorDriver;
}
开发者ID:mohitsoni，项目名称:compose-executor，代码行数:6，代码来源:DockerComposeExecutor.java
示例13: registered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
@Override
public void registered(ExecutorDriver driver, ExecutorInfo executorInfo, FrameworkInfo frameworkInfo, SlaveInfo slaveInfo) {
LOGGER.debug("Registered ", executorInfo, " for framework ", frameworkInfo, " on mesos slave ", slaveInfo);
}
开发者ID:apache，项目名称:incubator-myriad，代码行数:5，代码来源:MyriadExecutor.java
示例14: reregistered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
@Override
public void reregistered(ExecutorDriver driver, SlaveInfo slaveInfo) {
LOGGER.debug("ReRegistered");
}
开发者ID:apache，项目名称:incubator-myriad，代码行数:5，代码来源:MyriadExecutor.java
示例15: reregistered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
@Override
public void reregistered(ExecutorDriver driver, SlaveInfo slaveInfo) {
log.info("Executor reregistered with the slave");
}
开发者ID:jan-zajic，项目名称:mesos-hbase，代码行数:5，代码来源:AbstractNodeExecutor.java
示例16: reregistered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
@Override
public void reregistered(ExecutorDriver driver, SlaveInfo slaveInfo) {
}
开发者ID:deric，项目名称:storm-mesos，代码行数:4，代码来源:MesosSupervisor.java
示例17: reregistered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
@Override
public void reregistered(final ExecutorDriver driver, final SlaveInfo slaveInfo) {
LOG.log(Level.FINEST, "Executor reregistered. driver: {0}", driver);
}
开发者ID:apache，项目名称:reef，代码行数:5，代码来源:REEFExecutor.java
示例18: reregistered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
@Override
public void reregistered(ExecutorDriver arg0, SlaveInfo arg1) {
System.out.println("Do-Wah-Do-Wah GO GO GO!!!!");
str.println(id+"Re-regged");
}
开发者ID:apache，项目名称:oodt，代码行数:6，代码来源:ResourceExecutor.java
示例19: reregistered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
/**
* Invoked when the executor re-registers with a restarted slave.
*/
@Override
public void reregistered(ExecutorDriver driver, SlaveInfo slaveInfo) {
if (debug) Gpr.debug("Executor: Re-Registered on " + slaveInfo.getHostname());
}
开发者ID:pcingola，项目名称:BigDataScript，代码行数:8，代码来源:BdsMesosExecutor.java
示例20: registered
import org.apache.mesos.Protos.SlaveInfo; //导入依赖的package包/类
/**
* Invoked once the executor driver has been able to successfully
* connect with Mesos. In particular, a scheduler can pass some
* data to it's executors through the FrameworkInfo.ExecutorInfo's
* data field.
*/
@Override
public void registered(ExecutorDriver driver, ExecutorInfo executorInfo, FrameworkInfo frameworkInfo, SlaveInfo slaveInfo) {
if (debug) Gpr.debug("Executor: Registered on " + slaveInfo.getHostname());
}
开发者ID:pcingola，项目名称:BigDataScript，代码行数:11，代码来源:BdsMesosExecutor.java
注：本文中的org.apache.mesos.Protos.SlaveInfo类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论