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

项目：flink 文件：HBaseTestingClusterAutostarter.java

@BeforeClass
public static void setUp() throws Exception {
    LOG.info("HBase minicluster: Starting");
    ((Log4JLogger) RpcServer.LOG).getLogger().setLevel(Level.ALL);
    ((Log4JLogger) AbstractRpcClient.LOG).getLogger().setLevel(Level.ALL);
    ((Log4JLogger) ScannerCallable.LOG).getLogger().setLevel(Level.ALL);

    TEST_UTIL.startMiniCluster(1);

    // https://issues.apache.org/jira/browse/HBASE-11711
    TEST_UTIL.getConfiguration().setInt("hbase.master.info.port", -1);

    // Make sure the zookeeper quorum value contains the right port number (varies per run).
    TEST_UTIL.getConfiguration().set("hbase.zookeeper.quorum", "localhost:" + TEST_UTIL.getZkCluster().getClientPort());

    conf = initialize(TEST_UTIL.getConfiguration());
    LOG.info("HBase minicluster: Running");
}

项目：flink 文件：HBaseTestingClusterAutostarter.java

@BeforeClass
public static void setUp() throws Exception {
    LOG.info("HBase minicluster: Starting");
    ((Log4JLogger) RpcServer.LOG).getLogger().setLevel(Level.ALL);
    ((Log4JLogger) AbstractRpcClient.LOG).getLogger().setLevel(Level.ALL);
    ((Log4JLogger) ScannerCallable.LOG).getLogger().setLevel(Level.ALL);

    TEST_UTIL.startMiniCluster(1);

    // https://issues.apache.org/jira/browse/HBASE-11711
    TEST_UTIL.getConfiguration().setInt("hbase.master.info.port", -1);

    // Make sure the zookeeper quorum value contains the right port number (varies per run).
    TEST_UTIL.getConfiguration().set("hbase.zookeeper.quorum", "localhost:" + TEST_UTIL.getZkCluster().getClientPort());

    initialize(TEST_UTIL.getConfiguration());
    LOG.info("HBase minicluster: Running");
}

项目：ditb 文件：TestFromClientSideNoCodec.java

@Test
public void testNoCodec() {
  Configuration c = new Configuration();
  c.set("hbase.client.default.rpc.codec", "");
  String codec = AbstractRpcClient.getDefaultCodec(c);
  assertTrue(codec == null || codec.length() == 0);
}

项目：ditb 文件：TestClientScannerRPCTimeout.java

@BeforeClass
public static void setUpBeforeClass() throws Exception {
  ((Log4JLogger)RpcServer.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)AbstractRpcClient.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)ScannerCallable.LOG).getLogger().setLevel(Level.ALL);
  Configuration conf = TEST_UTIL.getConfiguration();
  // Don't report so often so easier to see other rpcs
  conf.setInt("hbase.regionserver.msginterval", 3 * 10000);
  conf.setInt(HConstants.HBASE_RPC_TIMEOUT_KEY, rpcTimeout);
  conf.setStrings(HConstants.REGION_SERVER_IMPL, RegionServerWithScanTimeout.class.getName());
  conf.setInt(HConstants.HBASE_CLIENT_RETRIES_NUMBER, CLIENT_RETRIES_NUMBER);
  conf.setInt(HConstants.HBASE_CLIENT_PAUSE, 1000);
  TEST_UTIL.startMiniCluster(1);
}

项目：ditb 文件：FilterTestingCluster.java

@BeforeClass
public static void setUp() throws Exception {
  ((Log4JLogger)RpcServer.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)AbstractRpcClient.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)ScannerCallable.LOG).getLogger().setLevel(Level.ALL);
  TEST_UTIL.startMiniCluster(1);
  initialize(TEST_UTIL.getConfiguration());
}

项目：ditb 文件：IntegrationTestRpcClient.java

protected AbstractRpcClient createRpcClient(Configuration conf, boolean isSyncClient) {
  return isSyncClient ?
      new RpcClientImpl(conf, HConstants.CLUSTER_ID_DEFAULT) :
        new AsyncRpcClient(conf) {
        @Override
        Codec getCodec() {
          return null;
        }
      };
}

项目：pbase 文件：TestFromClientSideNoCodec.java

@Test
public void testNoCodec() {
  Configuration c = new Configuration();
  c.set("hbase.client.default.rpc.codec", "");
  String codec = AbstractRpcClient.getDefaultCodec(c);
  assertTrue(codec == null || codec.length() == 0);
}

项目：pbase 文件：TestClientScannerRPCTimeout.java

@BeforeClass
public static void setUpBeforeClass() throws Exception {
  ((Log4JLogger)RpcServer.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)AbstractRpcClient.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)ScannerCallable.LOG).getLogger().setLevel(Level.ALL);
  Configuration conf = TEST_UTIL.getConfiguration();
  // Don't report so often so easier to see other rpcs
  conf.setInt("hbase.regionserver.msginterval", 3 * 10000);
  conf.setInt(HConstants.HBASE_RPC_TIMEOUT_KEY, rpcTimeout);
  conf.setStrings(HConstants.REGION_SERVER_IMPL, RegionServerWithScanTimeout.class.getName());
  conf.setInt(HConstants.HBASE_CLIENT_RETRIES_NUMBER, CLIENT_RETRIES_NUMBER);
  conf.setInt(HConstants.HBASE_CLIENT_PAUSE, 1000);
  TEST_UTIL.startMiniCluster(1);
}

项目：pbase 文件：FilterTestingCluster.java

@BeforeClass
public static void setUp() throws Exception {
  ((Log4JLogger)RpcServer.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)AbstractRpcClient.LOG).getLogger().setLevel(Level.ALL);
  ((Log4JLogger)ScannerCallable.LOG).getLogger().setLevel(Level.ALL);
  TEST_UTIL.startMiniCluster(1);
  initialize(TEST_UTIL.getConfiguration());
}

项目：hbase 文件：TestFromClientSideNoCodec.java

@Test
public void testNoCodec() {
  Configuration c = new Configuration();
  c.set("hbase.client.default.rpc.codec", "");
  String codec = AbstractRpcClient.getDefaultCodec(c);
  assertTrue(codec == null || codec.length() == 0);
}

项目：ditb 文件：IntegrationTestRpcClient.java

public SimpleClient(Cluster cluster, AbstractRpcClient rpcClient, String id) {
  this.cluster = cluster;
  this.rpcClient = rpcClient;
  this.id = id;
}