hbase-server/src/test/java/org/apache/hadoop/hbase/client/DummyAsyncClusterConnection.java

   1 /**
   2  * Licensed to the Apache Software Foundation (ASF) under one
   3  * or more contributor license agreements.  See the NOTICE file
   4  * distributed with this work for additional information
   5  * regarding copyright ownership.  The ASF licenses this file
   6  * to you under the Apache License, Version 2.0 (the
   7  * "License"); you may not use this file except in compliance
   8  * with the License.  You may obtain a copy of the License at
   9  *
  10  *     http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software
  13  * distributed under the License is distributed on an "AS IS" BASIS,
  14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  * See the License for the specific language governing permissions and
  16  * limitations under the License.
  17  */
  18 package org.apache.hadoop.hbase.client;
  19
  20 import java.io.IOException;
  21 import java.util.List;
  22 import java.util.concurrent.CompletableFuture;
  23 import java.util.concurrent.ExecutorService;
  24 import org.apache.hadoop.conf.Configuration;
  25 import org.apache.hadoop.hbase.RegionLocations;
  26 import org.apache.hadoop.hbase.ServerName;
  27 import org.apache.hadoop.hbase.TableName;
  28 import org.apache.hadoop.hbase.ipc.RpcClient;
  29 import org.apache.hadoop.hbase.util.Pair;
  30 import org.apache.hadoop.hbase.wal.WAL.Entry;
  31 import org.apache.hadoop.hbase.zookeeper.MasterAddressTracker;
  32 import org.apache.hadoop.security.token.Token;
  33
  34 import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse;
  35
  36 /**
  37  * Can be overridden in UT if you only want to implement part of the methods in
  38  * {@link AsyncClusterConnection}.
  39  */
  40 public class DummyAsyncClusterConnection implements AsyncClusterConnection {
  41
  42   @Override
  43   public Configuration getConfiguration() {
  44     return null;
  45   }
  46
  47   @Override
  48   public AsyncTableRegionLocator getRegionLocator(TableName tableName) {
  49     return null;
  50   }
  51
  52   @Override
  53   public void clearRegionLocationCache() {
  54   }
  55
  56   @Override
  57   public AsyncTableBuilder<AdvancedScanResultConsumer> getTableBuilder(TableName tableName) {
  58     return null;
  59   }
  60
  61   @Override
  62   public AsyncTableBuilder<ScanResultConsumer> getTableBuilder(TableName tableName,
  63       ExecutorService pool) {
  64     return null;
  65   }
  66
  67   @Override
  68   public AsyncAdminBuilder getAdminBuilder() {
  69     return null;
  70   }
  71
  72   @Override
  73   public AsyncAdminBuilder getAdminBuilder(ExecutorService pool) {
  74     return null;
  75   }
  76
  77   @Override
  78   public AsyncBufferedMutatorBuilder getBufferedMutatorBuilder(TableName tableName) {
  79     return null;
  80   }
  81
  82   @Override
  83   public AsyncBufferedMutatorBuilder getBufferedMutatorBuilder(TableName tableName,
  84       ExecutorService pool) {
  85     return null;
  86   }
  87
  88   @Override
  89   public CompletableFuture<Hbck> getHbck() {
  90     return null;
  91   }
  92
  93   @Override
  94   public Hbck getHbck(ServerName masterServer) throws IOException {
  95     return null;
  96   }
  97
  98   @Override
  99   public boolean isClosed() {
 100     return false;
 101   }
 102
 103   @Override
 104   public void close() throws IOException {
 105   }
 106
 107   @Override
 108   public AsyncRegionServerAdmin getRegionServerAdmin(ServerName serverName) {
 109     return null;
 110   }
 111
 112   @Override
 113   public NonceGenerator getNonceGenerator() {
 114     return null;
 115   }
 116
 117   @Override
 118   public RpcClient getRpcClient() {
 119     return null;
 120   }
 121
 122   @Override
 123   public CompletableFuture<FlushRegionResponse> flush(byte[] regionName,
 124       boolean writeFlushWALMarker) {
 125     return null;
 126   }
 127
 128   @Override
 129   public CompletableFuture<RegionLocations> getRegionLocations(TableName tableName, byte[] row,
 130       boolean reload) {
 131     return null;
 132   }
 133
 134   @Override
 135   public CompletableFuture<String> prepareBulkLoad(TableName tableName) {
 136     return null;
 137   }
 138
 139   @Override
 140   public CompletableFuture<Boolean> bulkLoad(TableName tableName,
 141     List<Pair<byte[], String>> familyPaths, byte[] row, boolean assignSeqNum, Token<?> userToken,
 142     String bulkToken, boolean copyFiles, List<String> clusterIds, boolean replicate) {
 143     return null;
 144   }
 145
 146   @Override
 147   public CompletableFuture<Void> cleanupBulkLoad(TableName tableName, String bulkToken) {
 148     return null;
 149   }
 150
 151   @Override
 152   public Connection toConnection() {
 153     return null;
 154   }
 155
 156   @Override
 157   public CompletableFuture<List<ServerName>>
 158     getLiveRegionServers(MasterAddressTracker masterAddrTracker, int count) {
 159     return null;
 160   }
 161
 162   @Override
 163   public CompletableFuture<List<ServerName>> getAllBootstrapNodes(ServerName regionServer) {
 164     return null;
 165   }
 166
 167   @Override
 168   public CompletableFuture<Void> replicate(RegionInfo replica,
 169     List<Entry> entries, int numRetries, long rpcTimeoutNs,
 170     long operationTimeoutNs) {
 171     return null;
 172   }
 173 }