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

ZKFCProtocolClientSideTranslatorPB介绍

暂无

代码示例

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

/**
 * @return a proxy to the ZKFC which is associated with this HA service.
 */
public ZKFCProtocol getZKFCProxy(Configuration conf, int timeoutMs)
  throws IOException {
 Configuration confCopy = new Configuration(conf);
 // Lower the timeout so we quickly fail to connect
 confCopy.setInt(CommonConfigurationKeysPublic.IPC_CLIENT_CONNECT_MAX_RETRIES_KEY, 1);
 SocketFactory factory = NetUtils.getDefaultSocketFactory(confCopy);
 return new ZKFCProtocolClientSideTranslatorPB(
   getZKFCAddress(),
   confCopy, factory, timeoutMs);
}

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

/**
 * @return a proxy to the ZKFC which is associated with this HA service.
 */
public ZKFCProtocol getZKFCProxy(Configuration conf, int timeoutMs)
  throws IOException {
 Configuration confCopy = new Configuration(conf);
 // Lower the timeout so we quickly fail to connect
 confCopy.setInt(CommonConfigurationKeysPublic.IPC_CLIENT_CONNECT_MAX_RETRIES_KEY, 1);
 SocketFactory factory = NetUtils.getDefaultSocketFactory(confCopy);
 return new ZKFCProtocolClientSideTranslatorPB(
   getZKFCAddress(),
   confCopy, factory, timeoutMs);
}

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

/**
 * @return a proxy to the ZKFC which is associated with this HA service.
 */
public ZKFCProtocol getZKFCProxy(Configuration conf, int timeoutMs)
  throws IOException {
 Configuration confCopy = new Configuration(conf);
 // Lower the timeout so we quickly fail to connect
 confCopy.setInt(CommonConfigurationKeysPublic.IPC_CLIENT_CONNECT_MAX_RETRIES_KEY, 1);
 SocketFactory factory = NetUtils.getDefaultSocketFactory(confCopy);
 return new ZKFCProtocolClientSideTranslatorPB(
   getZKFCAddress(),
   confCopy, factory, timeoutMs);
}

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

/**
 * @return a proxy to the ZKFC which is associated with this HA service.
 */
public ZKFCProtocol getZKFCProxy(Configuration conf, int timeoutMs)
  throws IOException {
 Configuration confCopy = new Configuration(conf);
 // Lower the timeout so we quickly fail to connect
 confCopy.setInt(CommonConfigurationKeysPublic.IPC_CLIENT_CONNECT_MAX_RETRIES_KEY, 1);
 SocketFactory factory = NetUtils.getDefaultSocketFactory(confCopy);
 return new ZKFCProtocolClientSideTranslatorPB(
   getZKFCAddress(),
   confCopy, factory, timeoutMs);
}

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

/**
 * @return a proxy to the ZKFC which is associated with this HA service.
 */
public ZKFCProtocol getZKFCProxy(Configuration conf, int timeoutMs)
  throws IOException {
 Configuration confCopy = new Configuration(conf);
 // Lower the timeout so we quickly fail to connect
 confCopy.setInt(CommonConfigurationKeysPublic.IPC_CLIENT_CONNECT_MAX_RETRIES_KEY, 1);
 SocketFactory factory = NetUtils.getDefaultSocketFactory(confCopy);
 return new ZKFCProtocolClientSideTranslatorPB(
   getZKFCAddress(),
   confCopy, factory, timeoutMs);
}