hbase-server/src/test/java/org/apache/hadoop/hbase/client/DummyAsyncTable.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.util.List;
  21 import java.util.concurrent.CompletableFuture;
  22 import java.util.concurrent.TimeUnit;
  23 import java.util.function.Function;
  24 import org.apache.hadoop.conf.Configuration;
  25 import org.apache.hadoop.hbase.TableName;
  26 import org.apache.hadoop.hbase.filter.Filter;
  27
  28 import org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel;
  29
  30 /**
  31  * Can be overridden in UT if you only want to implement part of the methods in {@link AsyncTable}.
  32  */
  33 public class DummyAsyncTable<C extends ScanResultConsumerBase> implements AsyncTable<C> {
  34
  35   @Override
  36   public TableName getName() {
  37     return null;
  38   }
  39
  40   @Override
  41   public Configuration getConfiguration() {
  42     return null;
  43   }
  44
  45   @Override
  46   public CompletableFuture<TableDescriptor> getDescriptor() {
  47     return null;
  48   }
  49
  50   @Override
  51   public AsyncTableRegionLocator getRegionLocator() {
  52     return null;
  53   }
  54
  55   @Override
  56   public long getRpcTimeout(TimeUnit unit) {
  57     return 0;
  58   }
  59
  60   @Override
  61   public long getReadRpcTimeout(TimeUnit unit) {
  62     return 0;
  63   }
  64
  65   @Override
  66   public long getWriteRpcTimeout(TimeUnit unit) {
  67     return 0;
  68   }
  69
  70   @Override
  71   public long getOperationTimeout(TimeUnit unit) {
  72     return 0;
  73   }
  74
  75   @Override
  76   public long getScanTimeout(TimeUnit unit) {
  77     return 0;
  78   }
  79
  80   @Override
  81   public CompletableFuture<Result> get(Get get) {
  82     return null;
  83   }
  84
  85   @Override
  86   public CompletableFuture<Void> put(Put put) {
  87     return null;
  88   }
  89
  90   @Override
  91   public CompletableFuture<Void> delete(Delete delete) {
  92     return null;
  93   }
  94
  95   @Override
  96   public CompletableFuture<Result> append(Append append) {
  97     return null;
  98   }
  99
 100   @Override
 101   public CompletableFuture<Result> increment(Increment increment) {
 102     return null;
 103   }
 104
 105   @Override
 106   public CheckAndMutateBuilder checkAndMutate(byte[] row, byte[] family) {
 107     return null;
 108   }
 109
 110   @Override
 111   public CheckAndMutateWithFilterBuilder checkAndMutate(byte[] row, Filter filter) {
 112     return null;
 113   }
 114
 115   @Override
 116   public CompletableFuture<CheckAndMutateResult> checkAndMutate(CheckAndMutate checkAndMutate) {
 117     return null;
 118   }
 119
 120   @Override
 121   public List<CompletableFuture<CheckAndMutateResult>> checkAndMutate(
 122     List<CheckAndMutate> checkAndMutates) {
 123     return null;
 124   }
 125
 126   @Override
 127   public CompletableFuture<Result> mutateRow(RowMutations mutation) {
 128     return null;
 129   }
 130
 131   @Override
 132   public void scan(Scan scan, C consumer) {
 133   }
 134
 135   @Override
 136   public ResultScanner getScanner(Scan scan) {
 137     return null;
 138   }
 139
 140   @Override
 141   public CompletableFuture<List<Result>> scanAll(Scan scan) {
 142     return null;
 143   }
 144
 145   @Override
 146   public List<CompletableFuture<Result>> get(List<Get> gets) {
 147     return null;
 148   }
 149
 150   @Override
 151   public List<CompletableFuture<Void>> put(List<Put> puts) {
 152     return null;
 153   }
 154
 155   @Override
 156   public List<CompletableFuture<Void>> delete(List<Delete> deletes) {
 157     return null;
 158   }
 159
 160   @Override
 161   public <T> List<CompletableFuture<T>> batch(List<? extends Row> actions) {
 162     return null;
 163   }
 164
 165   @Override
 166   public <S, R> CompletableFuture<R> coprocessorService(Function<RpcChannel, S> stubMaker,
 167       ServiceCaller<S, R> callable, byte[] row) {
 168     return null;
 169   }
 170
 171   @Override
 172   public <S, R> CoprocessorServiceBuilder<S, R> coprocessorService(
 173       Function<RpcChannel, S> stubMaker, ServiceCaller<S, R> callable,
 174       CoprocessorCallback<R> callback) {
 175     return null;
 176   }
 177 }