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