org.apache.hadoop.hbase.protobuf

类 RequestConverter

java.lang.Object

org.apache.hadoop.hbase.protobuf.RequestConverter

@InterfaceAudience.Private
public final class RequestConverter
extends Object

Helper utility to build protocol buffer requests, or build components for protocol buffer requests.

方法概要

方法

限定符和类型	方法和说明
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.AddColumnRequest	buildAddColumnRequest(org.apache.hadoop.hbase.TableName tableName, HColumnDescriptor column) 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() Creates a protocol buffer BalanceRequest
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.BulkLoadHFileRequest	buildBulkLoadHFileRequest(List<org.apache.hadoop.hbase.util.Pair<byte[],String>> familyPaths, byte[] regionName, boolean assignSeqNum) 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.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.MasterProtos.CreateTableRequest	buildCreateTableRequest(HTableDescriptor hTableDesc, byte[][] splitKeys) Creates a protocol buffer CreateTableRequest
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.DeleteColumnRequest	buildDeleteColumnRequest(org.apache.hadoop.hbase.TableName tableName, byte[] columnName) Create a protocol buffer DeleteColumnRequest
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.DeleteTableRequest	buildDeleteTableRequest(org.apache.hadoop.hbase.TableName tableName) Creates a protocol buffer DeleteTableRequest
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.DisableTableRequest	buildDisableTableRequest(org.apache.hadoop.hbase.TableName tableName) 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(org.apache.hadoop.hbase.TableName tableName) 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.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(org.apache.hadoop.hbase.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<org.apache.hadoop.hbase.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(org.apache.hadoop.hbase.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, 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, 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, org.apache.hadoop.hbase.TableName tableName, byte[] family, byte[] qualifier, 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.IsCatalogJanitorEnabledRequest	buildIsCatalogJanitorEnabledRequest() Creates a request for querying the master whether the catalog janitor is enabled
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsMasterRunningRequest	buildIsMasterRunningRequest() Creates a protocol buffer IsMasterRunningRequest
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(org.apache.hadoop.hbase.TableName tableName, HColumnDescriptor column) Create a protocol buffer ModifyColumnRequest
static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.ModifyTableRequest	buildModifyTableRequest(org.apache.hadoop.hbase.TableName tableName, HTableDescriptor hTableDesc) 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<org.apache.hadoop.hbase.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<org.apache.hadoop.hbase.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.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<org.apache.hadoop.hbase.util.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, org.apache.hadoop.hbase.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) 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) 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.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(org.apache.hadoop.hbase.TableName tableName, boolean preserveSplits) 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<org.apache.hadoop.hbase.util.Pair<HRegionInfo,List<ServerName>>> updateRegionInfos) Create a protocol buffer UpdateFavoredNodesRequest to update a list of favorednode mappings

从类继承的方法 java.lang.Object

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

方法详细资料

buildGetRowOrBeforeRequest

public 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. If there is no such row, return the closest row before it.

参数:

regionName - the name of the region to get

row - the row to get

family - the column family to get should return the immediate row before

返回:

a protocol buffer GetReuqest

buildGetRequest

public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.GetRequest buildGetRequest(byte[] regionName,
                                                                                 Get get)
                                                                                          throws IOException

Create a protocol buffer GetRequest for a client Get

参数:

regionName - the name of the region to get

get - the client Get

返回:

a protocol buffer GetRequest

抛出:

IOException

buildIncrementRequest

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)

Create a protocol buffer MutateRequest for a client increment

参数:

regionName -

row -

family -

qualifier -

amount -

durability -

返回:

a mutate request

buildMutateRequest

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

Create a protocol buffer MutateRequest for a conditioned put

参数:

regionName -

row -

family -

qualifier -

comparator -

compareType -

put -

返回:

a mutate request

抛出:

IOException

buildMutateRequest

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

Create a protocol buffer MutateRequest for a conditioned delete

参数:

