@InterfaceAudience.Private public final class RequestConverter extends Object
Modifier and Type | Method and Description |
---|---|
static MasterProtos.AddColumnRequest |
buildAddColumnRequest(TableName tableName,
HColumnDescriptor column)
Create a protocol buffer AddColumnRequest
|
static MasterProtos.AssignRegionRequest |
buildAssignRegionRequest(byte[] regionName)
Create a protocol buffer AssignRegionRequest
|
static MasterProtos.BalanceRequest |
buildBalanceRequest(boolean force)
Creates a protocol buffer BalanceRequest
|
static ClientProtos.BulkLoadHFileRequest |
buildBulkLoadHFileRequest(List<Pair<byte[],String>> familyPaths,
byte[] regionName,
boolean assignSeqNum)
Create a protocol buffer bulk load request
|
static MasterProtos.RunCatalogScanRequest |
buildCatalogScanRequest()
Creates a request for running a catalog scan
|
static AdminProtos.CloseRegionRequest |
buildCloseRegionRequest(ServerName server,
byte[] regionName,
boolean transitionInZK)
Create a CloseRegionRequest for a given region name
|
static AdminProtos.CloseRegionRequest |
buildCloseRegionRequest(ServerName server,
byte[] regionName,
int versionOfClosingNode,
ServerName destinationServer,
boolean transitionInZK) |
static AdminProtos.CloseRegionRequest |
buildCloseRegionRequest(ServerName server,
String encodedRegionName,
boolean transitionInZK)
Create a CloseRegionRequest for a given encoded region name
|
static AdminProtos.CompactRegionRequest |
buildCompactRegionRequest(byte[] regionName,
boolean major,
byte[] family)
Create a CompactRegionRequest for a given region name
|
static MasterProtos.CreateTableRequest |
buildCreateTableRequest(HTableDescriptor hTableDesc,
byte[][] splitKeys)
Creates a protocol buffer CreateTableRequest
|
static MasterProtos.DeleteColumnRequest |
buildDeleteColumnRequest(TableName tableName,
byte[] columnName)
Create a protocol buffer DeleteColumnRequest
|
static MasterProtos.DeleteTableRequest |
buildDeleteTableRequest(TableName tableName)
Creates a protocol buffer DeleteTableRequest
|
static MasterProtos.DisableTableRequest |
buildDisableTableRequest(TableName tableName)
Creates a protocol buffer DisableTableRequest
|
static MasterProtos.DispatchMergingRegionsRequest |
buildDispatchMergingRegionsRequest(byte[] encodedNameOfRegionA,
byte[] encodedNameOfRegionB,
boolean forcible) |
static MasterProtos.EnableCatalogJanitorRequest |
buildEnableCatalogJanitorRequest(boolean enable)
Creates a request for enabling/disabling the catalog janitor
|
static MasterProtos.EnableTableRequest |
buildEnableTableRequest(TableName tableName)
Creates a protocol buffer EnableTableRequest
|
static AdminProtos.FlushRegionRequest |
buildFlushRegionRequest(byte[] regionName)
Create a protocol buffer FlushRegionRequest for a given region name
|
static AdminProtos.FlushRegionRequest |
buildFlushRegionRequest(byte[] regionName,
boolean writeFlushWALMarker)
Create a protocol buffer FlushRegionRequest for a given region name
|
static MasterProtos.GetClusterStatusRequest |
buildGetClusterStatusRequest()
Creates a protocol buffer GetClusterStatusRequest
|
static RegionServerStatusProtos.GetLastFlushedSequenceIdRequest |
buildGetLastFlushedSequenceIdRequest(byte[] regionName)
Creates a request for querying the master the last flushed sequence Id for a region
|
static AdminProtos.GetOnlineRegionRequest |
buildGetOnlineRegionRequest()
Create a protocol buffer GetOnlineRegionRequest
|
static AdminProtos.GetRegionInfoRequest |
buildGetRegionInfoRequest(byte[] regionName)
Create a protocol buffer GetRegionInfoRequest for a given region name
|
static AdminProtos.GetRegionInfoRequest |
buildGetRegionInfoRequest(byte[] regionName,
boolean includeCompactionState)
Create a protocol buffer GetRegionInfoRequest for a given region name
|
static ClientProtos.GetRequest |
buildGetRequest(byte[] regionName,
Get get)
Create a protocol buffer GetRequest for a client Get
|
static 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 MasterProtos.GetSchemaAlterStatusRequest |
buildGetSchemaAlterStatusRequest(TableName tableName)
Creates a protocol buffer GetSchemaAlterStatusRequest
|
static AdminProtos.GetServerInfoRequest |
buildGetServerInfoRequest()
Create a new GetServerInfoRequest
|
static AdminProtos.GetStoreFileRequest |
buildGetStoreFileRequest(byte[] regionName,
byte[] family)
Create a protocol buffer GetStoreFileRequest for a given region name
|
static MasterProtos.GetTableDescriptorsRequest |
buildGetTableDescriptorsRequest(List<TableName> tableNames)
Creates a protocol buffer GetTableDescriptorsRequest
|
static MasterProtos.GetTableDescriptorsRequest |
buildGetTableDescriptorsRequest(Pattern pattern,
boolean includeSysTables)
Creates a protocol buffer GetTableDescriptorsRequest
|
static MasterProtos.GetTableDescriptorsRequest |
buildGetTableDescriptorsRequest(TableName tableName)
Creates a protocol buffer GetTableDescriptorsRequest for a single table
|
static MasterProtos.GetTableNamesRequest |
buildGetTableNamesRequest(Pattern pattern,
boolean includeSysTables)
Creates a protocol buffer GetTableNamesRequest
|
static AccessControlProtos.GrantRequest |
buildGrantRequest(String username,
AccessControlProtos.Permission.Action... actions)
Create a request to grant user permissions.
|
static AccessControlProtos.GrantRequest |
buildGrantRequest(String username,
String namespace,
AccessControlProtos.Permission.Action... actions)
Create a request to grant user permissions.
|
static AccessControlProtos.GrantRequest |
buildGrantRequest(String username,
TableName tableName,
byte[] family,
byte[] qualifier,
AccessControlProtos.Permission.Action... actions)
Create a request to grant user permissions.
|
static 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 MasterProtos.IsBalancerEnabledRequest |
buildIsBalancerEnabledRequest()
Creates a protocol buffer IsBalancerEnabledRequest
|
static MasterProtos.IsCatalogJanitorEnabledRequest |
buildIsCatalogJanitorEnabledRequest()
Creates a request for querying the master whether the catalog janitor is enabled
|
static MasterProtos.IsMasterRunningRequest |
buildIsMasterRunningRequest()
Creates a protocol buffer IsMasterRunningRequest
|
static MasterProtos.IsNormalizerEnabledRequest |
buildIsNormalizerEnabledRequest()
Creates a protocol buffer IsNormalizerEnabledRequest
|
static AdminProtos.MergeRegionsRequest |
buildMergeRegionsRequest(byte[] regionA,
byte[] regionB,
boolean forcible)
Create a MergeRegionsRequest for the given regions
|
static MasterProtos.ModifyColumnRequest |
buildModifyColumnRequest(TableName tableName,
HColumnDescriptor column)
Create a protocol buffer ModifyColumnRequest
|
static MasterProtos.ModifyTableRequest |
buildModifyTableRequest(TableName tableName,
HTableDescriptor hTableDesc)
Creates a protocol buffer ModifyTableRequest
|
static MasterProtos.MoveRegionRequest |
buildMoveRegionRequest(byte[] encodedRegionName,
byte[] destServerName)
Create a protocol buffer MoveRegionRequest
|
static ClientProtos.MutateRequest |
buildMutateRequest(byte[] regionName,
Append append,
long nonceGroup,
long nonce)
Create a protocol buffer MutateRequest for an append
|
static ClientProtos.MutateRequest |
buildMutateRequest(byte[] regionName,
byte[] row,
byte[] family,
byte[] qualifier,
ByteArrayComparable comparator,
HBaseProtos.CompareType compareType,
Delete delete)
Create a protocol buffer MutateRequest for a conditioned delete
|
static ClientProtos.MutateRequest |
buildMutateRequest(byte[] regionName,
byte[] row,
byte[] family,
byte[] qualifier,
ByteArrayComparable comparator,
HBaseProtos.CompareType compareType,
Put put)
Create a protocol buffer MutateRequest for a conditioned put
|
static ClientProtos.MultiRequest |
buildMutateRequest(byte[] regionName,
byte[] row,
byte[] family,
byte[] qualifier,
ByteArrayComparable comparator,
HBaseProtos.CompareType compareType,
RowMutations rowMutations)
Create a protocol buffer MutateRequest for conditioned row mutations
|
static ClientProtos.MutateRequest |
buildMutateRequest(byte[] regionName,
Delete delete)
Create a protocol buffer MutateRequest for a delete
|
static ClientProtos.MutateRequest |
buildMutateRequest(byte[] regionName,
Increment increment,
long nonceGroup,
long nonce)
Create a protocol buffer MutateRequest for a client increment
|
static ClientProtos.MutateRequest |
buildMutateRequest(byte[] regionName,
Put put)
Create a protocol buffer MutateRequest for a put
|
static <R> ClientProtos.RegionAction.Builder |
buildNoDataRegionAction(byte[] regionName,
List<Action<R>> actions,
List<CellScannable> cells,
ClientProtos.RegionAction.Builder regionActionBuilder,
ClientProtos.Action.Builder actionBuilder,
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 ClientProtos.RegionAction.Builder |
buildNoDataRegionAction(byte[] regionName,
RowMutations rowMutations,
List<CellScannable> cells,
ClientProtos.RegionAction.Builder regionActionBuilder,
ClientProtos.Action.Builder actionBuilder,
ClientProtos.MutationProto.Builder mutationBuilder)
Create a protocol buffer MultiRequest for row mutations that does not hold data.
|
static MasterProtos.NormalizeRequest |
buildNormalizeRequest()
Creates a protocol buffer NormalizeRequest
|
static MasterProtos.OfflineRegionRequest |
buildOfflineRegionRequest(byte[] regionName)
Creates a protocol buffer OfflineRegionRequest
|
static AdminProtos.OpenRegionRequest |
buildOpenRegionRequest(ServerName server,
HRegionInfo region,
int versionOfOfflineNode,
List<ServerName> favoredNodes,
Boolean openForReplay)
Create a protocol buffer OpenRegionRequest for a given region
|
static 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> ClientProtos.RegionAction.Builder |
buildRegionAction(byte[] regionName,
List<Action<R>> actions,
ClientProtos.RegionAction.Builder regionActionBuilder,
ClientProtos.Action.Builder actionBuilder,
ClientProtos.MutationProto.Builder mutationBuilder)
Create a protocol buffer multi request for a list of actions.
|
static ClientProtos.RegionAction.Builder |
buildRegionAction(byte[] regionName,
RowMutations rowMutations)
Create a protocol buffer MultiRequest for row mutations.
|
static HBaseProtos.RegionSpecifier |
buildRegionSpecifier(HBaseProtos.RegionSpecifier.RegionSpecifierType type,
byte[] value)
Convert a byte array to a protocol buffer RegionSpecifier
|
static AccessControlProtos.RevokeRequest |
buildRevokeRequest(String username,
AccessControlProtos.Permission.Action... actions)
Create a request to revoke user permissions.
|
static AccessControlProtos.RevokeRequest |
buildRevokeRequest(String username,
String namespace,
AccessControlProtos.Permission.Action... actions)
Create a request to revoke user permissions.
|
static AccessControlProtos.RevokeRequest |
buildRevokeRequest(String username,
TableName tableName,
byte[] family,
byte[] qualifier,
AccessControlProtos.Permission.Action... actions)
Create a request to revoke user permissions.
|
static AdminProtos.RollWALWriterRequest |
buildRollWALWriterRequest()
Create a new RollWALWriterRequest
|
static ClientProtos.ScanRequest |
buildScanRequest(byte[] regionName,
Scan scan,
int numberOfRows,
boolean closeScanner)
Create a protocol buffer ScanRequest for a client Scan
|
static ClientProtos.ScanRequest |
buildScanRequest(long scannerId,
int numberOfRows,
boolean closeScanner)
Create a protocol buffer ScanRequest for a scanner id
|
static ClientProtos.ScanRequest |
buildScanRequest(long scannerId,
int numberOfRows,
boolean closeScanner,
long nextCallSeq)
Create a protocol buffer ScanRequest for a scanner id
|
static MasterProtos.SetBalancerRunningRequest |
buildSetBalancerRunningRequest(boolean on,
boolean synchronous)
Creates a protocol buffer SetBalancerRunningRequest
|
static MasterProtos.SetNormalizerRunningRequest |
buildSetNormalizerRunningRequest(boolean on)
Creates a protocol buffer SetNormalizerRunningRequest
|
static AdminProtos.SplitRegionRequest |
buildSplitRegionRequest(byte[] regionName,
byte[] splitPoint)
Create a SplitRegionRequest for a given region name
|
static AdminProtos.StopServerRequest |
buildStopServerRequest(String reason)
Create a new StopServerRequest
|
static MasterProtos.TruncateTableRequest |
buildTruncateTableRequest(TableName tableName,
boolean preserveSplits)
Creates a protocol buffer TruncateTableRequest
|
static MasterProtos.UnassignRegionRequest |
buildUnassignRegionRequest(byte[] regionName,
boolean force)
Creates a protocol buffer UnassignRegionRequest
|
static AdminProtos.UpdateFavoredNodesRequest |
buildUpdateFavoredNodesRequest(List<Pair<HRegionInfo,List<ServerName>>> updateRegionInfos)
Create a protocol buffer UpdateFavoredNodesRequest to update a list of favorednode mappings
|
static AdminProtos.WarmupRegionRequest |
buildWarmupRegionRequest(HRegionInfo regionInfo)
Create a WarmupRegionRequest for a given region name
|
public static 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 ClientProtos.GetRequest buildGetRequest(byte[] regionName, Get get) throws IOException
regionName
- the name of the region to getget
- the client GetIOException
public static 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 ClientProtos.MutateRequest buildMutateRequest(byte[] regionName, byte[] row, byte[] family, byte[] qualifier, ByteArrayComparable comparator, HBaseProtos.CompareType compareType, Put put) throws IOException
regionName
- row
- family
- qualifier
- comparator
- compareType
- put
- IOException
public static ClientProtos.MutateRequest buildMutateRequest(byte[] regionName, byte[] row, byte[] family, byte[] qualifier, ByteArrayComparable comparator, HBaseProtos.CompareType compareType, Delete delete) throws IOException
regionName
- row
- family
- qualifier
- comparator
- compareType
- delete
- IOException
public static ClientProtos.MultiRequest buildMutateRequest(byte[] regionName, byte[] row, byte[] family, byte[] qualifier, ByteArrayComparable comparator, HBaseProtos.CompareType compareType, RowMutations rowMutations) throws IOException
regionName
- row
- family
- qualifier
- comparator
- compareType
- rowMutations
- IOException
public static ClientProtos.MutateRequest buildMutateRequest(byte[] regionName, Put put) throws IOException
regionName
- put
- IOException
public static ClientProtos.MutateRequest buildMutateRequest(byte[] regionName, Append append, long nonceGroup, long nonce) throws IOException
regionName
- append
- IOException
public static ClientProtos.MutateRequest buildMutateRequest(byte[] regionName, Increment increment, long nonceGroup, long nonce)
regionName
- increment
- public static ClientProtos.MutateRequest buildMutateRequest(byte[] regionName, Delete delete) throws IOException
regionName
- delete
- IOException
public static ClientProtos.RegionAction.Builder buildRegionAction(byte[] regionName, RowMutations rowMutations) throws IOException
regionName
- rowMutations
- IOException
public static ClientProtos.RegionAction.Builder buildNoDataRegionAction(byte[] regionName, RowMutations rowMutations, List<CellScannable> cells, ClientProtos.RegionAction.Builder regionActionBuilder, ClientProtos.Action.Builder actionBuilder, 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 ClientProtos.ScanRequest buildScanRequest(byte[] regionName, Scan scan, int numberOfRows, boolean closeScanner) throws IOException
regionName
- scan
- numberOfRows
- closeScanner
- IOException
public static ClientProtos.ScanRequest buildScanRequest(long scannerId, int numberOfRows, boolean closeScanner)
scannerId
- numberOfRows
- closeScanner
- public static ClientProtos.ScanRequest buildScanRequest(long scannerId, int numberOfRows, boolean closeScanner, long nextCallSeq)
scannerId
- numberOfRows
- closeScanner
- nextCallSeq
- public static ClientProtos.BulkLoadHFileRequest buildBulkLoadHFileRequest(List<Pair<byte[],String>> familyPaths, byte[] regionName, boolean assignSeqNum)
familyPaths
- regionName
- assignSeqNum
- public static <R> ClientProtos.RegionAction.Builder buildRegionAction(byte[] regionName, List<Action<R>> actions, ClientProtos.RegionAction.Builder regionActionBuilder, ClientProtos.Action.Builder actionBuilder, ClientProtos.MutationProto.Builder mutationBuilder) throws IOException
regionName
- actions
- IOException
public static <R> ClientProtos.RegionAction.Builder buildNoDataRegionAction(byte[] regionName, List<Action<R>> actions, List<CellScannable> cells, ClientProtos.RegionAction.Builder regionActionBuilder, ClientProtos.Action.Builder actionBuilder, 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 AdminProtos.GetRegionInfoRequest buildGetRegionInfoRequest(byte[] regionName)
regionName
- the name of the region to get infopublic static AdminProtos.GetRegionInfoRequest buildGetRegionInfoRequest(byte[] regionName, boolean includeCompactionState)
regionName
- the name of the region to get infoincludeCompactionState
- indicate if the compaction state is requestedpublic static AdminProtos.GetStoreFileRequest buildGetStoreFileRequest(byte[] regionName, byte[] family)
regionName
- the name of the region to get infofamily
- the family to get store file listpublic static AdminProtos.GetOnlineRegionRequest buildGetOnlineRegionRequest()
public static AdminProtos.FlushRegionRequest buildFlushRegionRequest(byte[] regionName)
regionName
- the name of the region to get infopublic static AdminProtos.FlushRegionRequest buildFlushRegionRequest(byte[] regionName, boolean writeFlushWALMarker)
regionName
- the name of the region to get infopublic static 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 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 AdminProtos.UpdateFavoredNodesRequest buildUpdateFavoredNodesRequest(List<Pair<HRegionInfo,List<ServerName>>> updateRegionInfos)
updateRegionInfos
- public static AdminProtos.CloseRegionRequest buildCloseRegionRequest(ServerName server, byte[] regionName, boolean transitionInZK)
regionName
- the name of the region to closetransitionInZK
- indicator if to transition in ZKpublic static AdminProtos.CloseRegionRequest buildCloseRegionRequest(ServerName server, byte[] regionName, int versionOfClosingNode, ServerName destinationServer, boolean transitionInZK)
public static AdminProtos.WarmupRegionRequest buildWarmupRegionRequest(HRegionInfo regionInfo)
regionInfo
- Region we are warming uppublic static AdminProtos.CloseRegionRequest buildCloseRegionRequest(ServerName server, String encodedRegionName, boolean transitionInZK)
encodedRegionName
- the name of the region to closetransitionInZK
- indicator if to transition in ZKpublic static AdminProtos.SplitRegionRequest buildSplitRegionRequest(byte[] regionName, byte[] splitPoint)
regionName
- the name of the region to splitsplitPoint
- the split pointpublic static 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 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 AdminProtos.RollWALWriterRequest buildRollWALWriterRequest()
public static AdminProtos.GetServerInfoRequest buildGetServerInfoRequest()
public static AdminProtos.StopServerRequest buildStopServerRequest(String reason)
reason
- the reason to stop the serverpublic static HBaseProtos.RegionSpecifier buildRegionSpecifier(HBaseProtos.RegionSpecifier.RegionSpecifierType type, byte[] value)
type
- the region specifier typevalue
- the region specifier byte array valuepublic static MasterProtos.AddColumnRequest buildAddColumnRequest(TableName tableName, HColumnDescriptor column)
tableName
- column
- public static MasterProtos.DeleteColumnRequest buildDeleteColumnRequest(TableName tableName, byte[] columnName)
tableName
- columnName
- public static MasterProtos.ModifyColumnRequest buildModifyColumnRequest(TableName tableName, HColumnDescriptor column)
tableName
- column
- public static MasterProtos.MoveRegionRequest buildMoveRegionRequest(byte[] encodedRegionName, byte[] destServerName) throws DeserializationException
encodedRegionName
- destServerName
- DeserializationException
public static MasterProtos.DispatchMergingRegionsRequest buildDispatchMergingRegionsRequest(byte[] encodedNameOfRegionA, byte[] encodedNameOfRegionB, boolean forcible) throws DeserializationException
DeserializationException
public static MasterProtos.AssignRegionRequest buildAssignRegionRequest(byte[] regionName)
regionName
- public static MasterProtos.UnassignRegionRequest buildUnassignRegionRequest(byte[] regionName, boolean force)
regionName
- force
- public static MasterProtos.OfflineRegionRequest buildOfflineRegionRequest(byte[] regionName)
regionName
- public static MasterProtos.DeleteTableRequest buildDeleteTableRequest(TableName tableName)
tableName
- public static MasterProtos.TruncateTableRequest buildTruncateTableRequest(TableName tableName, boolean preserveSplits)
tableName
- name of table to truncatepreserveSplits
- True if the splits should be preservedpublic static MasterProtos.EnableTableRequest buildEnableTableRequest(TableName tableName)
tableName
- public static MasterProtos.DisableTableRequest buildDisableTableRequest(TableName tableName)
tableName
- public static MasterProtos.CreateTableRequest buildCreateTableRequest(HTableDescriptor hTableDesc, byte[][] splitKeys)
hTableDesc
- splitKeys
- public static MasterProtos.ModifyTableRequest buildModifyTableRequest(TableName tableName, HTableDescriptor hTableDesc)
tableName
- hTableDesc
- public static MasterProtos.GetSchemaAlterStatusRequest buildGetSchemaAlterStatusRequest(TableName tableName)
tableName
- public static MasterProtos.GetTableDescriptorsRequest buildGetTableDescriptorsRequest(List<TableName> tableNames)
tableNames
- public static MasterProtos.GetTableDescriptorsRequest buildGetTableDescriptorsRequest(Pattern pattern, boolean includeSysTables)
pattern
- The compiled regular expression to match againstincludeSysTables
- False to match only against userspace tablespublic static MasterProtos.GetTableNamesRequest buildGetTableNamesRequest(Pattern pattern, boolean includeSysTables)
pattern
- The compiled regular expression to match againstincludeSysTables
- False to match only against userspace tablespublic static MasterProtos.GetTableDescriptorsRequest buildGetTableDescriptorsRequest(TableName tableName)
tableName
- the table namepublic static MasterProtos.IsMasterRunningRequest buildIsMasterRunningRequest()
public static MasterProtos.BalanceRequest buildBalanceRequest(boolean force)
public static MasterProtos.SetBalancerRunningRequest buildSetBalancerRunningRequest(boolean on, boolean synchronous)
on
- synchronous
- public static MasterProtos.IsBalancerEnabledRequest buildIsBalancerEnabledRequest()
public static MasterProtos.GetClusterStatusRequest buildGetClusterStatusRequest()
public static MasterProtos.RunCatalogScanRequest buildCatalogScanRequest()
MasterProtos.RunCatalogScanRequest
public static MasterProtos.EnableCatalogJanitorRequest buildEnableCatalogJanitorRequest(boolean enable)
MasterProtos.EnableCatalogJanitorRequest
public static MasterProtos.IsCatalogJanitorEnabledRequest buildIsCatalogJanitorEnabledRequest()
MasterProtos.IsCatalogJanitorEnabledRequest
public static RegionServerStatusProtos.GetLastFlushedSequenceIdRequest buildGetLastFlushedSequenceIdRequest(byte[] regionName)
regionName
- RegionServerStatusProtos.GetLastFlushedSequenceIdRequest
public static AccessControlProtos.GrantRequest buildGrantRequest(String username, AccessControlProtos.Permission.Action... actions)
username
- the short user name who to grant permissionsactions
- the permissions to be grantedAccessControlProtos
GrantRequestpublic static AccessControlProtos.GrantRequest buildGrantRequest(String username, TableName tableName, byte[] family, byte[] qualifier, 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 AccessControlProtos.GrantRequest buildGrantRequest(String username, String namespace, 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 AccessControlProtos.RevokeRequest buildRevokeRequest(String username, AccessControlProtos.Permission.Action... actions)
username
- the short user name whose permissions to be revokedactions
- the permissions to be revokedAccessControlProtos
RevokeRequestpublic static AccessControlProtos.RevokeRequest buildRevokeRequest(String username, TableName tableName, byte[] family, byte[] qualifier, 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 AccessControlProtos.RevokeRequest buildRevokeRequest(String username, String namespace, 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 MasterProtos.NormalizeRequest buildNormalizeRequest()
public static MasterProtos.IsNormalizerEnabledRequest buildIsNormalizerEnabledRequest()
public static MasterProtos.SetNormalizerRunningRequest buildSetNormalizerRunningRequest(boolean on)
on
-