本文整理汇总了Java中org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerStatus类的典型用法代码示例。如果您正苦于以下问题：Java LocalizerStatus类的具体用法？Java LocalizerStatus怎么用？Java LocalizerStatus使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
LocalizerStatus类属于org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords包，在下文中一共展示了LocalizerStatus类的9个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: processHeartbeat
import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerStatus; //导入依赖的package包/类
public LocalizerHeartbeatResponse processHeartbeat(LocalizerStatus status) {
String locId = status.getLocalizerId();
synchronized (privLocalizers) {
LocalizerRunner localizer = privLocalizers.get(locId);
if (null == localizer) {
// TODO process resources anyway
LOG.info("Unknown localizer with localizerId " + locId
+ " is sending heartbeat. Ordering it to DIE");
LocalizerHeartbeatResponse response =
recordFactory.newRecordInstance(LocalizerHeartbeatResponse.class);
response.setLocalizerAction(LocalizerAction.DIE);
return response;
}
return localizer.processHeartbeat(status.getResources());
}
}
开发者ID:naver，项目名称:hadoop，代码行数:17，代码来源:ResourceLocalizationService.java
示例2: matches
import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerStatus; //导入依赖的package包/类
@Override
public boolean matches(Object o) {
LocalizerStatus status = (LocalizerStatus) o;
for (LocalResourceStatus localized : status.getResources()) {
switch (localized.getStatus()) {
case FETCH_SUCCESS:
if (localized.getLocalPath().getFile().contains(
rsrc.getResource().getFile())) {
return true;
}
break;
default:
fail("Unexpected: " + localized.getStatus());
break;
}
}
return false;
}
开发者ID:naver，项目名称:hadoop，代码行数:19，代码来源:TestContainerLocalizer.java
示例3: testLocalizerStatusSerDe
import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerStatus; //导入依赖的package包/类
@Test(timeout=10000)
public void testLocalizerStatusSerDe() throws Exception {
LocalizerStatus rsrcS = createLocalizerStatus();
assertTrue(rsrcS instanceof LocalizerStatusPBImpl);
LocalizerStatusPBImpl rsrcPb = (LocalizerStatusPBImpl) rsrcS;
DataOutputBuffer out = new DataOutputBuffer();
rsrcPb.getProto().writeDelimitedTo(out);
DataInputBuffer in = new DataInputBuffer();
in.reset(out.getData(), 0, out.getLength());
LocalizerStatusProto rsrcPbD =
LocalizerStatusProto.parseDelimitedFrom(in);
assertNotNull(rsrcPbD);
LocalizerStatus rsrcD =
new LocalizerStatusPBImpl(rsrcPbD);
assertEquals(rsrcS, rsrcD);
assertEquals("localizer0", rsrcS.getLocalizerId());
assertEquals("localizer0", rsrcD.getLocalizerId());
assertEquals(createLocalResourceStatus(), rsrcS.getResourceStatus(0));
assertEquals(createLocalResourceStatus(), rsrcD.getResourceStatus(0));
}
开发者ID:naver，项目名称:hadoop，代码行数:22，代码来源:TestPBRecordImpl.java
示例4: testLocalizerRPC
import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerStatus; //导入依赖的package包/类
@Test
public void testLocalizerRPC() throws Exception {
InetSocketAddress locAddr = new InetSocketAddress("0.0.0.0", 8040);
LocalizerService server = new LocalizerService(locAddr);
try {
server.start();
Configuration conf = new Configuration();
YarnRPC rpc = YarnRPC.create(conf);
LocalizationProtocol client = (LocalizationProtocol)
rpc.getProxy(LocalizationProtocol.class, locAddr, conf);
LocalizerStatus status =
recordFactory.newRecordInstance(LocalizerStatus.class);
status.setLocalizerId("localizer0");
LocalizerHeartbeatResponse response = client.heartbeat(status);
assertEquals(dieHBResponse(), response);
} finally {
server.stop();
}
assertTrue(true);
}
开发者ID:naver，项目名称:hadoop，代码行数:21，代码来源:TestPBLocalizerRPC.java
示例5: processHeartbeat
import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerStatus; //导入依赖的package包/类
public LocalizerHeartbeatResponse processHeartbeat(LocalizerStatus status) {
String locId = status.getLocalizerId();
synchronized (privLocalizers) {
LocalizerRunner localizer = privLocalizers.get(locId);
if (null == localizer) {
// TODO process resources anyway
LOG.info("Unknown localizer with localizerId " + locId
+ " is sending heartbeat. Ordering it to DIE");
LocalizerHeartbeatResponse response =
recordFactory.newRecordInstance(LocalizerHeartbeatResponse.class);
response.setLocalizerAction(LocalizerAction.DIE);
return response;
}
return localizer.update(status.getResources());
}
}
开发者ID:ict-carch，项目名称:hadoop-plus，代码行数:17，代码来源:ResourceLocalizationService.java
示例6: testMainFailure
import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerStatus; //导入依赖的package包/类
@Test(timeout = 15000)
public void testMainFailure() throws Exception {
FileContext fs = FileContext.getLocalFSFileContext();
spylfs = spy(fs.getDefaultFileSystem());
ContainerLocalizer localizer = setupContainerLocalizerForTest();
// Assume the NM heartbeat fails say because of absent tokens.
when(nmProxy.heartbeat(isA(LocalizerStatus.class))).thenThrow(
new YarnException("Sigh, no token!"));
// run localization, it should fail
try {
localizer.runLocalization(nmAddr);
Assert.fail("Localization succeeded unexpectedly!");
} catch (IOException e) {
Assert.assertTrue(e.getMessage().contains("Sigh, no token!"));
}
}
开发者ID:hopshadoop，项目名称:hops，代码行数:20，代码来源:TestContainerLocalizer.java
示例7: heartbeat
import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerStatus; //导入依赖的package包/类
@Override
public LocalizerHeartbeatResponse heartbeat(LocalizerStatus status)
throws YarnException, IOException {
LocalizerStatusProto statusProto = ((LocalizerStatusPBImpl)status).getProto();
try {
return new LocalizerHeartbeatResponsePBImpl(
proxy.heartbeat(null, statusProto));
} catch (ServiceException e) {
RPCUtil.unwrapAndThrowException(e);
return null;
}
}
开发者ID:naver，项目名称:hadoop，代码行数:13，代码来源:LocalizationProtocolPBClientImpl.java
示例8: createLocalizerStatusForFailedResource
import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerStatus; //导入依赖的package包/类
private LocalizerStatus createLocalizerStatusForFailedResource(
String localizerId, LocalResourceRequest req) {
LocalizerStatus status = createLocalizerStatus(localizerId);
LocalResourceStatus resourceStatus = new LocalResourceStatusPBImpl();
resourceStatus.setException(SerializedException
.newInstance(new YarnException("test")));
resourceStatus.setStatus(ResourceStatusType.FETCH_FAILURE);
resourceStatus.setResource(req);
status.addResourceStatus(resourceStatus);
return status;
}
开发者ID:naver，项目名称:hadoop，代码行数:12，代码来源:TestResourceLocalizationService.java
示例9: createLocalizerStatus
import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerStatus; //导入依赖的package包/类
static LocalizerStatus createLocalizerStatus() {
LocalizerStatus ret =
recordFactory.newRecordInstance(LocalizerStatus.class);
assertTrue(ret instanceof LocalizerStatusPBImpl);
ret.setLocalizerId("localizer0");
ret.addResourceStatus(createLocalResourceStatus());
return ret;
}
开发者ID:naver，项目名称:hadoop，代码行数:9，代码来源:TestPBRecordImpl.java
注：本文中的org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerStatus类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论