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

ZKFCProtocolServerSideTranslatorPB介绍

暂无

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-common

ZKFCRpcServer(Configuration conf,
  InetSocketAddress bindAddr,
  ZKFailoverController zkfc,
  PolicyProvider policy) throws IOException {
 this.zkfc = zkfc;
 
 RPC.setProtocolEngine(conf, ZKFCProtocolPB.class,
   ProtobufRpcEngine.class);
 ZKFCProtocolServerSideTranslatorPB translator =
   new ZKFCProtocolServerSideTranslatorPB(this);
 BlockingService service = ZKFCProtocolService
   .newReflectiveBlockingService(translator);
 this.server = new RPC.Builder(conf).setProtocol(ZKFCProtocolPB.class)
   .setInstance(service).setBindAddress(bindAddr.getHostName())
   .setPort(bindAddr.getPort()).setNumHandlers(HANDLER_COUNT)
   .setVerbose(false).build();
 
 // set service-level authorization security policy
 if (conf.getBoolean(
   CommonConfigurationKeys.HADOOP_SECURITY_AUTHORIZATION, false)) {
  server.refreshServiceAcl(conf, policy);
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

ZKFCRpcServer(Configuration conf,
  InetSocketAddress bindAddr,
  ZKFailoverController zkfc,
  PolicyProvider policy) throws IOException {
 this.zkfc = zkfc;
 
 RPC.setProtocolEngine(conf, ZKFCProtocolPB.class,
   ProtobufRpcEngine.class);
 ZKFCProtocolServerSideTranslatorPB translator =
   new ZKFCProtocolServerSideTranslatorPB(this);
 BlockingService service = ZKFCProtocolService
   .newReflectiveBlockingService(translator);
 this.server = new RPC.Builder(conf).setProtocol(ZKFCProtocolPB.class)
   .setInstance(service).setBindAddress(bindAddr.getHostName())
   .setPort(bindAddr.getPort()).setNumHandlers(HANDLER_COUNT)
   .setVerbose(false).build();
 
 // set service-level authorization security policy
 if (conf.getBoolean(
   CommonConfigurationKeys.HADOOP_SECURITY_AUTHORIZATION, false)) {
  server.refreshServiceAcl(conf, policy);
 }
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

ZKFCRpcServer(Configuration conf,
  InetSocketAddress bindAddr,
  ZKFailoverController zkfc,
  PolicyProvider policy) throws IOException {
 this.zkfc = zkfc;
 
 RPC.setProtocolEngine(conf, ZKFCProtocolPB.class,
   ProtobufRpcEngine.class);
 ZKFCProtocolServerSideTranslatorPB translator =
   new ZKFCProtocolServerSideTranslatorPB(this);
 BlockingService service = ZKFCProtocolService
   .newReflectiveBlockingService(translator);
 this.server = new RPC.Builder(conf).setProtocol(ZKFCProtocolPB.class)
   .setInstance(service).setBindAddress(bindAddr.getHostName())
   .setPort(bindAddr.getPort()).setNumHandlers(HANDLER_COUNT)
   .setVerbose(false).build();
 
 // set service-level authorization security policy
 if (conf.getBoolean(
   CommonConfigurationKeys.HADOOP_SECURITY_AUTHORIZATION, false)) {
  server.refreshServiceAcl(conf, policy);
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

ZKFCRpcServer(Configuration conf,
  InetSocketAddress bindAddr,
  ZKFailoverController zkfc,
  PolicyProvider policy) throws IOException {
 this.zkfc = zkfc;
 
 RPC.setProtocolEngine(conf, ZKFCProtocolPB.class,
   ProtobufRpcEngine.class);
 ZKFCProtocolServerSideTranslatorPB translator =
   new ZKFCProtocolServerSideTranslatorPB(this);
 BlockingService service = ZKFCProtocolService
   .newReflectiveBlockingService(translator);
 this.server = new RPC.Builder(conf).setProtocol(ZKFCProtocolPB.class)
   .setInstance(service).setBindAddress(bindAddr.getHostName())
   .setPort(bindAddr.getPort()).setNumHandlers(HANDLER_COUNT)
   .setVerbose(false).build();
 
 // set service-level authorization security policy
 if (conf.getBoolean(
   CommonConfigurationKeys.HADOOP_SECURITY_AUTHORIZATION, false)) {
  server.refreshServiceAcl(conf, policy);
 }
}

代码示例来源：origin: io.hops/hadoop-common

ZKFCRpcServer(Configuration conf,
  InetSocketAddress bindAddr,
  ZKFailoverController zkfc,
  PolicyProvider policy) throws IOException {
 this.zkfc = zkfc;
 
 RPC.setProtocolEngine(conf, ZKFCProtocolPB.class,
   ProtobufRpcEngine.class);
 ZKFCProtocolServerSideTranslatorPB translator =
   new ZKFCProtocolServerSideTranslatorPB(this);
 BlockingService service = ZKFCProtocolService
   .newReflectiveBlockingService(translator);
 this.server = new RPC.Builder(conf).setProtocol(ZKFCProtocolPB.class)
   .setInstance(service).setBindAddress(bindAddr.getHostName())
   .setPort(bindAddr.getPort()).setNumHandlers(HANDLER_COUNT)
   .setVerbose(false).build();
 
 // set service-level authorization security policy
 if (conf.getBoolean(
   CommonConfigurationKeys.HADOOP_SECURITY_AUTHORIZATION, false)) {
  server.refreshServiceAcl(conf, policy);
 }
}