• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java AsyncLogger类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.hadoop.hdfs.qjournal.client.AsyncLogger的典型用法代码示例。如果您正苦于以下问题:Java AsyncLogger类的具体用法?Java AsyncLogger怎么用?Java AsyncLogger使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



AsyncLogger类属于org.apache.hadoop.hdfs.qjournal.client包,在下文中一共展示了AsyncLogger类的5个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: createLogger

import org.apache.hadoop.hdfs.qjournal.client.AsyncLogger; //导入依赖的package包/类
@Override
public AsyncLogger createLogger(Configuration conf, NamespaceInfo nsInfo,
    String journalId, InetSocketAddress addr) {
  AsyncLogger ch = IPCLoggerChannel.FACTORY.createLogger(
      conf, nsInfo, journalId, addr);
  AsyncLogger spy = Mockito.spy(ch);
  Mockito.doAnswer(new SometimesFaulty<Long>(0.10f))
      .when(spy).getJournalState();
  Mockito.doAnswer(new SometimesFaulty<Void>(0.40f))
      .when(spy).newEpoch(Mockito.anyLong());

  return spy;
}
 
开发者ID:naver,项目名称:hadoop,代码行数:14,代码来源:TestEpochsAreUnique.java


示例2: setup

import org.apache.hadoop.hdfs.qjournal.client.AsyncLogger; //导入依赖的package包/类
@Before
public void setup() throws Exception {
  spyLoggers = ImmutableList.of(
      mockLogger(),
      mockLogger(),
      mockLogger());

  qjm = new QuorumJournalManager(conf, new URI("qjournal://host/jid"), FAKE_NSINFO) {
    @Override
    protected List<AsyncLogger> createLoggers(AsyncLogger.Factory factory) {
      return spyLoggers;
    }
  };

  for (AsyncLogger logger : spyLoggers) {
    futureReturns(GetJournalStateResponseProto.newBuilder()
        .setLastPromisedEpoch(0)
        .setHttpPort(-1)
        .build())
      .when(logger).getJournalState();
    
    futureReturns(
        NewEpochResponseProto.newBuilder().build()
        ).when(logger).newEpoch(Mockito.anyLong());
    
    futureReturns(null).when(logger).format(Mockito.<NamespaceInfo>any());
  }
  
  qjm.recoverUnfinalizedSegments();
}
 
开发者ID:naver,项目名称:hadoop,代码行数:31,代码来源:TestQuorumJournalManagerUnit.java


示例3: createLogger

import org.apache.hadoop.hdfs.qjournal.client.AsyncLogger; //导入依赖的package包/类
@Override
public AsyncLogger createLogger(Configuration conf, NamespaceInfo nsInfo,
    String journalId, InetSocketAddress addr) {
  AsyncLogger ch = IPCLoggerChannel.FACTORY.createLogger(conf, nsInfo,
      journalId, addr);
  AsyncLogger spy = Mockito.spy(ch);
  Mockito.doAnswer(new SometimesFaulty<Long>(0.10f)).when(spy)
      .getJournalState();
  Mockito.doAnswer(new SometimesFaulty<Void>(0.40f)).when(spy)
      .newEpoch(Mockito.anyLong());

  return spy;
}
 
开发者ID:rhli,项目名称:hadoop-EAR,代码行数:14,代码来源:TestEpochsAreUnique.java


示例4: setup

import org.apache.hadoop.hdfs.qjournal.client.AsyncLogger; //导入依赖的package包/类
@Before
public void setup() throws Exception {
  spyLoggers = ImmutableList.of(
      mockLogger(),
      mockLogger(),
      mockLogger());

  qjm = new QuorumJournalManager(conf, new URI("qjournal://host/jid"),
      FAKE_NSINFO, null, false) {
    @Override
    protected List<AsyncLogger> createLoggers(AsyncLogger.Factory factory) {
      return spyLoggers;
    }
  };

  for (AsyncLogger logger : spyLoggers) {
    GetJournalStateResponseProto p = new GetJournalStateResponseProto();
    p.setLastPromisedEpoch(0);
    p.setHttpPort(-1);
    futureReturns(p)
      .when(logger).getJournalState();
    
    futureReturns(
        new NewEpochResponseProto()
        ).when(logger).newEpoch(Mockito.anyLong());
    
    StartupOption startOpt = null;
    futureReturns(null).when(logger).transitionJournal(
        Mockito.<NamespaceInfo> any(), Mockito.eq(Transition.FORMAT),
        Mockito.eq(startOpt));
  }
  
  qjm.recoverUnfinalizedSegments();
}
 
开发者ID:rhli,项目名称:hadoop-EAR,代码行数:35,代码来源:TestQuorumJournalManagerUnit.java


示例5: mockLogger

import org.apache.hadoop.hdfs.qjournal.client.AsyncLogger; //导入依赖的package包/类
private AsyncLogger mockLogger() {
  return Mockito.mock(AsyncLogger.class);
}
 
开发者ID:naver,项目名称:hadoop,代码行数:4,代码来源:TestQuorumJournalManagerUnit.java



注:本文中的org.apache.hadoop.hdfs.qjournal.client.AsyncLogger类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java FitLayout类代码示例发布时间:2022-05-22
下一篇:
Java ClientConfig类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap