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