001/**
002 * Licensed to the Apache Software Foundation (ASF) under one
003 * or more contributor license agreements.  See the NOTICE file
004 * distributed with this work for additional information
005 * regarding copyright ownership.  The ASF licenses this file
006 * to you under the Apache License, Version 2.0 (the
007 * "License"); you may not use this file except in compliance
008 * with the License.  You may obtain a copy of the License at
009 *
010 *     http://www.apache.org/licenses/LICENSE-2.0
011 *
012 * Unless required by applicable law or agreed to in writing, software
013 * distributed under the License is distributed on an "AS IS" BASIS,
014 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
015 * See the License for the specific language governing permissions and
016 * limitations under the License.
017 */
018package org.apache.hadoop.hbase.client;
019
020import org.apache.yetus.audience.InterfaceAudience;
021import org.apache.hbase.thirdparty.com.google.protobuf.RpcController;
022import org.apache.hbase.thirdparty.com.google.protobuf.ServiceException;
023
024import org.apache.hadoop.hbase.shaded.protobuf.generated.AccessControlProtos.GetUserPermissionsRequest;
025import org.apache.hadoop.hbase.shaded.protobuf.generated.AccessControlProtos.GetUserPermissionsResponse;
026import org.apache.hadoop.hbase.shaded.protobuf.generated.AccessControlProtos.GrantRequest;
027import org.apache.hadoop.hbase.shaded.protobuf.generated.AccessControlProtos.GrantResponse;
028import org.apache.hadoop.hbase.shaded.protobuf.generated.AccessControlProtos.HasUserPermissionsRequest;
029import org.apache.hadoop.hbase.shaded.protobuf.generated.AccessControlProtos.HasUserPermissionsResponse;
030import org.apache.hadoop.hbase.shaded.protobuf.generated.AccessControlProtos.RevokeRequest;
031import org.apache.hadoop.hbase.shaded.protobuf.generated.AccessControlProtos.RevokeResponse;
032import org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceRequest;
033import org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceResponse;
034import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AbortProcedureRequest;
035import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AbortProcedureResponse;
036import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest;
037import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse;
038import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest;
039import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse;
040import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest;
041import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse;
042import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ClearDeadServersRequest;
043import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ClearDeadServersResponse;
044import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest;
045import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse;
046import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateTableRequest;
047import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateTableResponse;
048import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DecommissionRegionServersRequest;
049import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DecommissionRegionServersResponse;
050import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteColumnRequest;
051import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteColumnResponse;
052import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest;
053import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse;
054import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest;
055import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse;
056import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteTableRequest;
057import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteTableResponse;
058import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest;
059import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse;
060import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableCatalogJanitorRequest;
061import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableCatalogJanitorResponse;
062import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest;
063import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse;
064import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ExecProcedureRequest;
065import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ExecProcedureResponse;
066import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetClusterStatusRequest;
067import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetClusterStatusResponse;
068import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetCompletedSnapshotsRequest;
069import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetCompletedSnapshotsResponse;
070import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetLocksRequest;
071import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetLocksResponse;
072import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetNamespaceDescriptorRequest;
073import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetNamespaceDescriptorResponse;
074import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetProcedureResultRequest;
075import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetProcedureResultResponse;
076import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetProceduresRequest;
077import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetProceduresResponse;
078import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetSchemaAlterStatusRequest;
079import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetSchemaAlterStatusResponse;
080import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetTableDescriptorsRequest;
081import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetTableDescriptorsResponse;
082import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetTableNamesRequest;
083import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetTableNamesResponse;
084import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetTableStateRequest;
085import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetTableStateResponse;
086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsBalancerEnabledRequest;
087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsBalancerEnabledResponse;
088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsCatalogJanitorEnabledRequest;
089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsCatalogJanitorEnabledResponse;
090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsCleanerChoreEnabledRequest;
091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsCleanerChoreEnabledResponse;
092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsInMaintenanceModeRequest;
093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsInMaintenanceModeResponse;
094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsMasterRunningRequest;
095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsMasterRunningResponse;
096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsNormalizerEnabledRequest;
097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsNormalizerEnabledResponse;
098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsProcedureDoneRequest;
099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsProcedureDoneResponse;
100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsRpcThrottleEnabledRequest;
101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsRpcThrottleEnabledResponse;
102import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsSnapshotDoneRequest;
103import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsSnapshotDoneResponse;
104import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsSplitOrMergeEnabledRequest;
105import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.IsSplitOrMergeEnabledResponse;
106import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ListDecommissionedRegionServersRequest;
107import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ListDecommissionedRegionServersResponse;
108import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ListNamespaceDescriptorsRequest;
109import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ListNamespaceDescriptorsResponse;
110import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ListTableDescriptorsByNamespaceRequest;
111import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ListTableDescriptorsByNamespaceResponse;
112import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ListTableNamesByNamespaceRequest;
113import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ListTableNamesByNamespaceResponse;
114import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MajorCompactionTimestampForRegionRequest;
115import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MajorCompactionTimestampRequest;
116import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MajorCompactionTimestampResponse;
117import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService;
118import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MergeTableRegionsRequest;
119import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MergeTableRegionsResponse;
120import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ModifyColumnRequest;
121import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ModifyColumnResponse;
122import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ModifyNamespaceRequest;
123import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ModifyNamespaceResponse;
124import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ModifyTableRequest;
125import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ModifyTableResponse;
126import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MoveRegionRequest;
127import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MoveRegionResponse;
128import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.NormalizeRequest;
129import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.NormalizeResponse;
130import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.OfflineRegionRequest;
131import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.OfflineRegionResponse;
132import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RecommissionRegionServerRequest;
133import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RecommissionRegionServerResponse;
134import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RestoreSnapshotRequest;
135import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RestoreSnapshotResponse;
136import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RunCatalogScanRequest;
137import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RunCatalogScanResponse;
138import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RunCleanerChoreRequest;
139import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RunCleanerChoreResponse;
140import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SecurityCapabilitiesRequest;
141import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SecurityCapabilitiesResponse;
142import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SetBalancerRunningRequest;
143import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SetBalancerRunningResponse;
144import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SetCleanerChoreRunningRequest;
145import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SetCleanerChoreRunningResponse;
146import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SetNormalizerRunningRequest;
147import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SetNormalizerRunningResponse;
148import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SetQuotaRequest;
149import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SetQuotaResponse;
150import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SetSplitOrMergeEnabledRequest;
151import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SetSplitOrMergeEnabledResponse;
152import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ShutdownRequest;
153import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ShutdownResponse;
154import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SnapshotRequest;
155import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SnapshotResponse;
156import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SplitTableRegionRequest;
157import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SplitTableRegionResponse;
158import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.StopMasterRequest;
159import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.StopMasterResponse;
160import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SwitchExceedThrottleQuotaRequest;
161import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SwitchExceedThrottleQuotaResponse;
162import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SwitchRpcThrottleRequest;
163import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SwitchRpcThrottleResponse;
164import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.TruncateTableRequest;
165import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.TruncateTableResponse;
166import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.UnassignRegionRequest;
167import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.UnassignRegionResponse;
168import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetQuotaStatesRequest;
169import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetQuotaStatesResponse;
170import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesRequest;
171import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse;
172import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.AddReplicationPeerRequest;
173import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.AddReplicationPeerResponse;
174import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.DisableReplicationPeerRequest;
175import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.DisableReplicationPeerResponse;
176import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.EnableReplicationPeerRequest;
177import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.EnableReplicationPeerResponse;
178import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.GetReplicationPeerConfigRequest;
179import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.GetReplicationPeerConfigResponse;
180import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.ListReplicationPeersRequest;
181import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.ListReplicationPeersResponse;
182import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.RemoveReplicationPeerRequest;
183import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.RemoveReplicationPeerResponse;
184import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.UpdateReplicationPeerConfigRequest;
185import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.UpdateReplicationPeerConfigResponse;
186
187/**
188 * A short-circuit connection that can bypass the RPC layer (serialization, deserialization,
189 * networking, etc..) when talking to a local master
190 */
191@InterfaceAudience.Private
192public class ShortCircuitMasterConnection implements MasterKeepAliveConnection {
193
194  private final MasterService.BlockingInterface stub;
195
196  public ShortCircuitMasterConnection(MasterService.BlockingInterface stub) {
197    this.stub = stub;
198  }
199
200  @Override
201  public UnassignRegionResponse unassignRegion(RpcController controller,
202      UnassignRegionRequest request) throws ServiceException {
203    return stub.unassignRegion(controller, request);
204  }
205
206  @Override
207  public TruncateTableResponse truncateTable(RpcController controller, TruncateTableRequest request)
208      throws ServiceException {
209    return stub.truncateTable(controller, request);
210  }
211
212  @Override
213  public StopMasterResponse stopMaster(RpcController controller, StopMasterRequest request)
214      throws ServiceException {
215    return stub.stopMaster(controller, request);
216  }
217
218  @Override
219  public SnapshotResponse snapshot(RpcController controller, SnapshotRequest request)
220      throws ServiceException {
221    return stub.snapshot(controller, request);
222  }
223
224  @Override
225  public ShutdownResponse shutdown(RpcController controller, ShutdownRequest request)
226      throws ServiceException {
227    return stub.shutdown(controller, request);
228  }
229
230  @Override
231  public SetSplitOrMergeEnabledResponse setSplitOrMergeEnabled(RpcController controller,
232      SetSplitOrMergeEnabledRequest request) throws ServiceException {
233    return stub.setSplitOrMergeEnabled(controller, request);
234  }
235
236  @Override
237  public SetQuotaResponse setQuota(RpcController controller, SetQuotaRequest request)
238      throws ServiceException {
239    return stub.setQuota(controller, request);
240  }
241
242  @Override
243  public SetNormalizerRunningResponse setNormalizerRunning(RpcController controller,
244      SetNormalizerRunningRequest request) throws ServiceException {
245    return stub.setNormalizerRunning(controller, request);
246  }
247
248  @Override
249  public SetBalancerRunningResponse setBalancerRunning(RpcController controller,
250      SetBalancerRunningRequest request) throws ServiceException {
251    return stub.setBalancerRunning(controller, request);
252  }
253
254  @Override
255  public RunCatalogScanResponse runCatalogScan(RpcController controller,
256      RunCatalogScanRequest request) throws ServiceException {
257    return stub.runCatalogScan(controller, request);
258  }
259
260  @Override
261  public RestoreSnapshotResponse restoreSnapshot(RpcController controller,
262      RestoreSnapshotRequest request) throws ServiceException {
263    return stub.restoreSnapshot(controller, request);
264  }
265
266  @Override
267  public RemoveReplicationPeerResponse removeReplicationPeer(RpcController controller,
268      RemoveReplicationPeerRequest request) throws ServiceException {
269    return stub.removeReplicationPeer(controller, request);
270  }
271
272  @Override
273  public RecommissionRegionServerResponse recommissionRegionServer(RpcController controller,
274      RecommissionRegionServerRequest request) throws ServiceException {
275    return stub.recommissionRegionServer(controller, request);
276  }
277
278  @Override
279  public OfflineRegionResponse offlineRegion(RpcController controller, OfflineRegionRequest request)
280      throws ServiceException {
281    return stub.offlineRegion(controller, request);
282  }
283
284  @Override
285  public NormalizeResponse normalize(RpcController controller, NormalizeRequest request)
286      throws ServiceException {
287    return stub.normalize(controller, request);
288  }
289
290  @Override
291  public MoveRegionResponse moveRegion(RpcController controller, MoveRegionRequest request)
292      throws ServiceException {
293    return stub.moveRegion(controller, request);
294  }
295
296  @Override
297  public ModifyTableResponse modifyTable(RpcController controller, ModifyTableRequest request)
298      throws ServiceException {
299    return stub.modifyTable(controller, request);
300  }
301
302  @Override
303  public ModifyNamespaceResponse modifyNamespace(RpcController controller,
304      ModifyNamespaceRequest request) throws ServiceException {
305    return stub.modifyNamespace(controller, request);
306  }
307
308  @Override
309  public ModifyColumnResponse modifyColumn(RpcController controller, ModifyColumnRequest request)
310      throws ServiceException {
311    return stub.modifyColumn(controller, request);
312  }
313
314  @Override
315  public MergeTableRegionsResponse mergeTableRegions(RpcController controller,
316      MergeTableRegionsRequest request) throws ServiceException {
317    return stub.mergeTableRegions(controller, request);
318  }
319
320  @Override
321  public ListTableNamesByNamespaceResponse listTableNamesByNamespace(RpcController controller,
322      ListTableNamesByNamespaceRequest request) throws ServiceException {
323    return stub.listTableNamesByNamespace(controller, request);
324  }
325
326  @Override
327  public ListTableDescriptorsByNamespaceResponse listTableDescriptorsByNamespace(
328      RpcController controller, ListTableDescriptorsByNamespaceRequest request)
329      throws ServiceException {
330    return stub.listTableDescriptorsByNamespace(controller, request);
331  }
332
333  @Override
334  public GetProceduresResponse getProcedures(RpcController controller,
335      GetProceduresRequest request) throws ServiceException {
336    return stub.getProcedures(controller, request);
337  }
338
339  @Override
340  public GetLocksResponse getLocks(RpcController controller,
341      GetLocksRequest request) throws ServiceException {
342    return stub.getLocks(controller, request);
343  }
344
345  @Override
346  public ListNamespaceDescriptorsResponse listNamespaceDescriptors(RpcController controller,
347      ListNamespaceDescriptorsRequest request) throws ServiceException {
348    return stub.listNamespaceDescriptors(controller, request);
349  }
350
351  @Override
352  public ListDecommissionedRegionServersResponse listDecommissionedRegionServers(RpcController controller,
353      ListDecommissionedRegionServersRequest request) throws ServiceException {
354    return stub.listDecommissionedRegionServers(controller, request);
355  }
356
357  @Override
358  public IsSplitOrMergeEnabledResponse isSplitOrMergeEnabled(RpcController controller,
359      IsSplitOrMergeEnabledRequest request) throws ServiceException {
360    return stub.isSplitOrMergeEnabled(controller, request);
361  }
362
363  @Override
364  public IsSnapshotDoneResponse isSnapshotDone(RpcController controller,
365      IsSnapshotDoneRequest request) throws ServiceException {
366    return stub.isSnapshotDone(controller, request);
367  }
368
369  @Override
370  public IsProcedureDoneResponse isProcedureDone(RpcController controller,
371      IsProcedureDoneRequest request) throws ServiceException {
372    return stub.isProcedureDone(controller, request);
373  }
374
375  @Override
376  public IsNormalizerEnabledResponse isNormalizerEnabled(RpcController controller,
377      IsNormalizerEnabledRequest request) throws ServiceException {
378    return stub.isNormalizerEnabled(controller, request);
379  }
380
381  @Override
382  public IsMasterRunningResponse isMasterRunning(RpcController controller,
383      IsMasterRunningRequest request) throws ServiceException {
384    return stub.isMasterRunning(controller, request);
385  }
386
387  @Override
388  public IsInMaintenanceModeResponse isMasterInMaintenanceMode(RpcController controller,
389      IsInMaintenanceModeRequest request) throws ServiceException {
390    return stub.isMasterInMaintenanceMode(controller, request);
391  }
392
393  @Override
394  public IsCatalogJanitorEnabledResponse isCatalogJanitorEnabled(RpcController controller,
395      IsCatalogJanitorEnabledRequest request) throws ServiceException {
396    return stub.isCatalogJanitorEnabled(controller, request);
397  }
398
399  @Override
400  public IsBalancerEnabledResponse isBalancerEnabled(RpcController controller,
401      IsBalancerEnabledRequest request) throws ServiceException {
402    return stub.isBalancerEnabled(controller, request);
403  }
404
405  @Override
406  public GetTableStateResponse getTableState(RpcController controller, GetTableStateRequest request)
407      throws ServiceException {
408    return stub.getTableState(controller, request);
409  }
410
411  @Override
412  public GetTableNamesResponse getTableNames(RpcController controller, GetTableNamesRequest request)
413      throws ServiceException {
414    return stub.getTableNames(controller, request);
415  }
416
417  @Override
418  public GetTableDescriptorsResponse getTableDescriptors(RpcController controller,
419      GetTableDescriptorsRequest request) throws ServiceException {
420    return stub.getTableDescriptors(controller, request);
421  }
422
423  @Override
424  public SecurityCapabilitiesResponse getSecurityCapabilities(RpcController controller,
425      SecurityCapabilitiesRequest request) throws ServiceException {
426    return stub.getSecurityCapabilities(controller, request);
427  }
428
429  @Override
430  public GetSchemaAlterStatusResponse getSchemaAlterStatus(RpcController controller,
431      GetSchemaAlterStatusRequest request) throws ServiceException {
432    return stub.getSchemaAlterStatus(controller, request);
433  }
434
435  @Override
436  public GetProcedureResultResponse getProcedureResult(RpcController controller,
437      GetProcedureResultRequest request) throws ServiceException {
438    return stub.getProcedureResult(controller, request);
439  }
440
441  @Override
442  public GetNamespaceDescriptorResponse getNamespaceDescriptor(RpcController controller,
443      GetNamespaceDescriptorRequest request) throws ServiceException {
444    return stub.getNamespaceDescriptor(controller, request);
445  }
446
447  @Override
448  public MajorCompactionTimestampResponse getLastMajorCompactionTimestampForRegion(
449      RpcController controller, MajorCompactionTimestampForRegionRequest request)
450      throws ServiceException {
451    return stub.getLastMajorCompactionTimestampForRegion(controller, request);
452  }
453
454  @Override
455  public MajorCompactionTimestampResponse getLastMajorCompactionTimestamp(RpcController controller,
456      MajorCompactionTimestampRequest request) throws ServiceException {
457    return stub.getLastMajorCompactionTimestamp(controller, request);
458  }
459
460  @Override
461  public GetCompletedSnapshotsResponse getCompletedSnapshots(RpcController controller,
462      GetCompletedSnapshotsRequest request) throws ServiceException {
463    return stub.getCompletedSnapshots(controller, request);
464  }
465
466  @Override
467  public GetClusterStatusResponse getClusterStatus(RpcController controller,
468      GetClusterStatusRequest request) throws ServiceException {
469    return stub.getClusterStatus(controller, request);
470  }
471
472  @Override
473  public ExecProcedureResponse execProcedureWithRet(RpcController controller,
474      ExecProcedureRequest request) throws ServiceException {
475    return stub.execProcedureWithRet(controller, request);
476  }
477
478  @Override
479  public ExecProcedureResponse execProcedure(RpcController controller, ExecProcedureRequest request)
480      throws ServiceException {
481    return stub.execProcedure(controller, request);
482  }
483
484  @Override
485  public CoprocessorServiceResponse execMasterService(RpcController controller,
486      CoprocessorServiceRequest request) throws ServiceException {
487    return stub.execMasterService(controller, request);
488  }
489
490  @Override
491  public EnableTableResponse enableTable(RpcController controller, EnableTableRequest request)
492      throws ServiceException {
493    return stub.enableTable(controller, request);
494  }
495
496  @Override
497  public EnableReplicationPeerResponse enableReplicationPeer(RpcController controller,
498      EnableReplicationPeerRequest request) throws ServiceException {
499    return stub.enableReplicationPeer(controller, request);
500  }
501
502  @Override
503  public EnableCatalogJanitorResponse enableCatalogJanitor(RpcController controller,
504      EnableCatalogJanitorRequest request) throws ServiceException {
505    return stub.enableCatalogJanitor(controller, request);
506  }
507
508  @Override
509  public DecommissionRegionServersResponse decommissionRegionServers(RpcController controller,
510      DecommissionRegionServersRequest request) throws ServiceException {
511    return stub.decommissionRegionServers(controller, request);
512  }
513
514  @Override
515  public DisableTableResponse disableTable(RpcController controller, DisableTableRequest request)
516      throws ServiceException {
517    return stub.disableTable(controller, request);
518  }
519
520  @Override
521  public DisableReplicationPeerResponse disableReplicationPeer(RpcController controller,
522      DisableReplicationPeerRequest request) throws ServiceException {
523    return stub.disableReplicationPeer(controller, request);
524  }
525
526  @Override
527  public DeleteTableResponse deleteTable(RpcController controller, DeleteTableRequest request)
528      throws ServiceException {
529    return stub.deleteTable(controller, request);
530  }
531
532  @Override
533  public DeleteSnapshotResponse deleteSnapshot(RpcController controller,
534      DeleteSnapshotRequest request) throws ServiceException {
535    return stub.deleteSnapshot(controller, request);
536  }
537
538  @Override
539  public DeleteNamespaceResponse deleteNamespace(RpcController controller,
540      DeleteNamespaceRequest request) throws ServiceException {
541    return stub.deleteNamespace(controller, request);
542  }
543
544  @Override
545  public DeleteColumnResponse deleteColumn(RpcController controller, DeleteColumnRequest request)
546      throws ServiceException {
547    return stub.deleteColumn(controller, request);
548  }
549
550  @Override
551  public CreateTableResponse createTable(RpcController controller, CreateTableRequest request)
552      throws ServiceException {
553    return stub.createTable(controller, request);
554  }
555
556  @Override
557  public CreateNamespaceResponse createNamespace(RpcController controller,
558      CreateNamespaceRequest request) throws ServiceException {
559    return stub.createNamespace(controller, request);
560  }
561
562  @Override
563  public BalanceResponse balance(RpcController controller, BalanceRequest request)
564      throws ServiceException {
565    return stub.balance(controller, request);
566  }
567
568  @Override
569  public AssignRegionResponse assignRegion(RpcController controller, AssignRegionRequest request)
570      throws ServiceException {
571    return stub.assignRegion(controller, request);
572  }
573
574  @Override
575  public AddReplicationPeerResponse addReplicationPeer(RpcController controller,
576      AddReplicationPeerRequest request) throws ServiceException {
577    return stub.addReplicationPeer(controller, request);
578  }
579
580  @Override
581  public AddColumnResponse addColumn(RpcController controller, AddColumnRequest request)
582      throws ServiceException {
583    return stub.addColumn(controller, request);
584  }
585
586  @Override
587  public AbortProcedureResponse abortProcedure(RpcController controller,
588      AbortProcedureRequest request) throws ServiceException {
589    return stub.abortProcedure(controller, request);
590  }
591
592  @Override
593  public void close() {
594    // nothing to do here
595  }
596
597  @Override
598  public RunCleanerChoreResponse runCleanerChore(RpcController controller,
599      RunCleanerChoreRequest request) throws ServiceException {
600    return stub.runCleanerChore(controller, request);
601  }
602
603  @Override
604  public SetCleanerChoreRunningResponse setCleanerChoreRunning(RpcController controller,
605      SetCleanerChoreRunningRequest request) throws ServiceException {
606    return stub.setCleanerChoreRunning(controller, request);
607  }
608
609  @Override
610  public IsCleanerChoreEnabledResponse isCleanerChoreEnabled(RpcController controller,
611      IsCleanerChoreEnabledRequest request) throws ServiceException {
612    return stub.isCleanerChoreEnabled(controller, request);
613  }
614
615  @Override
616  public GetReplicationPeerConfigResponse getReplicationPeerConfig(RpcController controller,
617      GetReplicationPeerConfigRequest request) throws ServiceException {
618    return stub.getReplicationPeerConfig(controller, request);
619  }
620
621  @Override
622  public UpdateReplicationPeerConfigResponse updateReplicationPeerConfig(RpcController controller,
623      UpdateReplicationPeerConfigRequest request) throws ServiceException {
624    return stub.updateReplicationPeerConfig(controller, request);
625  }
626
627  @Override
628  public ListReplicationPeersResponse listReplicationPeers(RpcController controller,
629      ListReplicationPeersRequest request) throws ServiceException {
630    return stub.listReplicationPeers(controller, request);
631  }
632
633  @Override
634  public GetSpaceQuotaRegionSizesResponse getSpaceQuotaRegionSizes(RpcController controller,
635      GetSpaceQuotaRegionSizesRequest request) throws ServiceException {
636    return stub.getSpaceQuotaRegionSizes(controller, request);
637  }
638
639  @Override
640  public GetQuotaStatesResponse getQuotaStates(RpcController controller,
641      GetQuotaStatesRequest request) throws ServiceException {
642    return stub.getQuotaStates(controller, request);
643  }
644
645  @Override
646  public ClearDeadServersResponse clearDeadServers(RpcController controller,
647      ClearDeadServersRequest request) throws ServiceException {
648    return stub.clearDeadServers(controller, request);
649  }
650
651  @Override
652  public SplitTableRegionResponse splitRegion(RpcController controller, SplitTableRegionRequest request)
653      throws ServiceException {
654    return stub.splitRegion(controller, request);
655  }
656
657  @Override
658  public SwitchRpcThrottleResponse switchRpcThrottle(RpcController controller,
659      SwitchRpcThrottleRequest request) throws ServiceException {
660    return stub.switchRpcThrottle(controller, request);
661  }
662
663  @Override
664  public IsRpcThrottleEnabledResponse isRpcThrottleEnabled(RpcController controller,
665      IsRpcThrottleEnabledRequest request) throws ServiceException {
666    return stub.isRpcThrottleEnabled(controller, request);
667  }
668
669  @Override
670  public SwitchExceedThrottleQuotaResponse switchExceedThrottleQuota(RpcController controller,
671      SwitchExceedThrottleQuotaRequest request) throws ServiceException {
672    return stub.switchExceedThrottleQuota(controller, request);
673  }
674
675  @Override
676  public GrantResponse grant(RpcController controller, GrantRequest request)
677      throws ServiceException {
678    return stub.grant(controller, request);
679  }
680
681  @Override
682  public RevokeResponse revoke(RpcController controller, RevokeRequest request)
683      throws ServiceException {
684    return stub.revoke(controller, request);
685  }
686
687  @Override
688  public GetUserPermissionsResponse getUserPermissions(RpcController controller,
689      GetUserPermissionsRequest request) throws ServiceException {
690    return stub.getUserPermissions(controller, request);
691  }
692
693  @Override
694  public HasUserPermissionsResponse hasUserPermissions(RpcController controller,
695      HasUserPermissionsRequest request) throws ServiceException {
696    return stub.hasUserPermissions(controller, request);
697  }
698}