regionName -

row -

family -

qualifier -

comparator -

compareType -

delete -

返回:

a mutate request

抛出:

IOException

buildMutateRequest

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

Create a protocol buffer MutateRequest for conditioned row mutations

参数:

regionName -

row -

family -

qualifier -

comparator -

compareType -

rowMutations -

返回:

a mutate request

抛出:

IOException

buildMutateRequest

public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateRequest buildMutateRequest(byte[] regionName,
                                                                                       Put put)
                                                                                                throws IOException

Create a protocol buffer MutateRequest for a put

参数:

regionName -

put -

返回:

a mutate request

抛出:

IOException

buildMutateRequest

public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateRequest buildMutateRequest(byte[] regionName,
                                                                                       Append append,
                                                                                       long nonceGroup,
                                                                                       long nonce)
                                                                                                throws IOException

Create a protocol buffer MutateRequest for an append

参数:

regionName -

append -

返回:

a mutate request

抛出:

IOException

buildMutateRequest

public 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

参数:

regionName -

increment -

返回:

a mutate request

buildMutateRequest

public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateRequest buildMutateRequest(byte[] regionName,
                                                                                       Delete delete)
                                                                                                throws IOException

Create a protocol buffer MutateRequest for a delete

参数:

regionName -

delete -

返回:

a mutate request

抛出:

IOException

buildRegionAction

public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder buildRegionAction(byte[] regionName,
                                                                                             RowMutations rowMutations)
                                                                                                      throws IOException

Create a protocol buffer MultiRequest for row mutations. Does not propagate Action absolute position. Does not set atomic action on the created RegionAtomic. Caller should do that if wanted.

参数:

regionName -

rowMutations -

返回:

a data-laden RegionMutation.Builder

抛出:

IOException

buildNoDataRegionAction

