PR Feedback

apache · Mar 16, 2022 · c2a8978 · c2a8978
1 parent 297bc30
commit c2a8978
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 10 deletions.
diff --git a/...int/src/test/java/org/apache/hadoop/hbase/coprocessor/TestCoprocessorEndpointTracing.java b/...int/src/test/java/org/apache/hadoop/hbase/coprocessor/TestCoprocessorEndpointTracing.java
@@ -228,7 +228,7 @@ public void onError(Throwable error) {
 
   @Test
   public void traceSyncTableEndpointCall() throws Exception {
-    final Connection connection = connectionRule.getSyncConnection();
+    final Connection connection = connectionRule.getConnection();
     try (final Table table = connection.getTable(TEST_TABLE)) {
       final RpcController controller = new ServerRpcController();
       final EchoRequestProto request = EchoRequestProto.newBuilder().setMessage("hello").build();
@@ -280,7 +280,7 @@ public void traceSyncTableEndpointCall() throws Exception {
 
   @Test
   public void traceSyncTableEndpointCallAndCallback() throws Exception {
-    final Connection connection = connectionRule.getSyncConnection();
+    final Connection connection = connectionRule.getConnection();
     try (final Table table = connection.getTable(TEST_TABLE)) {
       final RpcController controller = new ServerRpcController();
       final EchoRequestProto request = EchoRequestProto.newBuilder().setMessage("hello").build();
@@ -336,7 +336,7 @@ public void traceSyncTableEndpointCallAndCallback() throws Exception {
 
   @Test
   public void traceSyncTableRegionCoprocessorRpcChannel() throws Exception {
-    final Connection connection = connectionRule.getSyncConnection();
+    final Connection connection = connectionRule.getConnection();
     try (final Table table = connection.getTable(TEST_TABLE)) {
       final EchoRequestProto request = EchoRequestProto.newBuilder().setMessage("hello").build();
       final EchoResponseProto response = TraceUtil.trace(() -> {
@@ -376,7 +376,7 @@ public void traceSyncTableRegionCoprocessorRpcChannel() throws Exception {
 
   @Test
   public void traceSyncTableBatchEndpoint() throws Exception {
-    final Connection connection = connectionRule.getSyncConnection();
+    final Connection connection = connectionRule.getConnection();
     try (final Table table = connection.getTable(TEST_TABLE)) {
       final Descriptors.MethodDescriptor descriptor =
         TestProtobufRpcProto.getDescriptor().findMethodByName("echo");
@@ -423,7 +423,7 @@ public void traceSyncTableBatchEndpoint() throws Exception {
 
   @Test
   public void traceSyncTableBatchEndpointCallback() throws Exception {
-    final Connection connection = connectionRule.getSyncConnection();
+    final Connection connection = connectionRule.getConnection();
     try (final Table table = connection.getTable(TEST_TABLE)) {
       final Descriptors.MethodDescriptor descriptor =
         TestProtobufRpcProto.getDescriptor().findMethodByName("echo");
@@ -504,7 +504,7 @@ public void traceAsyncAdminEndpoint() throws Exception {
 
   @Test
   public void traceSyncAdminEndpoint() throws Exception {
-    final Connection connection = connectionRule.getSyncConnection();
+    final Connection connection = connectionRule.getConnection();
     try (final Admin admin = connection.getAdmin()) {
       final TestProtobufRpcProto.BlockingInterface service =
         TestProtobufRpcProto.newBlockingStub(admin.coprocessorService());

diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/ConnectionRule.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/ConnectionRule.java
@@ -53,7 +53,7 @@ public final class ConnectionRule extends ExternalResource {
   private Connection connection;
   private AsyncConnection asyncConnection;
 
-  public static ConnectionRule createSyncConnectionRule(
+  public static ConnectionRule createConnectionRule(
     final Supplier<Connection> connectionSupplier
   ) {
     return new ConnectionRule(connectionSupplier, null);
@@ -80,7 +80,7 @@ private ConnectionRule(
     this.asyncConnectionSupplier = asyncConnectionSupplier;
   }
 
-  public Connection getSyncConnection() {
+  public Connection getConnection() {
     if (connection == null) {
       throw new IllegalStateException(
         "ConnectionRule not initialized with a synchronous connection.");

diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/MiniClusterRule.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/MiniClusterRule.java
@@ -111,10 +111,10 @@ public HBaseTestingUtil getTestingUtility() {
   }
 
   /**
-   * Create a {@link AsyncConnection} to the managed {@link SingleProcessHBaseCluster}. It's up to
+   * Create a {@link Connection} to the managed {@link SingleProcessHBaseCluster}. It's up to
    * the caller to {@link Connection#close() close()} the connection when finished.
    */
-  public Connection createSyncConnection() {
+  public Connection createConnection() {
     try {
       return createAsyncConnection().get().toConnection();
     } catch (InterruptedException | ExecutionException e) {