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}