org.apache.hadoop.hbase.procedure.ZKProcedureMemberRpcs.<init>()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(10.7k)|赞(0)|评价(0)|浏览(112)

本文整理了Java中org.apache.hadoop.hbase.procedure.ZKProcedureMemberRpcs.<init>()方法的一些代码示例，展示了ZKProcedureMemberRpcs.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZKProcedureMemberRpcs.<init>()方法的具体详情如下：
包路径：org.apache.hadoop.hbase.procedure.ZKProcedureMemberRpcs
类名称：ZKProcedureMemberRpcs
方法名：<init>

ZKProcedureMemberRpcs.<init>介绍

[英]Must call #start(String,ProcedureMember) before this can be used.
[中]必须调用#start（String，procedurememory）才能使用。

代码示例

代码示例来源：origin: apache/hbase

@Override
 public ProcedureMemberRpcs getProcedureMemberRpcs(String procType) throws KeeperException {
  return new ZKProcedureMemberRpcs(watcher, procType);
 }
}

代码示例来源：origin: apache/hbase

/**
 * Initialize this region server flush procedure manager
 * Uses a zookeeper based member controller.
 * @param rss region server
 * @throws KeeperException if the zookeeper cannot be reached
 */
@Override
public void initialize(RegionServerServices rss) throws KeeperException {
 this.rss = rss;
 ZKWatcher zkw = rss.getZooKeeper();
 this.memberRpcs = new ZKProcedureMemberRpcs(zkw,
  MasterFlushTableProcedureManager.FLUSH_TABLE_PROCEDURE_SIGNATURE);
 Configuration conf = rss.getConfiguration();
 long keepAlive = conf.getLong(FLUSH_TIMEOUT_MILLIS_KEY, FLUSH_TIMEOUT_MILLIS_DEFAULT);
 int opThreads = conf.getInt(FLUSH_REQUEST_THREADS_KEY, FLUSH_REQUEST_THREADS_DEFAULT);
 // create the actual flush table procedure member
 ThreadPoolExecutor pool = ProcedureMember.defaultPool(rss.getServerName().toString(),
  opThreads, keepAlive);
 this.member = new ProcedureMember(memberRpcs, pool, new FlushTableSubprocedureBuilder());
}

代码示例来源：origin: apache/hbase

/**
 * Create a default snapshot handler - uses a zookeeper based member controller.
 * @param rss region server running the handler
 * @throws KeeperException if the zookeeper cluster cannot be reached
 */
@Override
public void initialize(RegionServerServices rss) throws KeeperException {
 this.rss = rss;
 ZKWatcher zkw = rss.getZooKeeper();
 this.memberRpcs = new ZKProcedureMemberRpcs(zkw,
   SnapshotManager.ONLINE_SNAPSHOT_CONTROLLER_DESCRIPTION);
 // read in the snapshot request configuration properties
 Configuration conf = rss.getConfiguration();
 long keepAlive = conf.getLong(SNAPSHOT_TIMEOUT_MILLIS_KEY, SNAPSHOT_TIMEOUT_MILLIS_DEFAULT);
 int opThreads = conf.getInt(SNAPSHOT_REQUEST_THREADS_KEY, SNAPSHOT_REQUEST_THREADS_DEFAULT);
 // create the actual snapshot procedure member
 ThreadPoolExecutor pool = ProcedureMember.defaultPool(rss.getServerName().toString(),
  opThreads, keepAlive);
 this.member = new ProcedureMember(memberRpcs, pool, new SnapshotSubprocedureBuilder());
}

代码示例来源：origin: apache/hbase

@Override
 public Pair<ZKProcedureCoordinator, List<ZKProcedureMemberRpcs>> start(
     ZKWatcher watcher, String operationName,
     ProcedureCoordinator coordinator, String controllerName,
     ProcedureMember member, List<String> expected) throws Exception {
  // start the controller
  ZKProcedureCoordinator controller = new ZKProcedureCoordinator(
    watcher, operationName, CONTROLLER_NODE_NAME);
  controller.start(coordinator);
  // make a cohort controller for each expected node
  List<ZKProcedureMemberRpcs> cohortControllers = new ArrayList<>();
  for (String nodeName : expected) {
   ZKProcedureMemberRpcs cc = new ZKProcedureMemberRpcs(watcher, operationName);
   cc.start(nodeName, member);
   cohortControllers.add(cc);
  }
  return new Pair<>(controller, cohortControllers);
 }
};

代码示例来源：origin: apache/hbase

