Java 类org.apache.hadoop.hbase.procedure.ProcedureMemberRpcs 实例源码

项目：hbase 文件：ZkCoordinatedStateManager.java

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

项目：ditb 文件：RegionServerFlushTableProcedureManager.java

/**
 * Exposed for testing.
 * @param conf HBase configuration.
 * @param server region server.
 * @param memberRpc use specified memberRpc instance
 * @param procMember use specified ProcedureMember
 */
 RegionServerFlushTableProcedureManager(Configuration conf, HRegionServer server,
    ProcedureMemberRpcs memberRpc, ProcedureMember procMember) {
  this.rss = server;
  this.memberRpcs = memberRpc;
  this.member = procMember;
}

项目：ditb 文件：RegionServerSnapshotManager.java

/**
 * Exposed for testing.
 * @param conf HBase configuration.
 * @param parent parent running the snapshot handler
 * @param memberRpc use specified memberRpc instance
 * @param procMember use specified ProcedureMember
 */
 RegionServerSnapshotManager(Configuration conf, HRegionServer parent,
    ProcedureMemberRpcs memberRpc, ProcedureMember procMember) {
  this.rss = parent;
  this.memberRpcs = memberRpc;
  this.member = procMember;
}

项目：LCIndex-HBase-0.94.16 文件：RegionServerSnapshotManager.java

/**
 * Exposed for testing.
 * @param conf HBase configuration.
 * @param parent parent running the snapshot handler
 * @param memberRpc use specified memberRpc instance
 * @param procMember use specified ProcedureMember
 */
 RegionServerSnapshotManager(Configuration conf, HRegionServer parent,
    ProcedureMemberRpcs memberRpc, ProcedureMember procMember) {
  this.rss = parent;
  this.memberRpcs = memberRpc;
  this.member = procMember;
}

项目：pbase 文件：RegionServerFlushTableProcedureManager.java

/**
 * Exposed for testing.
 * @param conf HBase configuration.
 * @param server region server.
 * @param memberRpc use specified memberRpc instance
 * @param procMember use specified ProcedureMember
 */
 RegionServerFlushTableProcedureManager(Configuration conf, HRegionServer server,
    ProcedureMemberRpcs memberRpc, ProcedureMember procMember) {
  this.rss = server;
  this.memberRpcs = memberRpc;
  this.member = procMember;
}

项目：pbase 文件：RegionServerSnapshotManager.java

/**
 * Exposed for testing.
 * @param conf HBase configuration.
 * @param parent parent running the snapshot handler
 * @param memberRpc use specified memberRpc instance
 * @param procMember use specified ProcedureMember
 */
 RegionServerSnapshotManager(Configuration conf, HRegionServer parent,
    ProcedureMemberRpcs memberRpc, ProcedureMember procMember) {
  this.rss = parent;
  this.memberRpcs = memberRpc;
  this.member = procMember;
}

项目：HIndex 文件：RegionServerSnapshotManager.java

/**
 * Exposed for testing.
 * @param conf HBase configuration.
 * @param parent parent running the snapshot handler
 * @param memberRpc use specified memberRpc instance
 * @param procMember use specified ProcedureMember
 */
 RegionServerSnapshotManager(Configuration conf, HRegionServer parent,
    ProcedureMemberRpcs memberRpc, ProcedureMember procMember) {
  this.rss = parent;
  this.memberRpcs = memberRpc;
  this.member = procMember;
}

项目：IRIndex 文件：RegionServerSnapshotManager.java

/**
 * Exposed for testing.
 * @param conf HBase configuration.
 * @param parent parent running the snapshot handler
 * @param memberRpc use specified memberRpc instance
 * @param procMember use specified ProcedureMember
 */
 RegionServerSnapshotManager(Configuration conf, HRegionServer parent,
    ProcedureMemberRpcs memberRpc, ProcedureMember procMember) {
  this.rss = parent;
  this.memberRpcs = memberRpc;
  this.member = procMember;
}

项目：hbase 文件：RegionServerFlushTableProcedureManager.java

/**
 * Exposed for testing.
 * @param conf HBase configuration.
 * @param server region server.
 * @param memberRpc use specified memberRpc instance
 * @param procMember use specified ProcedureMember
 */
 RegionServerFlushTableProcedureManager(Configuration conf, HRegionServer server,
    ProcedureMemberRpcs memberRpc, ProcedureMember procMember) {
  this.rss = server;
  this.memberRpcs = memberRpc;
  this.member = procMember;
}

项目：hbase 文件：RegionServerSnapshotManager.java

