public static final class TestRegionReplicationForFlushMarker.ErrorReplayRSRpcServices extends org.apache.hadoop.hbase.regionserver.RSRpcServices
Modifier and Type | Field and Description |
---|---|
private static AtomicInteger |
callCounter |
Constructor and Description |
---|
ErrorReplayRSRpcServices(org.apache.hadoop.hbase.regionserver.HRegionServer rs) |
Modifier and Type | Method and 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) |
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
checkOOME, clearSlowLogsResponses, getAccessChecker, getActiveMaster, getBootstrapNodes, getClusterId, getConfiguration, getDeadline, getLogEntries, getMasters, getMetaRegionLocations, getPriority, getRpcScheduler, getRpcServer, getServer, getSocketAddress, getZkPermissionWatcher, internalStart, internalStop, requirePermission, updateConfiguration
private static final AtomicInteger callCounter
public ErrorReplayRSRpcServices(org.apache.hadoop.hbase.regionserver.HRegionServer rs) throws IOException
IOException
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
replicateToReplica
in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface
replicateToReplica
in class org.apache.hadoop.hbase.regionserver.RSRpcServices
org.apache.hbase.thirdparty.com.google.protobuf.ServiceException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.