public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder buildNoDataRegionAction(byte[] regionName,
                                                                                                   RowMutations rowMutations,
                                                                                                   List<org.apache.hadoop.hbase.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

Create a protocol buffer MultiRequest for row mutations that does not hold data. Data/Cells are carried outside of protobuf. Return references to the Cells in 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.

返回:

a region mutation minus data

抛出:

IOException

buildScanRequest

public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ScanRequest buildScanRequest(byte[] regionName,
                                                                                   Scan scan,
                                                                                   int numberOfRows,
                                                                                   boolean closeScanner)
                                                                                            throws IOException

Create a protocol buffer ScanRequest for a client Scan

参数:

regionName -

scan -

numberOfRows -

closeScanner -

返回:

a scan request

抛出:

IOException

buildScanRequest

public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ScanRequest buildScanRequest(long scannerId,
                                                                                   int numberOfRows,
                                                                                   boolean closeScanner)

Create a protocol buffer ScanRequest for a scanner id

参数:

scannerId -

numberOfRows -

closeScanner -

返回:

a scan request

buildScanRequest

public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ScanRequest buildScanRequest(long scannerId,
                                                                                   int numberOfRows,
                                                                                   boolean closeScanner,
                                                                                   long nextCallSeq)

Create a protocol buffer ScanRequest for a scanner id

参数:

scannerId -

numberOfRows -

closeScanner -

nextCallSeq -

返回:

a scan request

buildBulkLoadHFileRequest

public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.BulkLoadHFileRequest buildBulkLoadHFileRequest(List<org.apache.hadoop.hbase.util.Pair<byte[],String>> familyPaths,
                                                                                                     byte[] regionName,
                                                                                                     boolean assignSeqNum)

Create a protocol buffer bulk load request

参数:

familyPaths -

regionName -

assignSeqNum -

返回:

a bulk load request

buildRegionAction

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

Create a protocol buffer multi request for a list of actions. Propagates Actions original index.

参数:

regionName -

actions -

返回:

a multi request

抛出:

IOException

buildNoDataRegionAction

public static <R> org.apache.hadoop.hbase.protobuf.generated.ClientProtos.RegionAction.Builder buildNoDataRegionAction(byte[] regionName,
                                                                                                       List<Action<R>> actions,
                                                                                                       List<org.apache.hadoop.hbase.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

Create a protocol buffer multirequest with NO data for a list of actions (data is carried otherwise than via protobuf). This means it just notes attributes, whether to write the WAL, etc., and the presence in protobuf serves as place holder for the data which is coming along otherwise. Note that Get is different. It does not contain 'data' and is always carried by protobuf. We return references to the data by adding them to the passed in data param.

Propagates Actions original index.

参数:

regionName -

actions -

cells - Place to stuff references to actual data.

返回:

a multi request that does not carry any data.

抛出:

IOException

buildGetRegionInfoRequest

public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetRegionInfoRequest buildGetRegionInfoRequest(byte[] regionName)

Create a protocol buffer GetRegionInfoRequest for a given region name

参数:

regionName - the name of the region to get info

返回:

a protocol buffer GetRegionInfoRequest

buildGetRegionInfoRequest

public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetRegionInfoRequest buildGetRegionInfoRequest(byte[] regionName,
                                                                                                    boolean includeCompactionState)

Create a protocol buffer GetRegionInfoRequest for a given region name

参数:

regionName - the name of the region to get info

includeCompactionState - indicate if the compaction state is requested

返回:

a protocol buffer GetRegionInfoRequest

buildGetStoreFileRequest

public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetStoreFileRequest buildGetStoreFileRequest(byte[] regionName,
                                                                                                  byte[] family)

Create a protocol buffer GetStoreFileRequest for a given region name

参数:

regionName - the name of the region to get info

family - the family to get store file list

返回:

a protocol buffer GetStoreFileRequest

buildGetOnlineRegionRequest

public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetOnlineRegionRequest buildGetOnlineRegionRequest()

Create a protocol buffer GetOnlineRegionRequest

返回:

a protocol buffer GetOnlineRegionRequest

buildFlushRegionRequest

public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.FlushRegionRequest buildFlushRegionRequest(byte[] regionName)

Create a protocol buffer FlushRegionRequest for a given region name

参数:

regionName - the name of the region to get info

返回:

a protocol buffer FlushRegionRequest

buildOpenRegionRequest

public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.OpenRegionRequest buildOpenRegionRequest(ServerName server,
                                                                                              List<org.apache.hadoop.hbase.util.Triple<HRegionInfo,Integer,List<ServerName>>> regionOpenInfos,
                                                                                              Boolean openForReplay)

Create a protocol buffer OpenRegionRequest to open a list of regions

参数:

server - the serverName for the RPC

regionOpenInfos - info of a list of regions to open

openForReplay -

返回:

a protocol buffer OpenRegionRequest

buildOpenRegionRequest

public 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

参数:

server - the serverName for the RPC

region - the region to open

versionOfOfflineNode - that needs to be present in the offline node

favoredNodes -

openForReplay -

返回:

a protocol buffer OpenRegionRequest

buildUpdateFavoredNodesRequest

public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.UpdateFavoredNodesRequest buildUpdateFavoredNodesRequest(List<org.apache.hadoop.hbase.util.Pair<HRegionInfo,List<ServerName>>> updateRegionInfos)

Create a protocol buffer UpdateFavoredNodesRequest to update a list of favorednode mappings

参数:

updateRegionInfos -

返回:

a protocol buffer UpdateFavoredNodesRequest

buildCloseRegionRequest

public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.CloseRegionRequest buildCloseRegionRequest(ServerName server,
                                                                                                byte[] regionName,
                                                                                                boolean transitionInZK)

Create a CloseRegionRequest for a given region name

参数:

regionName - the name of the region to close

transitionInZK - indicator if to transition in ZK

返回:

a CloseRegionRequest

buildCloseRegionRequest

public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.CloseRegionRequest buildCloseRegionRequest(ServerName server,
                                                                                                byte[] regionName,
                                                                                                int versionOfClosingNode,
                                                                                                ServerName destinationServer,
                                                                                                boolean transitionInZK)

buildCloseRegionRequest

public 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

参数:

encodedRegionName - the name of the region to close

transitionInZK - indicator if to transition in ZK

返回:

a CloseRegionRequest

buildSplitRegionRequest

public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.SplitRegionRequest buildSplitRegionRequest(byte[] regionName,
                                                                                                byte[] splitPoint)

Create a SplitRegionRequest for a given region name

参数:

regionName - the name of the region to split

splitPoint - the split point

返回:

a SplitRegionRequest

buildMergeRegionsRequest

public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.MergeRegionsRequest buildMergeRegionsRequest(byte[] regionA,
                                                                                                  byte[] regionB,
                                                                                                  boolean forcible)

Create a MergeRegionsRequest for the given regions

参数:

regionA - name of region a

regionB - name of region b

forcible - true if it is a compulsory merge

返回:

a MergeRegionsRequest

buildCompactRegionRequest

public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.CompactRegionRequest buildCompactRegionRequest(byte[] regionName,
                                                                                                    boolean major,
                                                                                                    byte[] family)

Create a CompactRegionRequest for a given region name

参数:

regionName - the name of the region to get info

major - indicator if it is a major compaction

返回:

a CompactRegionRequest

buildRollWALWriterRequest

public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.RollWALWriterRequest buildRollWALWriterRequest()

Create a new RollWALWriterRequest

返回:

a ReplicateWALEntryRequest

buildGetServerInfoRequest

public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetServerInfoRequest buildGetServerInfoRequest()

Create a new GetServerInfoRequest

返回:

a GetServerInfoRequest

buildStopServerRequest

public static org.apache.hadoop.hbase.protobuf.generated.AdminProtos.StopServerRequest buildStopServerRequest(String reason)

Create a new StopServerRequest

参数:

reason - the reason to stop the server

返回:

a StopServerRequest

buildRegionSpecifier

public 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

参数:

type - the region specifier type

value - the region specifier byte array value

返回:

a protocol buffer RegionSpecifier

buildAddColumnRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.AddColumnRequest buildAddColumnRequest(org.apache.hadoop.hbase.TableName tableName,
                                                                                             HColumnDescriptor column)

Create a protocol buffer AddColumnRequest

参数:

tableName -

column -

返回:

an AddColumnRequest

buildDeleteColumnRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.DeleteColumnRequest buildDeleteColumnRequest(org.apache.hadoop.hbase.TableName tableName,
                                                                                                   byte[] columnName)

Create a protocol buffer DeleteColumnRequest

参数:

tableName -

columnName -

返回:

a DeleteColumnRequest

buildModifyColumnRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.ModifyColumnRequest buildModifyColumnRequest(org.apache.hadoop.hbase.TableName tableName,
                                                                                                   HColumnDescriptor column)

Create a protocol buffer ModifyColumnRequest

参数:

tableName -

column -

返回:

an ModifyColumnRequest

buildMoveRegionRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.MoveRegionRequest buildMoveRegionRequest(byte[] encodedRegionName,
                                                                                               byte[] destServerName)
                                                                                                        throws DeserializationException

Create a protocol buffer MoveRegionRequest

参数:

encodedRegionName -

destServerName -

返回:

A MoveRegionRequest

抛出:

DeserializationException

buildDispatchMergingRegionsRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.DispatchMergingRegionsRequest buildDispatchMergingRegionsRequest(byte[] encodedNameOfRegionA,
                                                                                                                       byte[] encodedNameOfRegionB,
                                                                                                                       boolean forcible)
                                                                                                                                throws DeserializationException

抛出:

DeserializationException

buildAssignRegionRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.AssignRegionRequest buildAssignRegionRequest(byte[] regionName)

Create a protocol buffer AssignRegionRequest

参数:

regionName -

返回:

an AssignRegionRequest

buildUnassignRegionRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.UnassignRegionRequest buildUnassignRegionRequest(byte[] regionName,
                                                                                                       boolean force)

Creates a protocol buffer UnassignRegionRequest

参数:

regionName -

force -

返回:

an UnassignRegionRequest

buildOfflineRegionRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.OfflineRegionRequest buildOfflineRegionRequest(byte[] regionName)

Creates a protocol buffer OfflineRegionRequest

参数:

regionName -

返回:

an OfflineRegionRequest

buildDeleteTableRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.DeleteTableRequest buildDeleteTableRequest(org.apache.hadoop.hbase.TableName tableName)

Creates a protocol buffer DeleteTableRequest

参数:

tableName -

返回:

a DeleteTableRequest

buildTruncateTableRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.TruncateTableRequest buildTruncateTableRequest(org.apache.hadoop.hbase.TableName tableName,
                                                                                                     boolean preserveSplits)

Creates a protocol buffer TruncateTableRequest

参数:

tableName - name of table to truncate

preserveSplits - True if the splits should be preserved

返回:

a TruncateTableRequest

buildEnableTableRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.EnableTableRequest buildEnableTableRequest(org.apache.hadoop.hbase.TableName tableName)

Creates a protocol buffer EnableTableRequest

参数:

tableName -

返回:

an EnableTableRequest

buildDisableTableRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.DisableTableRequest buildDisableTableRequest(org.apache.hadoop.hbase.TableName tableName)

Creates a protocol buffer DisableTableRequest

参数:

tableName -

返回:

a DisableTableRequest

buildCreateTableRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.CreateTableRequest buildCreateTableRequest(HTableDescriptor hTableDesc,
                                                                                                 byte[][] splitKeys)

Creates a protocol buffer CreateTableRequest

参数:

hTableDesc -

splitKeys -

返回:

a CreateTableRequest

buildModifyTableRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.ModifyTableRequest buildModifyTableRequest(org.apache.hadoop.hbase.TableName tableName,
                                                                                                 HTableDescriptor hTableDesc)

Creates a protocol buffer ModifyTableRequest

参数:

tableName -

hTableDesc -

返回:

a ModifyTableRequest

buildGetSchemaAlterStatusRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetSchemaAlterStatusRequest buildGetSchemaAlterStatusRequest(org.apache.hadoop.hbase.TableName tableName)

Creates a protocol buffer GetSchemaAlterStatusRequest

参数:

tableName -

返回:

a GetSchemaAlterStatusRequest

buildGetTableDescriptorsRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetTableDescriptorsRequest buildGetTableDescriptorsRequest(List<org.apache.hadoop.hbase.TableName> tableNames)

Creates a protocol buffer GetTableDescriptorsRequest

参数:

tableNames -

返回:

a GetTableDescriptorsRequest

buildGetTableDescriptorsRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetTableDescriptorsRequest buildGetTableDescriptorsRequest(Pattern pattern,
                                                                                                                 boolean includeSysTables)

Creates a protocol buffer GetTableDescriptorsRequest

参数:

pattern - The compiled regular expression to match against

includeSysTables - False to match only against userspace tables

返回:

a GetTableDescriptorsRequest

buildGetTableNamesRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetTableNamesRequest buildGetTableNamesRequest(Pattern pattern,
                                                                                                     boolean includeSysTables)

Creates a protocol buffer GetTableNamesRequest

参数:

pattern - The compiled regular expression to match against

includeSysTables - False to match only against userspace tables

返回:

a GetTableNamesRequest

buildGetTableDescriptorsRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetTableDescriptorsRequest buildGetTableDescriptorsRequest(org.apache.hadoop.hbase.TableName tableName)

Creates a protocol buffer GetTableDescriptorsRequest for a single table

参数:

tableName - the table name

返回:

a GetTableDescriptorsRequest

buildIsMasterRunningRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsMasterRunningRequest buildIsMasterRunningRequest()

Creates a protocol buffer IsMasterRunningRequest

返回:

a IsMasterRunningRequest

buildBalanceRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.BalanceRequest buildBalanceRequest()

Creates a protocol buffer BalanceRequest

返回:

a BalanceRequest

buildSetBalancerRunningRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.SetBalancerRunningRequest buildSetBalancerRunningRequest(boolean on,
                                                                                                               boolean synchronous)

Creates a protocol buffer SetBalancerRunningRequest

参数:

on -

synchronous -

返回:

a SetBalancerRunningRequest

buildGetClusterStatusRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.GetClusterStatusRequest buildGetClusterStatusRequest()

Creates a protocol buffer GetClusterStatusRequest

返回:

A GetClusterStatusRequest

buildCatalogScanRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.RunCatalogScanRequest buildCatalogScanRequest()

Creates a request for running a catalog scan

返回:

A MasterProtos.RunCatalogScanRequest

buildEnableCatalogJanitorRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.EnableCatalogJanitorRequest buildEnableCatalogJanitorRequest(boolean enable)

Creates a request for enabling/disabling the catalog janitor

返回:

A MasterProtos.EnableCatalogJanitorRequest

buildIsCatalogJanitorEnabledRequest

public static org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsCatalogJanitorEnabledRequest buildIsCatalogJanitorEnabledRequest()

Creates a request for querying the master whether the catalog janitor is enabled

返回:

A MasterProtos.IsCatalogJanitorEnabledRequest

buildGetLastFlushedSequenceIdRequest

public 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

参数:

regionName -

返回:

A RegionServerStatusProtos.GetLastFlushedSequenceIdRequest

buildGrantRequest

public static org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.GrantRequest buildGrantRequest(String username,
                                                                                            org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.Permission.Action... actions)

Create a request to grant user permissions.

参数:

username - the short user name who to grant permissions

actions - the permissions to be granted

返回:

A AccessControlProtos GrantRequest

buildGrantRequest

public static org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.GrantRequest buildGrantRequest(String username,
                                                                                            org.apache.hadoop.hbase.TableName tableName,
                                                                                            byte[] family,
                                                                                            byte[] qualifier,
                                                                                            org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.Permission.Action... actions)

Create a request to grant user permissions.

参数:

username - the short user name who to grant permissions

tableName - optional table name the permissions apply

family - optional column family

qualifier - optional qualifier

actions - the permissions to be granted

返回:

A AccessControlProtos GrantRequest

buildGrantRequest

public static org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.GrantRequest buildGrantRequest(String username,
                                                                                            String namespace,
                                                                                            org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.Permission.Action... actions)

Create a request to grant user permissions.

参数:

username - the short user name who to grant permissions

namespace - optional table name the permissions apply

actions - the permissions to be granted

返回:

A AccessControlProtos GrantRequest

buildRevokeRequest

public 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.

参数:

username - the short user name whose permissions to be revoked

actions - the permissions to be revoked

返回:

A AccessControlProtos RevokeRequest

buildRevokeRequest

public static org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.RevokeRequest buildRevokeRequest(String username,
                                                                                              org.apache.hadoop.hbase.TableName tableName,
                                                                                              byte[] family,
                                                                                              byte[] qualifier,
                                                                                              org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.Permission.Action... actions)

Create a request to revoke user permissions.

参数:

username - the short user name whose permissions to be revoked

tableName - optional table name the permissions apply

family - optional column family

qualifier - optional qualifier

actions - the permissions to be revoked

返回:

A AccessControlProtos RevokeRequest

buildRevokeRequest

public 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.

参数:

username - the short user name whose permissions to be revoked

namespace - optional table name the permissions apply

actions - the permissions to be revoked

返回:

A AccessControlProtos RevokeRequest