/**
 * Exposed for testing.
 * @param conf HBase configuration.
 * @param parent parent running the snapshot handler
 * @param memberRpc use specified memberRpc instance
 * @param procMember use specified ProcedureMember
 */
 RegionServerSnapshotManager(Configuration conf, HRegionServer parent,
    ProcedureMemberRpcs memberRpc, ProcedureMember procMember) {
  this.rss = parent;
  this.memberRpcs = memberRpc;
  this.member = procMember;
}

项目：PyroDB 文件：RegionServerFlushTableProcedureManager.java

/**
 * Exposed for testing.
 * @param conf HBase configuration.
 * @param server region server.
 * @param memberRpc use specified memberRpc instance
 * @param procMember use specified ProcedureMember
 */
 RegionServerFlushTableProcedureManager(Configuration conf, HRegionServer server,
    ProcedureMemberRpcs memberRpc, ProcedureMember procMember) {
  this.rss = server;
  this.memberRpcs = memberRpc;
  this.member = procMember;
}

项目：PyroDB 文件：RegionServerSnapshotManager.java

/**
 * Exposed for testing.
 * @param conf HBase configuration.
 * @param parent parent running the snapshot handler
 * @param memberRpc use specified memberRpc instance
 * @param procMember use specified ProcedureMember
 */
 RegionServerSnapshotManager(Configuration conf, HRegionServer parent,
    ProcedureMemberRpcs memberRpc, ProcedureMember procMember) {
  this.rss = parent;
  this.memberRpcs = memberRpc;
  this.member = procMember;
}

项目：c5 文件：RegionServerSnapshotManager.java

/**
 * Exposed for testing.
 * @param conf HBase configuration.
 * @param parent parent running the snapshot handler
 * @param memberRpc use specified memberRpc instance
 * @param procMember use specified ProcedureMember
 */
 RegionServerSnapshotManager(Configuration conf, HRegionServer parent,
    ProcedureMemberRpcs memberRpc, ProcedureMember procMember) {
  this.rss = parent;
  this.memberRpcs = memberRpc;
  this.member = procMember;
}

项目：HBase-Research 文件：RegionServerSnapshotManager.java

/**
 * Exposed for testing.
 * @param conf HBase configuration.
 * @param parent parent running the snapshot handler
 * @param memberRpc use specified memberRpc instance
 * @param procMember use specified ProcedureMember
 */
 RegionServerSnapshotManager(Configuration conf, HRegionServer parent,
    ProcedureMemberRpcs memberRpc, ProcedureMember procMember) {
  this.rss = parent;
  this.memberRpcs = memberRpc;
  this.member = procMember;
}

项目：hbase-0.94.8-qod 文件：RegionServerSnapshotManager.java

/**
 * Exposed for testing.
 * @param conf HBase configuration.
 * @param parent parent running the snapshot handler
 * @param memberRpc use specified memberRpc instance
 * @param procMember use specified ProcedureMember
 */
 RegionServerSnapshotManager(Configuration conf, HRegionServer parent,
    ProcedureMemberRpcs memberRpc, ProcedureMember procMember) {
  this.rss = parent;
  this.memberRpcs = memberRpc;
  this.member = procMember;
}

项目：hbase-0.94.8-qod 文件：RegionServerSnapshotManager.java

/**
 * Exposed for testing.
 * @param conf HBase configuration.
 * @param parent parent running the snapshot handler
 * @param memberRpc use specified memberRpc instance
 * @param procMember use specified ProcedureMember
 */
 RegionServerSnapshotManager(Configuration conf, HRegionServer parent,
    ProcedureMemberRpcs memberRpc, ProcedureMember procMember) {
  this.rss = parent;
  this.memberRpcs = memberRpc;
  this.member = procMember;
}

项目：hindex 文件：RegionServerSnapshotManager.java

/**
 * Exposed for testing.
 * @param conf HBase configuration.
 * @param parent parent running the snapshot handler
 * @param memberRpc use specified memberRpc instance
 * @param procMember use specified ProcedureMember
 */
 RegionServerSnapshotManager(Configuration conf, HRegionServer parent,
    ProcedureMemberRpcs memberRpc, ProcedureMember procMember) {
  this.rss = parent;
  this.memberRpcs = memberRpc;
  this.member = procMember;
}

项目：hbase 文件：CoordinatedStateManager.java

/**
 * Method to retrieve {@link org.apache.hadoop.hbase.procedure.ProcedureMemberRpcs}
 */
ProcedureMemberRpcs getProcedureMemberRpcs(String procType) throws KeeperException;