@Override
 public Pair<ZKProcedureCoordinator, List<ZKProcedureMemberRpcs>> start(
     ZKWatcher watcher, String operationName,
     ProcedureCoordinator coordinator, String controllerName,
     ProcedureMember member, List<String> expected) throws Exception {
  // make a cohort controller for each expected node
  List<ZKProcedureMemberRpcs> cohortControllers = new ArrayList<>();
  for (String nodeName : expected) {
   ZKProcedureMemberRpcs cc = new ZKProcedureMemberRpcs(watcher, operationName);
   cc.start(nodeName, member);
   cohortControllers.add(cc);
  }
  // start the controller
  ZKProcedureCoordinator controller = new ZKProcedureCoordinator(
    watcher, operationName, CONTROLLER_NODE_NAME);
  controller.start(coordinator);
  return new Pair<>(controller, cohortControllers);
 }
};

代码示例来源：origin: apache/hbase

final ZKProcedureMemberRpcs controller = new ZKProcedureMemberRpcs(
  watcher, "testSimple");

代码示例来源：origin: apache/hbase

ZKProcedureMemberRpcs comms = new ZKProcedureMemberRpcs(watcher, opDescription);
ThreadPoolExecutor pool2 = ProcedureMember.defaultPool(member, 1, KEEP_ALIVE);
ProcedureMember procMember = new ProcedureMember(comms, pool2, subprocFactory);

代码示例来源：origin: apache/hbase

@Override
public void initialize(RegionServerServices rss) throws KeeperException {
 this.rss = rss;
 ZKWatcher zkw = rss.getZooKeeper();
 this.memberRpcs = new ZKProcedureMemberRpcs(zkw, getProcedureSignature());
 ThreadPoolExecutor pool =
   ProcedureMember.defaultPool(rss.getServerName().toString(), 1);
 this.member = new ProcedureMember(memberRpcs, pool, new SimleSubprocedureBuilder());
 LOG.info("Initialized: " + rss.getServerName().toString());
}

代码示例来源：origin: apache/hbase

for (String member : expected) {
 ZKWatcher watcher = newZooKeeperWatcher();
 ZKProcedureMemberRpcs controller = new ZKProcedureMemberRpcs(watcher, opDescription);
 ThreadPoolExecutor pool2 = ProcedureMember.defaultPool(member, 1, KEEP_ALIVE);
 ProcedureMember mem = new ProcedureMember(controller, pool2, subprocFactory);

代码示例来源：origin: co.cask.hbase/hbase

/**
 * Create a default snapshot handler - uses a zookeeper based member controller.
 * @param rss region server running the handler
 * @throws KeeperException if the zookeeper cluster cannot be reached
 */
public RegionServerSnapshotManager(RegionServerServices rss)
  throws KeeperException {
 this.rss = rss;
 ZooKeeperWatcher zkw = rss.getZooKeeper();
 String nodeName = rss.getServerName().toString();
 this.memberRpcs = new ZKProcedureMemberRpcs(zkw,
   SnapshotManager.ONLINE_SNAPSHOT_CONTROLLER_DESCRIPTION, nodeName);
 // read in the snapshot request configuration properties
 Configuration conf = rss.getConfiguration();
 long wakeMillis = conf.getLong(SNAPSHOT_REQUEST_WAKE_MILLIS_KEY, SNAPSHOT_REQUEST_WAKE_MILLIS_DEFAULT);
 long keepAlive = conf.getLong(SNAPSHOT_TIMEOUT_MILLIS_KEY, SNAPSHOT_TIMEOUT_MILLIS_DEFAULT);
 int opThreads = conf.getInt(SNAPSHOT_REQUEST_THREADS_KEY, SNAPSHOT_REQUEST_THREADS_DEFAULT);
 // create the actual snapshot procedure member
 ThreadPoolExecutor pool = ProcedureMember.defaultPool(wakeMillis, keepAlive, opThreads, nodeName);
 this.member = new ProcedureMember(memberRpcs, pool, new SnapshotSubprocedureBuilder());
}

代码示例来源：origin: harbby/presto-connectors

/**
 * Initialize this region server flush procedure manager
 * Uses a zookeeper based member controller.
 * @param rss region server
 * @throws KeeperException if the zookeeper cannot be reached
 */
@Override
public void initialize(RegionServerServices rss) throws KeeperException {
 this.rss = rss;
 ZooKeeperWatcher zkw = rss.getZooKeeper();
 this.memberRpcs = new ZKProcedureMemberRpcs(zkw,
  MasterFlushTableProcedureManager.FLUSH_TABLE_PROCEDURE_SIGNATURE);
 Configuration conf = rss.getConfiguration();
 long keepAlive = conf.getLong(FLUSH_TIMEOUT_MILLIS_KEY, FLUSH_TIMEOUT_MILLIS_DEFAULT);
 int opThreads = conf.getInt(FLUSH_REQUEST_THREADS_KEY, FLUSH_REQUEST_THREADS_DEFAULT);
 // create the actual flush table procedure member
 ThreadPoolExecutor pool = ProcedureMember.defaultPool(rss.getServerName().toString(),
  opThreads, keepAlive);
 this.member = new ProcedureMember(memberRpcs, pool, new FlushTableSubprocedureBuilder());
}

代码示例来源：origin: harbby/presto-connectors

/**
 * Create a default snapshot handler - uses a zookeeper based member controller.
 * @param rss region server running the handler
 * @throws KeeperException if the zookeeper cluster cannot be reached
 */
@Override
public void initialize(RegionServerServices rss) throws KeeperException {
 this.rss = rss;
 ZooKeeperWatcher zkw = rss.getZooKeeper();
 this.memberRpcs = new ZKProcedureMemberRpcs(zkw,
   SnapshotManager.ONLINE_SNAPSHOT_CONTROLLER_DESCRIPTION);
 // read in the snapshot request configuration properties
 Configuration conf = rss.getConfiguration();
 long keepAlive = conf.getLong(SNAPSHOT_TIMEOUT_MILLIS_KEY, SNAPSHOT_TIMEOUT_MILLIS_DEFAULT);
 int opThreads = conf.getInt(SNAPSHOT_REQUEST_THREADS_KEY, SNAPSHOT_REQUEST_THREADS_DEFAULT);
 // create the actual snapshot procedure member
 ThreadPoolExecutor pool = ProcedureMember.defaultPool(rss.getServerName().toString(),
  opThreads, keepAlive);
 this.member = new ProcedureMember(memberRpcs, pool, new SnapshotSubprocedureBuilder());
}

代码示例来源：origin: org.apache.hbase/hbase-server

@Override
 public Pair<ZKProcedureCoordinator, List<ZKProcedureMemberRpcs>> start(
     ZKWatcher watcher, String operationName,
     ProcedureCoordinator coordinator, String controllerName,
     ProcedureMember member, List<String> expected) throws Exception {
  // start the controller
  ZKProcedureCoordinator controller = new ZKProcedureCoordinator(
    watcher, operationName, CONTROLLER_NODE_NAME);
  controller.start(coordinator);
  // make a cohort controller for each expected node
  List<ZKProcedureMemberRpcs> cohortControllers = new ArrayList<>();
  for (String nodeName : expected) {
   ZKProcedureMemberRpcs cc = new ZKProcedureMemberRpcs(watcher, operationName);
   cc.start(nodeName, member);
   cohortControllers.add(cc);
  }
  return new Pair<>(controller, cohortControllers);
 }
};

