Package org.apache.hadoop.hbase.regionserver.regionreplication

Class TestRegionReplicationSinkCallbackAndFlushConcurrently.ErrorReplayRSRpcServices

java.lang.Object
org.apache.hadoop.hbase.HBaseRpcServicesBase<org.apache.hadoop.hbase.regionserver.HRegionServer>
org.apache.hadoop.hbase.regionserver.RSRpcServices
org.apache.hadoop.hbase.regionserver.regionreplication.TestRegionReplicationSinkCallbackAndFlushConcurrently.ErrorReplayRSRpcServices
All Implemented Interfaces:
org.apache.hadoop.hbase.conf.ConfigurationObserver, org.apache.hadoop.hbase.ipc.HBaseRPCErrorHandler, org.apache.hadoop.hbase.ipc.PriorityFunction, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface, org.apache.hadoop.hbase.shaded.protobuf.generated.BootstrapNodeProtos.BootstrapNodeService.BlockingInterface, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface, org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.BlockingInterface
Enclosing class:
TestRegionReplicationSinkCallbackAndFlushConcurrently
public static final class TestRegionReplicationSinkCallbackAndFlushConcurrently.ErrorReplayRSRpcServices extends org.apache.hadoop.hbase.regionserver.RSRpcServices

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private static final AtomicInteger
    callCounter
     

    Fields inherited from class org.apache.hadoop.hbase.regionserver.RSRpcServices

    REGION_SERVER_RPC_SCHEDULER_FACTORY_CLASS, REGIONSERVER_ADMIN_SERVICE_CONFIG, REGIONSERVER_BOOTSTRAP_NODES_SERVICE_CONFIG, REGIONSERVER_CLIENT_META_SERVICE_CONFIG, REGIONSERVER_CLIENT_SERVICE_CONFIG

    Fields inherited from class org.apache.hadoop.hbase.HBaseRpcServicesBase

    CLIENT_BOOTSTRAP_NODE_LIMIT, DEFAULT_CLIENT_BOOTSTRAP_NODE_LIMIT, priority, rpcServer, server

  • Constructor Summary

    Constructors
    Constructor
    Description
    ErrorReplayRSRpcServices(org.apache.hadoop.hbase.regionserver.HRegionServer rs)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse
    replicateToReplica(org.apache.hbase.thirdparty.com.google.protobuf.RpcController rpcController, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryRequest replicateWALEntryRequest)
     

    Methods inherited from class org.apache.hadoop.hbase.regionserver.RSRpcServices

    bulkLoadHFile, checkOpen, cleanupBulkLoad, clearCompactionQueues, clearRegionBlockCache, closeRegion, compactionSwitch, compactRegion, createPriority, createRpcServer, defaultReservoirEnabled, execRegionServerService, execService, executeProcedures, flushRegion, get, getAllBootstrapNodes, getCachedFilesList, getDefaultPort, getDNSServerType, getHostname, getOnlineRegion, getPortConfigName, getRegion, getRegionInfo, getRegionLoad, getRpcSchedulerFactoryClass, getRpcSchedulerFactoryClass, getScanDetailsWithId, getScanDetailsWithRequest, getScannersCount, getServerInfo, getServices, getSpaceQuotaSnapshots, getStoreFile, multi, mutate, onConfigurationChange, openRegion, prepareBulkLoad, replay, replicateWALEntry, rollWALWriter, scan, stopServer, updateFavoredNodes, warmupRegion

    Methods inherited from class org.apache.hadoop.hbase.HBaseRpcServicesBase

    checkOOME, clearSlowLogsResponses, getAccessChecker, getActiveMaster, getBootstrapNodes, getClusterId, getConfiguration, getDeadline, getLogEntries, getMasters, getMetaRegionLocations, getPriority, getRpcScheduler, getRpcServer, getServer, getSocketAddress, getZkPermissionWatcher, internalStart, internalStop, requirePermission, updateConfiguration

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

  • Constructor Details

  • Method Details

    • replicateToReplica

      public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse replicateToReplica(org.apache.hbase.thirdparty.com.google.protobuf.RpcController rpcController, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryRequest replicateWALEntryRequest) throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException
      Specified by:
      replicateToReplica in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface
      Overrides:
      replicateToReplica in class org.apache.hadoop.hbase.regionserver.RSRpcServices
      Throws:
      org.apache.hbase.thirdparty.com.google.protobuf.ServiceException