Java 类org.apache.hadoop.hbase.ipc.HBaseServer 实例源码

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

@Override
public MapWritable regionServerStartup(final int port,
  final long serverStartCode, final long serverCurrentTime)
throws IOException {
  // Register with server manager
  InetAddress ia = HBaseServer.getRemoteIp();
  ServerName rs = this.serverManager.regionServerStartup(ia, port,
    serverStartCode, serverCurrentTime);
  // Send back some config info
  MapWritable mw = createConfigurationSubset();
  mw.put(new Text(HConstants.KEY_FOR_HOSTNAME_SEEN_BY_MASTER),
    new Text(rs.getHostname()));
  return mw;
}

项目：IRIndex 文件：HMaster.java

@Override
public MapWritable regionServerStartup(final int port,
  final long serverStartCode, final long serverCurrentTime)
throws IOException {
  // Register with server manager
  InetAddress ia = HBaseServer.getRemoteIp();
  ServerName rs = this.serverManager.regionServerStartup(ia, port,
    serverStartCode, serverCurrentTime);
  // Send back some config info
  MapWritable mw = createConfigurationSubset();
  mw.put(new Text(HConstants.KEY_FOR_HOSTNAME_SEEN_BY_MASTER),
    new Text(rs.getHostname()));
  return mw;
}

项目：RStore 文件：HMaster.java

@Override
public MapWritable regionServerStartup(final int port,
  final long serverStartCode, final long serverCurrentTime)
throws IOException {
  // Register with server manager
  InetAddress ia = HBaseServer.getRemoteIp();
  ServerName rs = this.serverManager.regionServerStartup(ia, port,
    serverStartCode, serverCurrentTime);
  // Send back some config info
  MapWritable mw = createConfigurationSubset();
  mw.put(new Text(HConstants.KEY_FOR_HOSTNAME_SEEN_BY_MASTER),
    new Text(rs.getHostname()));
  return mw;
}

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

@Override
public MapWritable regionServerStartup(final int port,
  final long serverStartCode, final long serverCurrentTime)
throws IOException {
  // Register with server manager
  InetAddress ia = HBaseServer.getRemoteIp();
  ServerName rs = this.serverManager.regionServerStartup(ia, port,
    serverStartCode, serverCurrentTime);
  // Send back some config info
  MapWritable mw = createConfigurationSubset();
  mw.put(new Text(HConstants.KEY_FOR_HOSTNAME_SEEN_BY_MASTER),
    new Text(rs.getHostname()));
  return mw;
}

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

@Override
public MapWritable regionServerStartup(final int port,
  final long serverStartCode, final long serverCurrentTime)
throws IOException {
  // Register with server manager
  InetAddress ia = HBaseServer.getRemoteIp();
  ServerName rs = this.serverManager.regionServerStartup(ia, port,
    serverStartCode, serverCurrentTime);
  // Send back some config info
  MapWritable mw = createConfigurationSubset();
  mw.put(new Text(HConstants.KEY_FOR_HOSTNAME_SEEN_BY_MASTER),
    new Text(rs.getHostname()));
  return mw;
}

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

@Override
public MapWritable regionServerStartup(final int port,
  final long serverStartCode, final long serverCurrentTime)
throws IOException {
  // Register with server manager
  InetAddress ia = HBaseServer.getRemoteIp();
  ServerName rs = this.serverManager.regionServerStartup(ia, port,
    serverStartCode, serverCurrentTime);
  // Send back some config info
  MapWritable mw = createConfigurationSubset();
  mw.put(new Text(HConstants.KEY_FOR_HOSTNAME_SEEN_BY_MASTER),
    new Text(rs.getHostname()));
  return mw;
}

项目：DominoHBase 文件：TokenProvider.java

@Override
public void start(CoprocessorEnvironment env) {
  // if running at region
  if (env instanceof RegionCoprocessorEnvironment) {
    RegionCoprocessorEnvironment regionEnv =
        (RegionCoprocessorEnvironment)env;
    RpcServer server = regionEnv.getRegionServerServices().getRpcServer();
    SecretManager<?> mgr = ((HBaseServer)server).getSecretManager();
    if (mgr instanceof AuthenticationTokenSecretManager) {
      secretManager = (AuthenticationTokenSecretManager)mgr;
    }
  }
}

项目：DominoHBase 文件：HMaster.java

/**
 * @return Get remote side's InetAddress
 * @throws UnknownHostException
 */
InetAddress getRemoteInetAddress(final int port, final long serverStartCode)
throws UnknownHostException {
  // Do it out here in its own little method so can fake an address when
  // mocking up in tests.
  return HBaseServer.getRemoteIp();
}

项目：hindex 文件：HMaster.java

@Override
public MapWritable regionServerStartup(final int port,
  final long serverStartCode, final long serverCurrentTime)
throws IOException {
  // Register with server manager
  InetAddress ia = HBaseServer.getRemoteIp();
  ServerName rs = this.serverManager.regionServerStartup(ia, port,
    serverStartCode, serverCurrentTime);
  // Send back some config info
  MapWritable mw = createConfigurationSubset();
  mw.put(new Text(HConstants.KEY_FOR_HOSTNAME_SEEN_BY_MASTER),
    new Text(rs.getHostname()));
  return mw;
}

项目：DominoHBase 文件：HBaseSaslRpcServer.java

public SaslDigestCallbackHandler(
    SecretManager<TokenIdentifier> secretManager,
    HBaseServer.Connection connection) {
  this.secretManager = secretManager;
  this.connection = connection;
}

项目：DominoHBase 文件：TestTokenAuthentication.java

public SecretManager<? extends TokenIdentifier> getSecretManager() {
  return ((HBaseServer)rpcServer).getSecretManager();
}