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