代码示例来源：origin: org.apache.hbase/hbase-server

@Override
 public Pair<ZKProcedureCoordinator, List<ZKProcedureMemberRpcs>> start(
     ZKWatcher watcher, String operationName,
     ProcedureCoordinator coordinator, String controllerName,
     ProcedureMember member, List<String> expected) throws Exception {
  // make a cohort controller for each expected node
  List<ZKProcedureMemberRpcs> cohortControllers = new ArrayList<>();
  for (String nodeName : expected) {
   ZKProcedureMemberRpcs cc = new ZKProcedureMemberRpcs(watcher, operationName);
   cc.start(nodeName, member);
   cohortControllers.add(cc);
  }
  // start the controller
  ZKProcedureCoordinator controller = new ZKProcedureCoordinator(
    watcher, operationName, CONTROLLER_NODE_NAME);
  controller.start(coordinator);
  return new Pair<>(controller, cohortControllers);
 }
};

代码示例来源：origin: org.apache.hbase/hbase-server

final ZKProcedureMemberRpcs controller = new ZKProcedureMemberRpcs(
  watcher, "testSimple");

代码示例来源：origin: org.apache.hbase/hbase-server

ZKProcedureMemberRpcs comms = new ZKProcedureMemberRpcs(watcher, opDescription);
ThreadPoolExecutor pool2 = ProcedureMember.defaultPool(member, 1, KEEP_ALIVE);
ProcedureMember procMember = new ProcedureMember(comms, pool2, subprocFactory);

代码示例来源：origin: org.apache.hbase/hbase-server

@Override
public void initialize(RegionServerServices rss) throws KeeperException {
 this.rss = rss;
 ZKWatcher zkw = rss.getZooKeeper();
 this.memberRpcs = new ZKProcedureMemberRpcs(zkw, getProcedureSignature());
 ThreadPoolExecutor pool =
   ProcedureMember.defaultPool(rss.getServerName().toString(), 1);
 this.member = new ProcedureMember(memberRpcs, pool, new SimleSubprocedureBuilder());
 LOG.info("Initialized: " + rss.getServerName().toString());
}

代码示例来源：origin: org.apache.hbase/hbase-server

for (String member : expected) {
 ZKWatcher watcher = newZooKeeperWatcher();
 ZKProcedureMemberRpcs controller = new ZKProcedureMemberRpcs(watcher, opDescription);
 ThreadPoolExecutor pool2 = ProcedureMember.defaultPool(member, 1, KEEP_ALIVE);
 ProcedureMember mem = new ProcedureMember(controller, pool2, subprocFactory);

内容来源于网络，如有侵权，请联系作者删除！

ZKProcedureMemberRpcs

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com