@InterfaceAudience.Private public final class RequestConverter extends Object
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.AddColumnRequest |
buildAddColumnRequest(TableName tableName,
HColumnDescriptor column,
long nonceGroup,
long nonce)
Create a protocol buffer AddColumnRequest
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.AssignRegionRequest |
buildAssignRegionRequest(byte[] regionName)
Create a protocol buffer AssignRegionRequest
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.BalanceRequest |
buildBalanceRequest(boolean force)
Creates a protocol buffer BalanceRequest
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.BulkLoadHFileRequest |
buildBulkLoadHFileRequest(List<Pair<byte[],String>> familyPaths,
byte[] regionName,
boolean assignSeqNum)
Deprecated.
use buildBulkLoadHFileRequest(final List
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.BulkLoadHFileRequest |
buildBulkLoadHFileRequest(List<Pair<byte[],String>> familyPaths,
byte[] regionName,
boolean assignSeqNum,
List<String> clusterIds)
Create a protocol buffer bulk load request
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.RunCatalogScanRequest |
buildCatalogScanRequest()
Creates a request for running a catalog scan
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.RunCleanerChoreRequest |
buildCleanerChoreRequest()
Creates a request for running cleaner chore
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.ClearDeadServersRequest |
buildClearDeadServersRequest(List<ServerName> deadServers) |
static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.CloseRegionRequest |
buildCloseRegionRequest(ServerName server,
byte[] regionName,
boolean transitionInZK)
Create a CloseRegionRequest for a given region name
|
static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.CloseRegionRequest |
buildCloseRegionRequest(ServerName server,
byte[] regionName,
int versionOfClosingNode,
ServerName destinationServer,
boolean transitionInZK) |
static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.CloseRegionRequest |
buildCloseRegionRequest(ServerName server,
String encodedRegionName,
boolean transitionInZK)
Create a CloseRegionRequest for a given encoded region name
|
static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.CompactRegionRequest |
buildCompactRegionRequest(byte[] regionName,
boolean major,
byte[] family)
Create a CompactRegionRequest for a given region name
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Condition |
buildCondition(byte[] row,
byte[] family,
byte[] qualifier,
ByteArrayComparable comparator,
org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.CompareType compareType)
Create a protocol buffer Condition
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.CreateTableRequest |
buildCreateTableRequest(HTableDescriptor hTableDesc,
byte[][] splitKeys,
long nonceGroup,
long nonce)
Creates a protocol buffer CreateTableRequest
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.DeleteColumnRequest |
buildDeleteColumnRequest(TableName tableName,
byte[] columnName,
long nonceGroup,
long nonce)
Create a protocol buffer DeleteColumnRequest
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.DeleteTableRequest |
buildDeleteTableRequest(TableName tableName,
long nonceGroup,
long nonce)
Creates a protocol buffer DeleteTableRequest
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.DisableTableRequest |
buildDisableTableRequest(TableName tableName,
long nonceGroup,
long nonce)
Creates a protocol buffer DisableTableRequest
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.DispatchMergingRegionsRequest |
buildDispatchMergingRegionsRequest(byte[] encodedNameOfRegionA,
byte[] encodedNameOfRegionB,
boolean forcible) |
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.EnableCatalogJanitorRequest |
buildEnableCatalogJanitorRequest(boolean enable)
Creates a request for enabling/disabling the catalog janitor
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.EnableTableRequest |
buildEnableTableRequest(TableName tableName,
long nonceGroup,
long nonce)
Creates a protocol buffer EnableTableRequest
|
static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.FlushRegionRequest |
buildFlushRegionRequest(byte[] regionName)
Create a protocol buffer FlushRegionRequest for a given region name
|
static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.FlushRegionRequest |
buildFlushRegionRequest(byte[] regionName,
boolean writeFlushWALMarker)
Create a protocol buffer FlushRegionRequest for a given region name
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetClusterStatusRequest |
buildGetClusterStatusRequest()
Creates a protocol buffer GetClusterStatusRequest
|
static org.apache.hadoop.hbase.protobuf.generated.RegionServerStatusProtos.GetLastFlushedSequenceIdRequest |
buildGetLastFlushedSequenceIdRequest(byte[] regionName)
Creates a request for querying the master the last flushed sequence Id for a region
|
static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetOnlineRegionRequest |
buildGetOnlineRegionRequest()
Create a protocol buffer GetOnlineRegionRequest
|
static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetRegionInfoRequest |
buildGetRegionInfoRequest(byte[] regionName)
Create a protocol buffer GetRegionInfoRequest for a given region name
|
static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetRegionInfoRequest |
buildGetRegionInfoRequest(byte[] regionName,
boolean includeCompactionState)
Create a protocol buffer GetRegionInfoRequest for a given region name
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.GetRequest |
buildGetRequest(byte[] regionName,
Get get)
Create a protocol buffer GetRequest for a client Get
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.GetRequest |
buildGetRowOrBeforeRequest(byte[] regionName,
byte[] row,
byte[] family)
Create a new protocol buffer GetRequest to get a row, all columns in a family.
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetSchemaAlterStatusRequest |
buildGetSchemaAlterStatusRequest(TableName tableName)
Creates a protocol buffer GetSchemaAlterStatusRequest
|
static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetServerInfoRequest |
buildGetServerInfoRequest()
Create a new GetServerInfoRequest
|
static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetStoreFileRequest |
buildGetStoreFileRequest(byte[] regionName,
byte[] family)
Create a protocol buffer GetStoreFileRequest for a given region name
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetTableDescriptorsRequest |
buildGetTableDescriptorsRequest(List<TableName> tableNames)
Creates a protocol buffer GetTableDescriptorsRequest
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetTableDescriptorsRequest |
buildGetTableDescriptorsRequest(Pattern pattern,
boolean includeSysTables)
Creates a protocol buffer GetTableDescriptorsRequest
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetTableDescriptorsRequest |
buildGetTableDescriptorsRequest(TableName tableName)
Creates a protocol buffer GetTableDescriptorsRequest for a single table
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetTableNamesRequest |
buildGetTableNamesRequest(Pattern pattern,
boolean includeSysTables)
Creates a protocol buffer GetTableNamesRequest
|
static org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.GrantRequest |
buildGrantRequest(String username,
boolean mergeExistingPermissions,
org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.Permission.Action... actions)
Create a request to grant user permissions.
|
static org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.GrantRequest |
buildGrantRequest(String username,
String namespace,
boolean mergeExistingPermissions,
org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.Permission.Action... actions)
Create a request to grant user permissions.
|
static org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.GrantRequest |
buildGrantRequest(String username,
TableName tableName,
byte[] family,
byte[] qualifier,
boolean mergeExistingPermissions,
org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.Permission.Action... actions)
Create a request to grant user permissions.
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateRequest |
buildIncrementRequest(byte[] regionName,
byte[] row,
byte[] family,
byte[] qualifier,
long amount,
Durability durability,
long nonceGroup,
long nonce)
Create a protocol buffer MutateRequest for a client increment
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsBalancerEnabledRequest |
buildIsBalancerEnabledRequest()
Creates a protocol buffer IsBalancerEnabledRequest
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsCatalogJanitorEnabledRequest |
buildIsCatalogJanitorEnabledRequest()
Creates a request for querying the master whether the catalog janitor is enabled
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsCleanerChoreEnabledRequest |
buildIsCleanerChoreEnabledRequest()
Creates a request for querying the master whether the cleaner chore is enabled
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsMasterRunningRequest |
buildIsMasterRunningRequest()
Creates a protocol buffer IsMasterRunningRequest
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsNormalizerEnabledRequest |
buildIsNormalizerEnabledRequest()
Creates a protocol buffer IsNormalizerEnabledRequest
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsSplitOrMergeEnabledRequest |
buildIsSplitOrMergeEnabledRequest(Admin.MasterSwitchType switchType)
Creates a protocol buffer IsSplitOrMergeEnabledRequest
|
static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.MergeRegionsRequest |
buildMergeRegionsRequest(byte[] regionA,
byte[] regionB,
boolean forcible)
Create a MergeRegionsRequest for the given regions
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.ModifyColumnRequest |
buildModifyColumnRequest(TableName tableName,
HColumnDescriptor column,
long nonceGroup,
long nonce)
Create a protocol buffer ModifyColumnRequest
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.ModifyTableRequest |
buildModifyTableRequest(TableName tableName,
HTableDescriptor hTableDesc,
long nonceGroup,
long nonce)
Creates a protocol buffer ModifyTableRequest
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.MoveRegionRequest |
buildMoveRegionRequest(byte[] encodedRegionName,
byte[] destServerName)
Create a protocol buffer MoveRegionRequest
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateRequest |
buildMutateRequest(byte[] regionName,
Append append,
long nonceGroup,
long nonce)
Create a protocol buffer MutateRequest for an append
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateRequest |
buildMutateRequest(byte[] regionName,
byte[] row,
byte[] family,
byte[] qualifier,
ByteArrayComparable comparator,
org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.CompareType compareType,
Delete delete)
Create a protocol buffer MutateRequest for a conditioned delete
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateRequest |
buildMutateRequest(byte[] regionName,
byte[] row,
byte[] family,
byte[] qualifier,
ByteArrayComparable comparator,
org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.CompareType compareType,
Put put)
Create a protocol buffer MutateRequest for a conditioned put
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MultiRequest |
buildMutateRequest(byte[] regionName,
byte[] row,
byte[] family,
byte[] qualifier,
ByteArrayComparable comparator,
org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.CompareType compareType,
RowMutations rowMutations)
Create a protocol buffer MutateRequest for conditioned row mutations
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateRequest |
buildMutateRequest(byte[] regionName,
Delete delete)
Create a protocol buffer MutateRequest for a delete
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateRequest |
buildMutateRequest(byte[] regionName,
Increment increment,
long nonceGroup,
long nonce)
Create a protocol buffer MutateRequest for a client increment
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateRequest |
buildMutateRequest(byte[] regionName,
Put put)
Create a protocol buffer MutateRequest for a put
|
static <R> org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder |
buildNoDataRegionAction(byte[] regionName,
List<Action<R>> actions,
List<CellScannable> cells,
org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder regionActionBuilder,
org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Action.Builder actionBuilder,
org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutationProto.Builder mutationBuilder)
Create a protocol buffer multirequest with NO data for a list of actions (data is carried
otherwise than via protobuf).
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder |
buildNoDataRegionAction(byte[] regionName,
RowMutations rowMutations,
List<CellScannable> cells,
org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder regionActionBuilder,
org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Action.Builder actionBuilder,
org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutationProto.Builder mutationBuilder)
Create a protocol buffer MultiRequest for row mutations that does not hold data.
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.NormalizeRequest |
buildNormalizeRequest()
Creates a protocol buffer NormalizeRequest
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.OfflineRegionRequest |
buildOfflineRegionRequest(byte[] regionName)
Creates a protocol buffer OfflineRegionRequest
|
static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.OpenRegionRequest |
buildOpenRegionRequest(ServerName server,
HRegionInfo region,
int versionOfOfflineNode,
List<ServerName> favoredNodes,
Boolean openForReplay)
Create a protocol buffer OpenRegionRequest for a given region
|
static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.OpenRegionRequest |
buildOpenRegionRequest(ServerName server,
List<Triple<HRegionInfo,Integer,List<ServerName>>> regionOpenInfos,
Boolean openForReplay)
Create a protocol buffer OpenRegionRequest to open a list of regions
|
static <R> org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder |
buildRegionAction(byte[] regionName,
List<Action<R>> actions,
org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder regionActionBuilder,
org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Action.Builder actionBuilder,
org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutationProto.Builder mutationBuilder)
Create a protocol buffer multi request for a list of actions.
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder |
buildRegionAction(byte[] regionName,
RowMutations rowMutations)
Create a protocol buffer MultiRequest for row mutations.
|
static org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.RegionSpecifier |
buildRegionSpecifier(org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.RegionSpecifier.RegionSpecifierType type,
byte[] value)
Convert a byte array to a protocol buffer RegionSpecifier
|
static org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.RevokeRequest |
buildRevokeRequest(String username,
org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.Permission.Action... actions)
Create a request to revoke user permissions.
|
static org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.RevokeRequest |
buildRevokeRequest(String username,
String namespace,
org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.Permission.Action... actions)
Create a request to revoke user permissions.
|
static org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.RevokeRequest |
buildRevokeRequest(String username,
TableName tableName,
byte[] family,
byte[] qualifier,
org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.Permission.Action... actions)
Create a request to revoke user permissions.
|
static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.RollWALWriterRequest |
buildRollWALWriterRequest()
Create a new RollWALWriterRequest
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ScanRequest |
buildScanRequest(byte[] regionName,
Scan scan,
int numberOfRows,
boolean closeScanner)
Create a protocol buffer ScanRequest for a client Scan
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ScanRequest |
buildScanRequest(long scannerId,
int numberOfRows,
boolean closeScanner,
boolean trackMetrics)
Create a protocol buffer ScanRequest for a scanner id
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ScanRequest |
buildScanRequest(long scannerId,
int numberOfRows,
boolean closeScanner,
long nextCallSeq,
boolean trackMetrics,
boolean renew,
int limitOfRows)
Create a protocol buffer ScanRequest for a scanner id
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.SetBalancerRunningRequest |
buildSetBalancerRunningRequest(boolean on,
boolean synchronous)
Creates a protocol buffer SetBalancerRunningRequest
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.SetCleanerChoreRunningRequest |
buildSetCleanerChoreRunningRequest(boolean on)
Creates a request for enabling/disabling the cleaner chore
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.SetNormalizerRunningRequest |
buildSetNormalizerRunningRequest(boolean on)
Creates a protocol buffer SetNormalizerRunningRequest
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.SetSplitOrMergeEnabledRequest |
buildSetSplitOrMergeEnabledRequest(boolean enabled,
boolean synchronous,
Admin.MasterSwitchType... switchTypes)
Creates a protocol buffer SetSplitOrMergeEnabledRequest
|
static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.SplitRegionRequest |
buildSplitRegionRequest(byte[] regionName,
byte[] splitPoint)
Create a SplitRegionRequest for a given region name
|
static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.StopServerRequest |
buildStopServerRequest(String reason)
Create a new StopServerRequest
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.TruncateTableRequest |
buildTruncateTableRequest(TableName tableName,
boolean preserveSplits,
long nonceGroup,
long nonce)
Creates a protocol buffer TruncateTableRequest
|
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.UnassignRegionRequest |
buildUnassignRegionRequest(byte[] regionName,
boolean force)
Creates a protocol buffer UnassignRegionRequest
|
static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.UpdateFavoredNodesRequest |
buildUpdateFavoredNodesRequest(List<Pair<HRegionInfo,List<ServerName>>> updateRegionInfos)
Create a protocol buffer UpdateFavoredNodesRequest to update a list of favorednode mappings
|
static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.WarmupRegionRequest |
buildWarmupRegionRequest(HRegionInfo regionInfo)
Create a WarmupRegionRequest for a given region name
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder |
getRegionActionBuilderWithRegion(org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder regionActionBuilder,
byte[] regionName) |
public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.GetRequest buildGetRowOrBeforeRequest(byte[] regionName, byte[] row, byte[] family)
regionName
- the name of the region to getrow
- the row to getfamily
- the column family to get
should return the immediate row beforepublic static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.GetRequest buildGetRequest(byte[] regionName, Get get) throws IOException
regionName
- the name of the region to getget
- the client GetIOException
public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateRequest buildIncrementRequest(byte[] regionName, byte[] row, byte[] family, byte[] qualifier, long amount, Durability durability, long nonceGroup, long nonce)
regionName
- row
- family
- qualifier
- amount
- durability
- public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateRequest buildMutateRequest(byte[] regionName, byte[] row, byte[] family, byte[] qualifier, ByteArrayComparable comparator, org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.CompareType compareType, Put put) throws IOException
regionName
- row
- family
- qualifier
- comparator
- compareType
- put
- IOException
public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateRequest buildMutateRequest(byte[] regionName, byte[] row, byte[] family, byte[] qualifier, ByteArrayComparable comparator, org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.CompareType compareType, Delete delete) throws IOException
regionName
- row
- family
- qualifier
- comparator
- compareType
- delete
- IOException
public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MultiRequest buildMutateRequest(byte[] regionName, byte[] row, byte[] family, byte[] qualifier, ByteArrayComparable comparator, org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.CompareType compareType, RowMutations rowMutations) throws IOException
regionName
- row
- family
- qualifier
- comparator
- compareType
- rowMutations
- IOException
public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateRequest buildMutateRequest(byte[] regionName, Put put) throws IOException
regionName
- put
- IOException
public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateRequest buildMutateRequest(byte[] regionName, Append append, long nonceGroup, long nonce) throws IOException
regionName
- append
- IOException
public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateRequest buildMutateRequest(byte[] regionName, Increment increment, long nonceGroup, long nonce)
regionName
- increment
- public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateRequest buildMutateRequest(byte[] regionName, Delete delete) throws IOException
regionName
- delete
- IOException
public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder buildRegionAction(byte[] regionName, RowMutations rowMutations) throws IOException
regionName
- rowMutations
- IOException
public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder buildNoDataRegionAction(byte[] regionName, RowMutations rowMutations, List<CellScannable> cells, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder regionActionBuilder, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Action.Builder actionBuilder, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutationProto.Builder mutationBuilder) throws IOException
cells
param.
Does not propagate Action absolute position. Does not set atomic action on the created
RegionAtomic. Caller should do that if wanted.regionName
- rowMutations
- cells
- Return in here a list of Cells as CellIterable.IOException
public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder getRegionActionBuilderWithRegion(org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder regionActionBuilder, byte[] regionName)
public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ScanRequest buildScanRequest(byte[] regionName, Scan scan, int numberOfRows, boolean closeScanner) throws IOException
regionName
- scan
- numberOfRows
- closeScanner
- IOException
public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ScanRequest buildScanRequest(long scannerId, int numberOfRows, boolean closeScanner, boolean trackMetrics)
scannerId
- numberOfRows
- closeScanner
- public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ScanRequest buildScanRequest(long scannerId, int numberOfRows, boolean closeScanner, long nextCallSeq, boolean trackMetrics, boolean renew, int limitOfRows)
scannerId
- numberOfRows
- closeScanner
- nextCallSeq
- public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.BulkLoadHFileRequest buildBulkLoadHFileRequest(List<Pair<byte[],String>> familyPaths, byte[] regionName, boolean assignSeqNum)
familyPaths
- regionName
- assignSeqNum
- public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.BulkLoadHFileRequest buildBulkLoadHFileRequest(List<Pair<byte[],String>> familyPaths, byte[] regionName, boolean assignSeqNum, List<String> clusterIds)
familyPaths
- regionName
- assignSeqNum
- clusterIds
- public static <R> org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder buildRegionAction(byte[] regionName, List<Action<R>> actions, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder regionActionBuilder, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Action.Builder actionBuilder, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutationProto.Builder mutationBuilder) throws IOException
regionName
- actions
- IOException
public static <R> org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder buildNoDataRegionAction(byte[] regionName, List<Action<R>> actions, List<CellScannable> cells, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder regionActionBuilder, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Action.Builder actionBuilder, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutationProto.Builder mutationBuilder) throws IOException
data
param.
Propagates Actions original index.
regionName
- actions
- cells
- Place to stuff references to actual data.IOException
public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetRegionInfoRequest buildGetRegionInfoRequest(byte[] regionName)
regionName
- the name of the region to get infopublic static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetRegionInfoRequest buildGetRegionInfoRequest(byte[] regionName, boolean includeCompactionState)
regionName
- the name of the region to get infoincludeCompactionState
- indicate if the compaction state is requestedpublic static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetStoreFileRequest buildGetStoreFileRequest(byte[] regionName, byte[] family)
regionName
- the name of the region to get infofamily
- the family to get store file listpublic static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetOnlineRegionRequest buildGetOnlineRegionRequest()
public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.FlushRegionRequest buildFlushRegionRequest(byte[] regionName)
regionName
- the name of the region to get infopublic static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.FlushRegionRequest buildFlushRegionRequest(byte[] regionName, boolean writeFlushWALMarker)
regionName
- the name of the region to get infopublic static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.OpenRegionRequest buildOpenRegionRequest(ServerName server, List<Triple<HRegionInfo,Integer,List<ServerName>>> regionOpenInfos, Boolean openForReplay)
server
- the serverName for the RPCregionOpenInfos
- info of a list of regions to openopenForReplay
- public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.OpenRegionRequest buildOpenRegionRequest(ServerName server, HRegionInfo region, int versionOfOfflineNode, List<ServerName> favoredNodes, Boolean openForReplay)
server
- the serverName for the RPCregion
- the region to openversionOfOfflineNode
- that needs to be present in the offline nodefavoredNodes
- openForReplay
- public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.UpdateFavoredNodesRequest buildUpdateFavoredNodesRequest(List<Pair<HRegionInfo,List<ServerName>>> updateRegionInfos)
updateRegionInfos
- public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.CloseRegionRequest buildCloseRegionRequest(ServerName server, byte[] regionName, boolean transitionInZK)
regionName
- the name of the region to closetransitionInZK
- indicator if to transition in ZKpublic static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.CloseRegionRequest buildCloseRegionRequest(ServerName server, byte[] regionName, int versionOfClosingNode, ServerName destinationServer, boolean transitionInZK)
public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.WarmupRegionRequest buildWarmupRegionRequest(HRegionInfo regionInfo)
regionInfo
- Region we are warming uppublic static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.CloseRegionRequest buildCloseRegionRequest(ServerName server, String encodedRegionName, boolean transitionInZK)
encodedRegionName
- the name of the region to closetransitionInZK
- indicator if to transition in ZKpublic static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.SplitRegionRequest buildSplitRegionRequest(byte[] regionName, byte[] splitPoint)
regionName
- the name of the region to splitsplitPoint
- the split pointpublic static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.MergeRegionsRequest buildMergeRegionsRequest(byte[] regionA, byte[] regionB, boolean forcible)
regionA
- name of region aregionB
- name of region bforcible
- true if it is a compulsory mergepublic static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.CompactRegionRequest buildCompactRegionRequest(byte[] regionName, boolean major, byte[] family)
regionName
- the name of the region to get infomajor
- indicator if it is a major compactionpublic static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.RollWALWriterRequest buildRollWALWriterRequest()
public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetServerInfoRequest buildGetServerInfoRequest()
public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.StopServerRequest buildStopServerRequest(String reason)
reason
- the reason to stop the serverpublic static org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.RegionSpecifier buildRegionSpecifier(org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.RegionSpecifier.RegionSpecifierType type, byte[] value)
type
- the region specifier typevalue
- the region specifier byte array valuepublic static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Condition buildCondition(byte[] row, byte[] family, byte[] qualifier, ByteArrayComparable comparator, org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.CompareType compareType) throws IOException
row
- family
- qualifier
- comparator
- compareType
- IOException
public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.AddColumnRequest buildAddColumnRequest(TableName tableName, HColumnDescriptor column, long nonceGroup, long nonce)
tableName
- column
- public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.DeleteColumnRequest buildDeleteColumnRequest(TableName tableName, byte[] columnName, long nonceGroup, long nonce)
tableName
- columnName
- public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.ModifyColumnRequest buildModifyColumnRequest(TableName tableName, HColumnDescriptor column, long nonceGroup, long nonce)
tableName
- column
- public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.MoveRegionRequest buildMoveRegionRequest(byte[] encodedRegionName, byte[] destServerName) throws DeserializationException
encodedRegionName
- destServerName
- DeserializationException
public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.DispatchMergingRegionsRequest buildDispatchMergingRegionsRequest(byte[] encodedNameOfRegionA, byte[] encodedNameOfRegionB, boolean forcible) throws DeserializationException
DeserializationException
public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.AssignRegionRequest buildAssignRegionRequest(byte[] regionName)
regionName
- public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.UnassignRegionRequest buildUnassignRegionRequest(byte[] regionName, boolean force)
regionName
- force
- public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.OfflineRegionRequest buildOfflineRegionRequest(byte[] regionName)
regionName
- public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.DeleteTableRequest buildDeleteTableRequest(TableName tableName, long nonceGroup, long nonce)
tableName
- public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.TruncateTableRequest buildTruncateTableRequest(TableName tableName, boolean preserveSplits, long nonceGroup, long nonce)
tableName
- name of table to truncatepreserveSplits
- True if the splits should be preservedpublic static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.EnableTableRequest buildEnableTableRequest(TableName tableName, long nonceGroup, long nonce)
tableName
- public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.DisableTableRequest buildDisableTableRequest(TableName tableName, long nonceGroup, long nonce)
tableName
- public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.CreateTableRequest buildCreateTableRequest(HTableDescriptor hTableDesc, byte[][] splitKeys, long nonceGroup, long nonce)
hTableDesc
- splitKeys
- public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.ModifyTableRequest buildModifyTableRequest(TableName tableName, HTableDescriptor hTableDesc, long nonceGroup, long nonce)
tableName
- hTableDesc
- public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetSchemaAlterStatusRequest buildGetSchemaAlterStatusRequest(TableName tableName)
tableName
- public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetTableDescriptorsRequest buildGetTableDescriptorsRequest(List<TableName> tableNames)
tableNames
- public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetTableDescriptorsRequest buildGetTableDescriptorsRequest(Pattern pattern, boolean includeSysTables)
pattern
- The compiled regular expression to match againstincludeSysTables
- False to match only against userspace tablespublic static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetTableNamesRequest buildGetTableNamesRequest(Pattern pattern, boolean includeSysTables)
pattern
- The compiled regular expression to match againstincludeSysTables
- False to match only against userspace tablespublic static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetTableDescriptorsRequest buildGetTableDescriptorsRequest(TableName tableName)
tableName
- the table namepublic static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsMasterRunningRequest buildIsMasterRunningRequest()
public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.BalanceRequest buildBalanceRequest(boolean force)
public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.SetBalancerRunningRequest buildSetBalancerRunningRequest(boolean on, boolean synchronous)
on
- synchronous
- public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsBalancerEnabledRequest buildIsBalancerEnabledRequest()
public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetClusterStatusRequest buildGetClusterStatusRequest()
public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.RunCatalogScanRequest buildCatalogScanRequest()
MasterProtos.RunCatalogScanRequest
public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.EnableCatalogJanitorRequest buildEnableCatalogJanitorRequest(boolean enable)
MasterProtos.EnableCatalogJanitorRequest
public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsCatalogJanitorEnabledRequest buildIsCatalogJanitorEnabledRequest()
MasterProtos.IsCatalogJanitorEnabledRequest
public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.RunCleanerChoreRequest buildCleanerChoreRequest()
MasterProtos.RunCleanerChoreRequest
public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.SetCleanerChoreRunningRequest buildSetCleanerChoreRunningRequest(boolean on)
MasterProtos.SetCleanerChoreRunningRequest
public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsCleanerChoreEnabledRequest buildIsCleanerChoreEnabledRequest()
MasterProtos.IsCleanerChoreEnabledRequest
public static org.apache.hadoop.hbase.protobuf.generated.RegionServerStatusProtos.GetLastFlushedSequenceIdRequest buildGetLastFlushedSequenceIdRequest(byte[] regionName)
regionName
- RegionServerStatusProtos.GetLastFlushedSequenceIdRequest
public static org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.GrantRequest buildGrantRequest(String username, boolean mergeExistingPermissions, org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.Permission.Action... actions)
username
- the short user name who to grant permissionsactions
- the permissions to be grantedAccessControlProtos
GrantRequestpublic static org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.GrantRequest buildGrantRequest(String username, TableName tableName, byte[] family, byte[] qualifier, boolean mergeExistingPermissions, org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.Permission.Action... actions)
username
- the short user name who to grant permissionstableName
- optional table name the permissions applyfamily
- optional column familyqualifier
- optional qualifieractions
- the permissions to be grantedAccessControlProtos
GrantRequestpublic static org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.GrantRequest buildGrantRequest(String username, String namespace, boolean mergeExistingPermissions, org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.Permission.Action... actions)
username
- the short user name who to grant permissionsnamespace
- optional table name the permissions applyactions
- the permissions to be grantedAccessControlProtos
GrantRequestpublic static org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.RevokeRequest buildRevokeRequest(String username, org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.Permission.Action... actions)
username
- the short user name whose permissions to be revokedactions
- the permissions to be revokedAccessControlProtos
RevokeRequestpublic static org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.RevokeRequest buildRevokeRequest(String username, TableName tableName, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.Permission.Action... actions)
username
- the short user name whose permissions to be revokedtableName
- optional table name the permissions applyfamily
- optional column familyqualifier
- optional qualifieractions
- the permissions to be revokedAccessControlProtos
RevokeRequestpublic static org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.RevokeRequest buildRevokeRequest(String username, String namespace, org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.Permission.Action... actions)
username
- the short user name whose permissions to be revokednamespace
- optional table name the permissions applyactions
- the permissions to be revokedAccessControlProtos
RevokeRequestpublic static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.NormalizeRequest buildNormalizeRequest()
public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsNormalizerEnabledRequest buildIsNormalizerEnabledRequest()
public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.SetNormalizerRunningRequest buildSetNormalizerRunningRequest(boolean on)
on
- public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsSplitOrMergeEnabledRequest buildIsSplitOrMergeEnabledRequest(Admin.MasterSwitchType switchType)
switchType
- see Admin.MasterSwitchType
public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.SetSplitOrMergeEnabledRequest buildSetSplitOrMergeEnabledRequest(boolean enabled, boolean synchronous, Admin.MasterSwitchType... switchTypes)
enabled
- switch is enabled or notsynchronous
- set switch sync?switchTypes
- see Admin.MasterSwitchType
, it is
a list.public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.ClearDeadServersRequest buildClearDeadServersRequest(List<ServerName> deadServers)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.