Modifier and Type | Method and Description |
---|---|
static Pair<HRegionInfo,ServerName> |
HRegionInfo.getHRegionInfoAndServerName(Result r)
Deprecated.
use MetaTableAccessor methods for interacting with meta layouts
|
static Pair<HRegionInfo,ServerName> |
MetaTableAccessor.getRegion(Connection connection,
byte[] regionName)
Deprecated.
|
static Pair<HRegionInfo,HRegionInfo> |
MetaTableAccessor.getRegionsFromMergeQualifier(Connection connection,
byte[] regionName)
Get regions from the merge qualifier of the specified merged region
|
Modifier and Type | Method and Description |
---|---|
static java.util.List<Pair<HRegionInfo,ServerName>> |
MetaTableAccessor.getTableRegionsAndLocations(ZooKeeperWatcher zkw,
Connection connection,
TableName tableName) |
static java.util.List<Pair<HRegionInfo,ServerName>> |
MetaTableAccessor.getTableRegionsAndLocations(ZooKeeperWatcher zkw,
Connection connection,
TableName tableName,
boolean excludeOfflinedSplitParents) |
Modifier and Type | Method and Description |
---|---|
boolean |
BackupObserver.postBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx,
java.util.List<Pair<byte[],java.lang.String>> stagingFamilyPaths,
java.util.Map<byte[],java.util.List<Path>> finalPaths,
boolean hasLoaded) |
void |
BackupObserver.preCommitStoreFile(ObserverContext<RegionCoprocessorEnvironment> ctx,
byte[] family,
java.util.List<Pair<Path,Path>> pairs) |
Modifier and Type | Method and Description |
---|---|
Pair<java.util.Map<TableName,java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.util.List<Pair<java.lang.String,java.lang.Boolean>>>>>,java.util.List<byte[]>> |
BackupSystemTable.readOrigBulkloadRows(java.util.List<TableName> tableList) |
Pair<java.util.Map<TableName,java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.util.List<Pair<java.lang.String,java.lang.Boolean>>>>>,java.util.List<byte[]>> |
BackupManager.readOrigBulkloadRows(java.util.List<TableName> tableList) |
Modifier and Type | Method and Description |
---|---|
Pair<java.util.Map<TableName,java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.util.List<Pair<java.lang.String,java.lang.Boolean>>>>>,java.util.List<byte[]>> |
BackupSystemTable.readOrigBulkloadRows(java.util.List<TableName> tableList) |
Pair<java.util.Map<TableName,java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.util.List<Pair<java.lang.String,java.lang.Boolean>>>>>,java.util.List<byte[]>> |
BackupManager.readOrigBulkloadRows(java.util.List<TableName> tableList) |
Modifier and Type | Method and Description |
---|---|
void |
BackupSystemTable.writeOrigBulkLoad(TableName tabName,
byte[] region,
byte[] family,
java.util.List<Pair<Path,Path>> pairs) |
Modifier and Type | Method and Description |
---|---|
static <T> T |
PolicyBasedChaosMonkey.selectWeightedRandomItem(java.util.List<Pair<T,java.lang.Integer>> items)
Selects a random item from the given items with weights
|
Constructor and Description |
---|
PeriodicRandomActionPolicy(long periodMs,
Pair<Action,java.lang.Integer>... actions) |
Constructor and Description |
---|
PeriodicRandomActionPolicy(long periodMs,
java.util.List<Pair<Action,java.lang.Integer>> actions) |
Modifier and Type | Method and Description |
---|---|
Pair<java.lang.Integer,java.lang.Integer> |
Admin.getAlterStatus(byte[] tableName)
Get the status of alter command - indicates how many regions have received the updated schema
Asynchronous operation.
|
Pair<java.lang.Integer,java.lang.Integer> |
HBaseAdmin.getAlterStatus(byte[] tableName)
Get the status of alter command - indicates how many regions have received
the updated schema Asynchronous operation.
|
Pair<java.lang.Integer,java.lang.Integer> |
Admin.getAlterStatus(TableName tableName)
Get the status of alter command - indicates how many regions have received the updated schema
Asynchronous operation.
|
Pair<java.lang.Integer,java.lang.Integer> |
HBaseAdmin.getAlterStatus(TableName tableName)
Get the status of alter command - indicates how many regions have received
the updated schema Asynchronous operation.
|
Pair<byte[][],byte[][]> |
HRegionLocator.getStartEndKeys()
Gets the starting and ending row keys for every region in the currently
open table.
|
Pair<byte[][],byte[][]> |
HTable.getStartEndKeys()
Deprecated.
Since 1.1.0. Use
RegionLocator.getStartEndKeys() instead; |
Pair<byte[][],byte[][]> |
RegionLocator.getStartEndKeys()
Gets the starting and ending row keys for every region in the currently
open table.
|
Modifier and Type | Method and Description |
---|---|
boolean |
SecureBulkLoadClient.bulkLoadHFiles(java.util.List<Pair<byte[],java.lang.String>> familyPaths,
<any> userToken,
java.lang.String bulkToken,
byte[] startRow,
boolean copyFile) |
Modifier and Type | Method and Description |
---|---|
static void |
Constraints.add(HTableDescriptor desc,
Pair<java.lang.Class<? extends Constraint>,Configuration>... constraints)
Add constraints and their associated configurations to the table.
|
Modifier and Type | Method and Description |
---|---|
boolean |
BaseRegionObserver.postBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx,
java.util.List<Pair<byte[],java.lang.String>> stagingFamilyPaths,
boolean hasLoaded) |
boolean |
RegionObserver.postBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx,
java.util.List<Pair<byte[],java.lang.String>> stagingFamilyPaths,
boolean hasLoaded)
|
boolean |
BaseRegionObserver.postBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx,
java.util.List<Pair<byte[],java.lang.String>> stagingFamilyPaths,
java.util.Map<byte[],java.util.List<Path>> finalPaths,
boolean hasLoaded) |
boolean |
RegionObserver.postBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx,
java.util.List<Pair<byte[],java.lang.String>> stagingFamilyPaths,
java.util.Map<byte[],java.util.List<Path>> finalPaths,
boolean hasLoaded)
Called after bulkLoadHFile.
|
boolean |
SimpleRegionObserver.postBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx,
java.util.List<Pair<byte[],java.lang.String>> familyPaths,
java.util.Map<byte[],java.util.List<Path>> map,
boolean hasLoaded) |
void |
BaseRegionObserver.preBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx,
java.util.List<Pair<byte[],java.lang.String>> familyPaths) |
void |
RegionObserver.preBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx,
java.util.List<Pair<byte[],java.lang.String>> familyPaths)
Called before bulkLoadHFile.
|
void |
SimpleRegionObserver.preBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx,
java.util.List<Pair<byte[],java.lang.String>> familyPaths) |
void |
BaseRegionObserver.preCommitStoreFile(ObserverContext<RegionCoprocessorEnvironment> ctx,
byte[] family,
java.util.List<Pair<Path,Path>> pairs) |
void |
RegionObserver.preCommitStoreFile(ObserverContext<RegionCoprocessorEnvironment> ctx,
byte[] family,
java.util.List<Pair<Path,Path>> pairs)
Called before moving bulk loaded hfile to region directory.
|
Constructor and Description |
---|
FuzzyRowFilter(java.util.List<Pair<byte[],byte[]>> fuzzyKeysData) |
Modifier and Type | Method and Description |
---|---|
static Pair<java.lang.Integer,java.lang.Integer> |
StreamUtils.readRawVarint32(byte[] input,
int offset)
Reads a varInt value stored in an array.
|
Modifier and Type | Method and Description |
---|---|
Pair<Message,CellScanner> |
RpcServer.call(BlockingService service,
MethodDescriptor md,
Message param,
CellScanner cellScanner,
long receiveTime,
MonitoredRPCHandler status)
This is a server side method, which is invoked over RPC.
|
Pair<Message,CellScanner> |
RpcServerInterface.call(BlockingService service,
MethodDescriptor md,
Message param,
CellScanner cellScanner,
long receiveTime,
MonitoredRPCHandler status) |
protected abstract Pair<Message,CellScanner> |
AbstractRpcClient.call(PayloadCarryingRpcController pcrc,
Descriptors.MethodDescriptor md,
Message param,
Message returnType,
User ticket,
java.net.InetSocketAddress isa)
Make a call, passing
param , to the IPC server running at
address which is servicing the protocol protocol,
with the ticket credentials, returning the value. |
protected Pair<Message,CellScanner> |
AsyncRpcClient.call(PayloadCarryingRpcController pcrc,
Descriptors.MethodDescriptor md,
Message param,
Message returnType,
User ticket,
java.net.InetSocketAddress addr)
Make a call, passing
param , to the IPC server running at
address which is servicing the protocol protocol,
with the ticket credentials, returning the value. |
protected Pair<Message,CellScanner> |
RpcClientImpl.call(PayloadCarryingRpcController pcrc,
MethodDescriptor md,
Message param,
Message returnType,
User ticket,
java.net.InetSocketAddress addr)
Make a call, passing
param , to the IPC server running at
address which is servicing the protocol protocol,
with the ticket credentials, returning the value. |
Modifier and Type | Method and Description |
---|---|
protected Pair<byte[][],byte[][]> |
TableInputFormat.getStartEndKeys() |
protected Pair<byte[][],byte[][]> |
TableInputFormatBase.getStartEndKeys() |
protected Pair<java.util.List<LoadIncrementalHFiles.LoadQueueItem>,java.lang.String> |
LoadIncrementalHFiles.groupOrSplit(<any> regionGroups,
LoadIncrementalHFiles.LoadQueueItem item,
Table table,
Pair<byte[][],byte[][]> startEndKeys)
Attempt to assign the given load queue item into its target region group.
|
Pair<java.lang.Integer,java.lang.Integer> |
ImportTsv.TsvParser.parseRowKey(byte[] lineBytes,
int length)
Return starting position and length of row key from the specified line bytes.
|
Modifier and Type | Method and Description |
---|---|
protected Pair<java.util.List<LoadIncrementalHFiles.LoadQueueItem>,java.lang.String> |
LoadIncrementalHFiles.groupOrSplit(<any> regionGroups,
LoadIncrementalHFiles.LoadQueueItem item,
Table table,
Pair<byte[][],byte[][]> startEndKeys)
Attempt to assign the given load queue item into its target region group.
|
void |
LoadIncrementalHFiles.loadHFileQueue(Table table,
Connection conn,
java.util.Deque<LoadIncrementalHFiles.LoadQueueItem> queue,
Pair<byte[][],byte[][]> startEndKeys)
Used by the replication sink to load the hfiles from the source cluster.
|
void |
LoadIncrementalHFiles.loadHFileQueue(Table table,
Connection conn,
java.util.Deque<LoadIncrementalHFiles.LoadQueueItem> queue,
Pair<byte[][],byte[][]> startEndKeys,
boolean copyFile)
Used by the replication sink to load the hfiles from the source cluster.
|
Modifier and Type | Method and Description |
---|---|
Pair<java.lang.Long,java.lang.String> |
HMaster.backupTables(BackupType type,
java.util.List<TableName> tableList,
java.lang.String targetRootDir,
int workers,
long bandwidth) |
Pair<java.lang.Long,java.lang.String> |
MasterServices.backupTables(BackupType type,
java.util.List<TableName> tableList,
java.lang.String targetRootDir,
int workers,
long bandwidth)
Full backup given list of tables
|
Pair<java.lang.Integer,java.lang.Integer> |
AssignmentManager.getReopenStatus(TableName tableName)
Used by the client to identify if all regions have the schema updates
|
Modifier and Type | Method and Description |
---|---|
java.util.List<Pair<ServerName,java.lang.Long>> |
DeadServer.copyDeadServersSince(long ts)
Extract all the servers dead since a given time, and sort them.
|
protected java.util.List<Pair<ServerName,java.lang.Long>> |
ClusterStatusPublisher.getDeadServers(long since)
Get the servers which died since a given timestamp.
|
Modifier and Type | Method and Description |
---|---|
void |
DisabledTableSnapshotHandler.snapshotRegions(java.util.List<Pair<HRegionInfo,ServerName>> regionsAndLocations) |
protected void |
EnabledTableSnapshotHandler.snapshotRegions(java.util.List<Pair<HRegionInfo,ServerName>> regions)
This method kicks off a snapshot procedure.
|
protected abstract void |
TakeSnapshotHandler.snapshotRegions(java.util.List<Pair<HRegionInfo,ServerName>> regions)
Snapshot the specified regions
|
Modifier and Type | Method and Description |
---|---|
Pair<ProcedureInfo,Procedure> |
ProcedureExecutor.getResultOrProcedure(long procId) |
Modifier and Type | Method and Description |
---|---|
static Pair<AdminProtos.ReplicateWALEntryRequest,CellScanner> |
ReplicationProtbufUtil.buildReplicateWALEntryRequest(WAL.Entry[] entries)
Create a new ReplicateWALEntryRequest from a list of WAL entries
|
static Pair<AdminProtos.ReplicateWALEntryRequest,CellScanner> |
ReplicationProtbufUtil.buildReplicateWALEntryRequest(WAL.Entry[] entries,
byte[] encodedRegionName,
java.lang.String replicationClusterId,
Path sourceBaseNamespaceDir,
Path sourceHFileArchiveDir)
Create a new ReplicateWALEntryRequest from a list of HLog entries
|
Modifier and Type | Method and Description |
---|---|
static ClientProtos.BulkLoadHFileRequest |
RequestConverter.buildBulkLoadHFileRequest(java.util.List<Pair<byte[],java.lang.String>> familyPaths,
byte[] regionName,
boolean assignSeqNum)
Create a protocol buffer bulk load request
|
static ClientProtos.BulkLoadHFileRequest |
RequestConverter.buildBulkLoadHFileRequest(java.util.List<Pair<byte[],java.lang.String>> familyPaths,
byte[] regionName,
boolean assignSeqNum,
boolean copyFiles)
Create a protocol buffer bulk load request
|
static AdminProtos.UpdateFavoredNodesRequest |
RequestConverter.buildUpdateFavoredNodesRequest(java.util.List<Pair<HRegionInfo,java.util.List<ServerName>>> updateRegionInfos)
Create a protocol buffer UpdateFavoredNodesRequest to update a list of favorednode mappings
|
static boolean |
ProtobufUtil.bulkLoadHFile(ClientProtos.ClientService.BlockingInterface client,
java.util.List<Pair<byte[],java.lang.String>> familyPaths,
byte[] regionName,
boolean assignSeqNum)
A helper to bulk load a list of HFiles using client protocol.
|
Modifier and Type | Method and Description |
---|---|
Pair<java.lang.Long,Cell> |
DefaultMemStore.add(Cell cell)
Write an update
|
Pair<java.lang.Long,Cell> |
HStore.add(Cell cell) |
Pair<java.lang.Long,Cell> |
MemStore.add(Cell cell)
Write an update
|
Pair<java.lang.Long,Cell> |
Store.add(Cell cell)
Adds a value to the memstore
|
Pair<Path,Path> |
HStore.preBulkLoadHFile(java.lang.String srcPathStr,
long seqNum) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<byte[],java.util.List<Path>> |
HRegion.bulkLoadHFiles(java.util.Collection<Pair<byte[],java.lang.String>> familyPaths,
boolean assignSeqId,
Region.BulkLoadListener bulkLoadListener) |
java.util.Map<byte[],java.util.List<Path>> |
Region.bulkLoadHFiles(java.util.Collection<Pair<byte[],java.lang.String>> familyPaths,
boolean assignSeqId,
Region.BulkLoadListener bulkLoadListener)
Attempts to atomically load a group of hfiles.
|
java.util.Map<byte[],java.util.List<Path>> |
HRegion.bulkLoadHFiles(java.util.Collection<Pair<byte[],java.lang.String>> familyPaths,
boolean assignSeqId,
Region.BulkLoadListener bulkLoadListener,
boolean copyFile) |
java.util.Map<byte[],java.util.List<Path>> |
Region.bulkLoadHFiles(java.util.Collection<Pair<byte[],java.lang.String>> familyPaths,
boolean assignSeqId,
Region.BulkLoadListener bulkLoadListener,
boolean copyFile)
Attempts to atomically load a group of hfiles.
|
boolean |
RegionCoprocessorHost.postBulkLoadHFile(java.util.List<Pair<byte[],java.lang.String>> familyPaths,
java.util.Map<byte[],java.util.List<Path>> map,
boolean hasLoaded) |
boolean |
RegionCoprocessorHost.preBulkLoadHFile(java.util.List<Pair<byte[],java.lang.String>> familyPaths) |
boolean |
RegionCoprocessorHost.preCommitStoreFile(byte[] family,
java.util.List<Pair<Path,Path>> pairs) |
java.util.List<CompactionRequest> |
CompactionRequestor.requestCompaction(Region r,
java.lang.String why,
int pri,
java.util.List<Pair<CompactionRequest,Store>> requests,
User user) |
java.util.List<CompactionRequest> |
CompactSplitThread.requestCompaction(Region r,
java.lang.String why,
int p,
java.util.List<Pair<CompactionRequest,Store>> requests,
User user) |
java.util.List<CompactionRequest> |
CompactionRequestor.requestCompaction(Region r,
java.lang.String why,
java.util.List<Pair<CompactionRequest,Store>> requests) |
java.util.List<CompactionRequest> |
CompactSplitThread.requestCompaction(Region r,
java.lang.String why,
java.util.List<Pair<CompactionRequest,Store>> requests) |
Modifier and Type | Method and Description |
---|---|
void |
WALEditsReplaySink.replayEntries(java.util.List<Pair<HRegionLocation,WAL.Entry>> entries)
Replay an array of actions of the same region directly into the newly assigned Region Server
|
Modifier and Type | Method and Description |
---|---|
Pair<ReplicationPeerConfig,Configuration> |
ReplicationPeers.getPeerConf(java.lang.String peerId)
Returns the configuration needed to talk to the remote slave cluster.
|
Pair<ReplicationPeerConfig,Configuration> |
ReplicationPeersZKImpl.getPeerConf(java.lang.String peerId) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationQueues.addHFileRefs(java.lang.String peerId,
java.util.List<Pair<Path,Path>> pairs)
Add new hfile references to the queue.
|
void |
ReplicationQueuesZKImpl.addHFileRefs(java.lang.String peerId,
java.util.List<Pair<Path,Path>> pairs) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationSource.addHFileRefs(TableName tableName,
byte[] family,
java.util.List<Pair<Path,Path>> pairs) |
void |
ReplicationSourceInterface.addHFileRefs(TableName tableName,
byte[] family,
java.util.List<Pair<Path,Path>> pairs)
Add hfile names to the queue to be replicated.
|
void |
ReplicationSourceManager.addHFileRefs(TableName tableName,
byte[] family,
java.util.List<Pair<Path,Path>> pairs) |
void |
ReplicationObserver.preCommitStoreFile(ObserverContext<RegionCoprocessorEnvironment> ctx,
byte[] family,
java.util.List<Pair<Path,Path>> pairs) |
Constructor and Description |
---|
HFileReplicator(Configuration sourceClusterConf,
java.lang.String sourceBaseNamespaceDirPath,
java.lang.String sourceHFileArchiveDirPath,
java.util.Map<java.lang.String,java.util.List<Pair<byte[],java.util.List<java.lang.String>>>> tableQueueMap,
Configuration conf,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
void |
AccessController.preBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx,
java.util.List<Pair<byte[],java.lang.String>> familyPaths)
Verifies user has CREATE privileges on
the Column Families involved in the bulkLoadHFile
request.
|
Modifier and Type | Method and Description |
---|---|
protected Pair<java.util.Map<java.lang.String,java.lang.Integer>,java.util.Map<java.lang.String,java.util.List<java.lang.Integer>>> |
DefaultVisibilityLabelServiceImpl.extractLabelsAndAuths(java.util.List<java.util.List<Cell>> labelDetails) |
Modifier and Type | Method and Description |
---|---|
static <T1,T2> Pair<T1,T2> |
Pair.newPair(T1 a,
T2 b)
Constructs a new pair, inferring the type via the passed arguments
|
Modifier and Type | Method and Description |
---|---|
static java.util.List<WALSplitter.MutationReplay> |
WALSplitter.getMutationsFromWALEntry(AdminProtos.WALEntry entry,
CellScanner cells,
Pair<WALKey,WALEdit> logEntry,
Durability durability)
This function is used to construct mutations from a WALEntry.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<Pair<HRegionInfo,ServerName>> |
MetaTableLocator.getMetaRegionsAndLocations(ZooKeeperWatcher zkw) |
java.util.List<Pair<HRegionInfo,ServerName>> |
MetaTableLocator.getMetaRegionsAndLocations(ZooKeeperWatcher zkw,
int replicaId) |