Uses of Interface
org.apache.hadoop.hbase.client.Connection

Packages that use org.apache.hadoop.hbase.client.Connection
Package
Description
org.apache.hadoop.hbase
 
org.apache.hadoop.hbase.backup
 
org.apache.hadoop.hbase.client
Provides HBase Client
org.apache.hadoop.hbase.client.example
 
org.apache.hadoop.hbase.coprocessor
Table of Contents
org.apache.hadoop.hbase.favored
 
org.apache.hadoop.hbase.mapred
Provides HBase MapReduce Input/OutputFormats, a table indexing MapReduce job, and utility methods.
org.apache.hadoop.hbase.mapreduce
Provides HBase MapReduce Input/OutputFormats, a table indexing MapReduce job, and utility methods.
org.apache.hadoop.hbase.master
 
org.apache.hadoop.hbase.namequeues
 
org.apache.hadoop.hbase.namequeues.impl
 
org.apache.hadoop.hbase.quotas
 
org.apache.hadoop.hbase.replication
Multi Cluster Replication
org.apache.hadoop.hbase.rsgroup
 
org.apache.hadoop.hbase.slowlog
 
org.apache.hadoop.hbase.snapshot
 
org.apache.hadoop.hbase.util
 
org.apache.hadoop.hbase.util.compaction
 
org.apache.hadoop.hbase.util.hbck
 

  • Uses of org.apache.hadoop.hbase.client.Connection in org.apache.hadoop.hbase

    Methods in org.apache.hadoop.hbase that return org.apache.hadoop.hbase.client.Connection in in
    Modifier and Type
    Method
    Description
    org.apache.hadoop.hbase.client.Connection
    HBaseServerBase.createConnection(org.apache.hadoop.conf.Configuration conf)
     
    org.apache.hadoop.hbase.client.Connection
    MockRegionServerServices.createConnection(org.apache.hadoop.conf.Configuration conf)
     
    org.apache.hadoop.hbase.client.Connection
    Server.createConnection(org.apache.hadoop.conf.Configuration conf)
     
    org.apache.hadoop.hbase.client.Connection
    HBaseTestingUtility.getConnection()
    Deprecated.
    Get a shared Connection to the cluster.
    org.apache.hadoop.hbase.client.Connection
    HBaseTestingUtility.getConnection(org.apache.hadoop.hbase.security.User user)
    Deprecated.
    Get a assigned Connection to the cluster.
    org.apache.hadoop.hbase.client.Connection
    MockRegionServerServices.getConnection()
     
    default org.apache.hadoop.hbase.client.Connection
    Server.getConnection()
    Returns a reference to the servers' connection.
    Methods in org.apache.hadoop.hbase with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier and Type
    Method
    Description
    static void
    MetaTableAccessor.addRegionsToMeta(org.apache.hadoop.hbase.client.Connection connection, List<org.apache.hadoop.hbase.client.RegionInfo> regionInfos, int regionReplication)
    Adds a hbase:meta row for each of the specified new regions.
    static void
    MetaTableAccessor.addRegionsToMeta(org.apache.hadoop.hbase.client.Connection connection, List<org.apache.hadoop.hbase.client.RegionInfo> regionInfos, int regionReplication, long ts)
    Adds a hbase:meta row for each of the specified new regions.
    static void
    MetaTableAccessor.addSplitsToParent(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.client.RegionInfo regionInfo, org.apache.hadoop.hbase.client.RegionInfo splitA, org.apache.hadoop.hbase.client.RegionInfo splitB)
    Adds daughter region infos to hbase:meta row for the specified region.
    static void
    MetaTableAccessor.deleteTableState(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.TableName table)
    Remove state for table from meta
    static void
    MetaTableAccessor.fullScanMetaAndPrint(org.apache.hadoop.hbase.client.Connection connection)
     
    static List<org.apache.hadoop.hbase.client.Result>
    MetaTableAccessor.fullScanRegions(org.apache.hadoop.hbase.client.Connection connection)
    Performs a full scan of hbase:meta for regions.
    static void
    MetaTableAccessor.fullScanRegions(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.ClientMetaTableAccessor.Visitor visitor)
    Performs a full scan of hbase:meta for regions.
    static void
    MetaTableAccessor.fullScanTables(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.ClientMetaTableAccessor.Visitor visitor)
    Performs a full scan of hbase:meta for tables.
    static List<org.apache.hadoop.hbase.client.RegionInfo>
    MetaTableAccessor.getAllRegions(org.apache.hadoop.hbase.client.Connection connection, boolean excludeOfflinedSplitParents)
    Lists all of the regions currently in META.
    static org.apache.hadoop.hbase.client.Result
    MetaTableAccessor.getCatalogFamilyRow(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.client.RegionInfo ri)
    Returns Return the HConstants.CATALOG_FAMILY row from hbase:meta.
    static org.apache.hadoop.hbase.client.Table
    MetaTableAccessor.getMetaHTable(org.apache.hadoop.hbase.client.Connection connection)
    Callers should call close on the returned Table instance.
    static int
    HBaseTestingUtility.getMetaRSPort(org.apache.hadoop.hbase.client.Connection connection)
    Deprecated.
     
    static org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.client.RegionInfo,org.apache.hadoop.hbase.ServerName>
    MetaTableAccessor.getRegion(org.apache.hadoop.hbase.client.Connection connection, byte[] regionName)
    Deprecated.
    use MetaTableAccessor.getRegionLocation(Connection, byte[]) instead
    static org.apache.hadoop.hbase.HRegionLocation
    MetaTableAccessor.getRegionLocation(org.apache.hadoop.hbase.client.Connection connection, byte[] regionName)
    Returns the HRegionLocation from meta for the given region
    static org.apache.hadoop.hbase.HRegionLocation
    MetaTableAccessor.getRegionLocation(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.client.RegionInfo regionInfo)
    Returns the HRegionLocation from meta for the given region
    static org.apache.hadoop.hbase.client.Result
    MetaTableAccessor.getRegionResult(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.client.RegionInfo regionInfo)
    Gets the result in hbase:meta for the specified region.
    static List<org.apache.hadoop.hbase.client.RegionInfo>
    MetaTableAccessor.getTableRegions(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.TableName tableName)
    Gets all of the regions of the specified table.
    static List<org.apache.hadoop.hbase.client.RegionInfo>
    MetaTableAccessor.getTableRegions(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.TableName tableName, boolean excludeOfflinedSplitParents)
    Gets all of the regions of the specified table.
    static List<org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.client.RegionInfo,org.apache.hadoop.hbase.ServerName>>
    MetaTableAccessor.getTableRegionsAndLocations(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.TableName tableName)
    Do not use this method to get meta table regions, use methods in MetaTableLocator instead.
    static List<org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.client.RegionInfo,org.apache.hadoop.hbase.ServerName>>
    MetaTableAccessor.getTableRegionsAndLocations(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.TableName tableName, boolean excludeOfflinedSplitParents)
    Do not use this method to get meta table regions, use methods in MetaTableLocator instead.
    static org.apache.hadoop.hbase.client.TableState
    MetaTableAccessor.getTableState(org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.hbase.TableName tableName)
    Fetch table state for given table from META table
    static Map<org.apache.hadoop.hbase.TableName,org.apache.hadoop.hbase.client.TableState>
    MetaTableAccessor.getTableStates(org.apache.hadoop.hbase.client.Connection conn)
    Fetch table states from META table
    static void
    MetaTableAccessor.putsToMetaTable(org.apache.hadoop.hbase.client.Connection connection, List<org.apache.hadoop.hbase.client.Put> ps)
    Put the passed ps to the hbase:meta table.
    static org.apache.hadoop.hbase.client.Result
    MetaTableAccessor.scanByRegionEncodedName(org.apache.hadoop.hbase.client.Connection connection, String regionEncodedName)
    Scans META table for a row whose key contains the specified regionEncodedName, returning a single related Result instance if any row is found, null otherwise.
    static void
    MetaTableAccessor.scanMeta(org.apache.hadoop.hbase.client.Connection connection, byte[] startRow, byte[] stopRow, org.apache.hadoop.hbase.ClientMetaTableAccessor.QueryType type, int maxRows, org.apache.hadoop.hbase.ClientMetaTableAccessor.Visitor visitor)
    Performs a scan of META table.
    static void
    MetaTableAccessor.scanMeta(org.apache.hadoop.hbase.client.Connection connection, byte[] startRow, byte[] stopRow, org.apache.hadoop.hbase.ClientMetaTableAccessor.QueryType type, org.apache.hadoop.hbase.ClientMetaTableAccessor.Visitor visitor)
     
    static void
    MetaTableAccessor.scanMeta(org.apache.hadoop.hbase.client.Connection connection, byte[] startRow, byte[] stopRow, org.apache.hadoop.hbase.ClientMetaTableAccessor.QueryType type, org.apache.hadoop.hbase.filter.Filter filter, int maxRows, org.apache.hadoop.hbase.ClientMetaTableAccessor.Visitor visitor)
     
    static void
    MetaTableAccessor.scanMeta(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.ClientMetaTableAccessor.Visitor visitor, org.apache.hadoop.hbase.TableName tableName, byte[] row, int rowLimit)
    Performs a scan of META table for given table starting from given row.
    static void
    MetaTableAccessor.scanMetaForTableRegions(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.ClientMetaTableAccessor.Visitor visitor, org.apache.hadoop.hbase.TableName tableName)
     
    static void
    MetaTableAccessor.updateRegionLocation(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.client.RegionInfo regionInfo, org.apache.hadoop.hbase.ServerName sn, long openSeqNum, long masterSystemTime)
    Updates the location of the specified region in hbase:meta to be the specified server hostname and startcode.
    static void
    MetaTableAccessor.updateRegionState(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.client.RegionInfo ri, org.apache.hadoop.hbase.master.RegionState.State state)
    Update state column in hbase:meta.
    static void
    MetaTableAccessor.updateTableState(org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.hbase.TableName tableName, org.apache.hadoop.hbase.client.TableState.State actual)
    Updates state in META Do not use.

  • Uses of org.apache.hadoop.hbase.client.Connection in org.apache.hadoop.hbase.backup

    Methods in org.apache.hadoop.hbase.backup with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier and Type
    Method
    Description
    static org.apache.hadoop.hbase.backup.impl.TableBackupClient
    BackupClientFactory.create(org.apache.hadoop.hbase.client.Connection conn, String backupId, org.apache.hadoop.hbase.backup.BackupRequest request)
     

  • Uses of org.apache.hadoop.hbase.client.Connection in org.apache.hadoop.hbase.client

    Classes in org.apache.hadoop.hbase.client that implement org.apache.hadoop.hbase.client.Connection in in
    Modifier and Type
    Class
    Description
    class 
    org.apache.hadoop.hbase.client.SharedConnection
    Wraps a Connection to make it can't be closed or aborted.
    Methods in org.apache.hadoop.hbase.client that return org.apache.hadoop.hbase.client.Connection in in
    Modifier and Type
    Method
    Description
    static org.apache.hadoop.hbase.client.Connection
    ConnectionFactory.createConnection()
    Create a new Connection instance using default HBaseConfiguration.
    static org.apache.hadoop.hbase.client.Connection
    ConnectionFactory.createConnection(URI connectionUri)
    Create a new Connection instance using default HBaseConfiguration.
    static org.apache.hadoop.hbase.client.Connection
    ConnectionFactory.createConnection(URI connectionUri, org.apache.hadoop.conf.Configuration conf)
    Create a new Connection instance using the passed conf instance.
    static org.apache.hadoop.hbase.client.Connection
    ConnectionFactory.createConnection(URI connectionUri, org.apache.hadoop.conf.Configuration conf, ExecutorService pool)
    Create a new Connection instance using the passed conf instance.
    static org.apache.hadoop.hbase.client.Connection
    ConnectionFactory.createConnection(URI connectionUri, org.apache.hadoop.conf.Configuration conf, ExecutorService pool, org.apache.hadoop.hbase.security.User user)
    Create a new Connection instance using the passed conf instance.
    static org.apache.hadoop.hbase.client.Connection
    ConnectionFactory.createConnection(URI connectionUri, org.apache.hadoop.conf.Configuration conf, ExecutorService pool, org.apache.hadoop.hbase.security.User user, Map<String,byte[]> connectionAttributes)
    Create a new Connection instance using the passed conf instance.
    static org.apache.hadoop.hbase.client.Connection
    ConnectionFactory.createConnection(URI connectionUri, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.security.User user)
    Create a new Connection instance using the passed conf instance.
    static org.apache.hadoop.hbase.client.Connection
    ConnectionFactory.createConnection(org.apache.hadoop.conf.Configuration conf)
    Create a new Connection instance using the passed conf instance.
    static org.apache.hadoop.hbase.client.Connection
    ConnectionFactory.createConnection(org.apache.hadoop.conf.Configuration conf, ExecutorService pool)
    Create a new Connection instance using the passed conf instance.
    static org.apache.hadoop.hbase.client.Connection
    ConnectionFactory.createConnection(org.apache.hadoop.conf.Configuration conf, ExecutorService pool, org.apache.hadoop.hbase.security.User user)
    Create a new Connection instance using the passed conf instance.
    static org.apache.hadoop.hbase.client.Connection
    ConnectionFactory.createConnection(org.apache.hadoop.conf.Configuration conf, ExecutorService pool, org.apache.hadoop.hbase.security.User user, Map<String,byte[]> connectionAttributes)
    Create a new Connection instance using the passed conf instance.
    static org.apache.hadoop.hbase.client.Connection
    ConnectionFactory.createConnection(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.security.User user)
    Create a new Connection instance using the passed conf instance.
    org.apache.hadoop.hbase.client.Connection
    Admin.getConnection()
    Returns Connection used by this object.
    org.apache.hadoop.hbase.client.Connection
    AsyncConnection.toConnection()
    Convert this connection to a Connection.
    org.apache.hadoop.hbase.client.Connection
    AsyncConnectionImpl.toConnection()
     
    org.apache.hadoop.hbase.client.Connection
    SharedAsyncConnection.toConnection()
     
    Constructors in org.apache.hadoop.hbase.client with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier
    Constructor
    Description
     
    SharedConnection(org.apache.hadoop.hbase.client.Connection conn)
     

  • Uses of org.apache.hadoop.hbase.client.Connection in org.apache.hadoop.hbase.client.example

    Constructors in org.apache.hadoop.hbase.client.example with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier
    Constructor
    Description
     
    ReadExampleCallable(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.TableName tableName)
     
     
    SingleWriteExampleCallable(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.TableName tableName)
     
     
    WriteExampleCallable(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.TableName tableName)
     

  • Uses of org.apache.hadoop.hbase.client.Connection in org.apache.hadoop.hbase.coprocessor

    Methods in org.apache.hadoop.hbase.coprocessor that return org.apache.hadoop.hbase.client.Connection in in
    Modifier and Type
    Method
    Description
    org.apache.hadoop.hbase.client.Connection
    MasterCoprocessorEnvironment.createConnection(org.apache.hadoop.conf.Configuration conf)
    Creates a cluster connection using the passed Configuration.
    org.apache.hadoop.hbase.client.Connection
    RegionCoprocessorEnvironment.createConnection(org.apache.hadoop.conf.Configuration conf)
    Creates a cluster connection using the passed Configuration.
    org.apache.hadoop.hbase.client.Connection
    RegionServerCoprocessorEnvironment.createConnection(org.apache.hadoop.conf.Configuration conf)
    Creates a cluster connection using the passed Configuration.
    org.apache.hadoop.hbase.client.Connection
    MasterCoprocessorEnvironment.getConnection()
    Returns the hosts' Connection to the Cluster.
    org.apache.hadoop.hbase.client.Connection
    RegionCoprocessorEnvironment.getConnection()
    Returns the hosts' Connection to the Cluster.
    org.apache.hadoop.hbase.client.Connection
    RegionServerCoprocessorEnvironment.getConnection()
    Returns the hosts' Connection to the Cluster.

  • Uses of org.apache.hadoop.hbase.client.Connection in org.apache.hadoop.hbase.favored

    Methods in org.apache.hadoop.hbase.favored with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier and Type
    Method
    Description
    static void
    FavoredNodeAssignmentHelper.updateMetaWithFavoredNodesInfo(Map<org.apache.hadoop.hbase.client.RegionInfo,List<org.apache.hadoop.hbase.ServerName>> regionToFavoredNodes, org.apache.hadoop.hbase.client.Connection connection)
    Update meta table with favored nodes info

  • Uses of org.apache.hadoop.hbase.client.Connection in org.apache.hadoop.hbase.mapred

    Methods in org.apache.hadoop.hbase.mapred with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier and Type
    Method
    Description
    protected void
    TableInputFormatBase.initializeTable(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.TableName tableName)
    Allows subclasses to initialize the table information.

  • Uses of org.apache.hadoop.hbase.client.Connection in org.apache.hadoop.hbase.mapreduce

    Methods in org.apache.hadoop.hbase.mapreduce with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier and Type
    Method
    Description
    protected void
    TableInputFormatBase.initializeTable(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.TableName tableName)
    Allows subclasses to initialize the table information.

  • Uses of org.apache.hadoop.hbase.client.Connection in org.apache.hadoop.hbase.master

    Methods in org.apache.hadoop.hbase.master with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier and Type
    Method
    Description
    static void
    TableNamespaceManager.insertNamespaceToMeta(org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.hbase.NamespaceDescriptor ns)
     
    Constructors in org.apache.hadoop.hbase.master with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier
    Constructor
    Description
     
    SnapshotOfRegionAssignmentFromMeta(org.apache.hadoop.hbase.client.Connection connection)
     
     
    SnapshotOfRegionAssignmentFromMeta(org.apache.hadoop.hbase.client.Connection connection, Set<org.apache.hadoop.hbase.TableName> disabledTables, boolean excludeOfflinedSplitParents)
     

  • Uses of org.apache.hadoop.hbase.client.Connection in org.apache.hadoop.hbase.namequeues

    Methods in org.apache.hadoop.hbase.namequeues with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier and Type
    Method
    Description
    void
    SlowLogPersistentService.addAllLogsToSysTable(org.apache.hadoop.hbase.client.Connection connection)
    Poll from queueForSysTable and insert 100 records in hbase:slowlog table in single batch
    static void
    WALEventTrackerTableAccessor.addWalEventTrackerRows(Queue<org.apache.hadoop.hbase.namequeues.WALEventTrackerPayload> walEventPayloads, org.apache.hadoop.hbase.client.Connection connection)
    Add wal event tracker rows to hbase:waleventtracker table
    void
    NamedQueueRecorder.persistAll(org.apache.hadoop.hbase.namequeues.NamedQueuePayload.NamedQueueEvent namedQueueEvent, org.apache.hadoop.hbase.client.Connection connection)
    Add all in memory queue records to system table.
    void
    NamedQueueService.persistAll(org.apache.hadoop.hbase.client.Connection connection)
    Add all in memory queue records to system table.
    void
    WALEventTrackerQueueService.persistAll(org.apache.hadoop.hbase.client.Connection connection)
     
    Constructors in org.apache.hadoop.hbase.namequeues with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier
    Constructor
    Description
     
    NamedQueueServiceChore(org.apache.hadoop.hbase.Stoppable stopper, int period, org.apache.hadoop.hbase.namequeues.NamedQueueRecorder namedQueueRecorder, org.apache.hadoop.hbase.client.Connection connection)
    Chore Constructor

  • Uses of org.apache.hadoop.hbase.client.Connection in org.apache.hadoop.hbase.namequeues.impl

    Methods in org.apache.hadoop.hbase.namequeues.impl with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier and Type
    Method
    Description
    void
    BalancerDecisionQueueService.persistAll(org.apache.hadoop.hbase.client.Connection connection)
     
    void
    BalancerRejectionQueueService.persistAll(org.apache.hadoop.hbase.client.Connection connection)
     
    void
    SlowLogQueueService.persistAll(org.apache.hadoop.hbase.client.Connection connection)
    Add all slowLog events to system table.

  • Uses of org.apache.hadoop.hbase.client.Connection in org.apache.hadoop.hbase.quotas

    Methods in org.apache.hadoop.hbase.quotas with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier and Type
    Method
    Description
    static void
    QuotaUtil.addNamespaceQuota(org.apache.hadoop.hbase.client.Connection connection, String namespace, org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas data)
     
    static void
    QuotaUtil.addRegionServerQuota(org.apache.hadoop.hbase.client.Connection connection, String regionServer, org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas data)
     
    static void
    QuotaUtil.addTableQuota(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.TableName table, org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas data)
     
    static void
    QuotaUtil.addUserQuota(org.apache.hadoop.hbase.client.Connection connection, String user, String namespace, org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas data)
     
    static void
    QuotaUtil.addUserQuota(org.apache.hadoop.hbase.client.Connection connection, String user, org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas data)
     
    static void
    QuotaUtil.addUserQuota(org.apache.hadoop.hbase.client.Connection connection, String user, org.apache.hadoop.hbase.TableName table, org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas data)
     
    static void
    QuotaUtil.deleteNamespaceQuota(org.apache.hadoop.hbase.client.Connection connection, String namespace)
     
    static void
    QuotaUtil.deleteRegionServerQuota(org.apache.hadoop.hbase.client.Connection connection, String regionServer)
     
    static void
    QuotaUtil.deleteTableQuota(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.TableName table)
     
    static void
    QuotaUtil.deleteUserQuota(org.apache.hadoop.hbase.client.Connection connection, String user)
     
    static void
    QuotaUtil.deleteUserQuota(org.apache.hadoop.hbase.client.Connection connection, String user, String namespace)
     
    static void
    QuotaUtil.deleteUserQuota(org.apache.hadoop.hbase.client.Connection connection, String user, org.apache.hadoop.hbase.TableName table)
     
    static void
    QuotaUtil.disableTableIfNotDisabled(org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.hbase.TableName tableName)
    Method to disable a table, if not already disabled.
    protected static org.apache.hadoop.hbase.client.Result[]
    QuotaTableUtil.doGet(org.apache.hadoop.hbase.client.Connection connection, List<org.apache.hadoop.hbase.client.Get> gets)
     
    protected static org.apache.hadoop.hbase.client.Result
    QuotaTableUtil.doGet(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.client.Get get)
     
    static void
    QuotaUtil.enableTableIfNotEnabled(org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.hbase.TableName tableName)
    Method to enable a table, if not already enabled.
    static <K> Map<K,org.apache.hadoop.hbase.quotas.QuotaState>
    QuotaUtil.fetchGlobalQuotas(String type, org.apache.hadoop.hbase.client.Connection connection, List<org.apache.hadoop.hbase.client.Get> gets, org.apache.hadoop.hbase.quotas.QuotaUtil.KeyFromRow<K> kfr)
     
    static Map<String,org.apache.hadoop.hbase.quotas.QuotaState>
    QuotaUtil.fetchNamespaceQuotas(org.apache.hadoop.hbase.client.Connection connection, List<org.apache.hadoop.hbase.client.Get> gets, double factor)
     
    static Map<String,org.apache.hadoop.hbase.quotas.QuotaState>
    QuotaUtil.fetchRegionServerQuotas(org.apache.hadoop.hbase.client.Connection connection, List<org.apache.hadoop.hbase.client.Get> gets)
     
    static Map<org.apache.hadoop.hbase.TableName,org.apache.hadoop.hbase.quotas.QuotaState>
    QuotaUtil.fetchTableQuotas(org.apache.hadoop.hbase.client.Connection connection, List<org.apache.hadoop.hbase.client.Get> gets, Map<org.apache.hadoop.hbase.TableName,Double> tableMachineFactors)
     
    static Map<String,org.apache.hadoop.hbase.quotas.UserQuotaState>
    QuotaUtil.fetchUserQuotas(org.apache.hadoop.hbase.client.Connection connection, List<org.apache.hadoop.hbase.client.Get> gets, Map<org.apache.hadoop.hbase.TableName,Double> tableMachineQuotaFactors, double factor)
     
    org.apache.hadoop.hbase.quotas.FileArchiverNotifier
    FileArchiverNotifierFactory.get(org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.hbase.TableName tn)
    Creates or obtains a FileArchiverNotifier instance for the given args.
    org.apache.hadoop.hbase.quotas.FileArchiverNotifier
    FileArchiverNotifierFactoryImpl.get(org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.hbase.TableName tn)
    Returns the FileArchiverNotifier instance for the given TableName.
    static org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot
    QuotaTableUtil.getCurrentSnapshotFromQuotaTable(org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.hbase.TableName tableName)
    Returns the current space quota snapshot of the given tableName from QuotaTableUtil.QUOTA_TABLE_NAME or null if the no quota information is available for that tableName.
    static org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas
    QuotaTableUtil.getNamespaceQuota(org.apache.hadoop.hbase.client.Connection connection, String namespace)
     
    static Set<String>
    QuotaTableUtil.getNamespaceSnapshots(org.apache.hadoop.hbase.client.Connection conn)
    Returns a set of the names of all namespaces containing snapshot entries.
    static Map<String,Long>
    QuotaTableUtil.getObservedSnapshotSizes(org.apache.hadoop.hbase.client.Connection conn)
    Fetches any persisted HBase snapshot sizes stored in the quota table.
    static org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas
    QuotaTableUtil.getRegionServerQuota(org.apache.hadoop.hbase.client.Connection connection, String regionServer)
     
    static Map<org.apache.hadoop.hbase.TableName,org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot>
    QuotaTableUtil.getSnapshots(org.apache.hadoop.hbase.client.Connection conn)
    Fetches all SpaceQuotaSnapshot objects from the hbase:quota table.
    static org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas
    QuotaTableUtil.getTableQuota(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.TableName table)
     
    static org.apache.hbase.thirdparty.com.google.common.collect.Multimap<org.apache.hadoop.hbase.TableName,String>
    QuotaTableUtil.getTableSnapshots(org.apache.hadoop.hbase.client.Connection conn)
    Returns a multimap for all existing table snapshot entries.
    static org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas
    QuotaTableUtil.getUserQuota(org.apache.hadoop.hbase.client.Connection connection, String user)
     
    static org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas
    QuotaTableUtil.getUserQuota(org.apache.hadoop.hbase.client.Connection connection, String user, String namespace)
     
    static org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas
    QuotaTableUtil.getUserQuota(org.apache.hadoop.hbase.client.Connection connection, String user, org.apache.hadoop.hbase.TableName table)
     
    void
    SpaceQuotaSnapshotNotifier.initialize(org.apache.hadoop.hbase.client.Connection conn)
    Initializes the notifier.
    void
    TableSpaceQuotaSnapshotNotifier.initialize(org.apache.hadoop.hbase.client.Connection conn)
     
    protected static boolean
    QuotaUtil.isExceedThrottleQuotaEnabled(org.apache.hadoop.hbase.client.Connection connection)
     
    void
    MasterQuotaManager.processFileArchivals(org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.FileArchiveNotificationRequest request, org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs)
     
    protected static void
    QuotaUtil.switchExceedThrottleQuota(org.apache.hadoop.hbase.client.Connection connection, boolean exceedThrottleQuotaEnabled)
     
    Constructors in org.apache.hadoop.hbase.quotas with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier
    Constructor
    Description
     
    FileArchiverNotifierImpl(org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.hbase.TableName tn)
     
     
    NamespaceQuotaSnapshotStore(org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.hbase.quotas.QuotaObserverChore chore, Map<org.apache.hadoop.hbase.client.RegionInfo,Long> regionUsage)
     
     
    QuotaRetriever(org.apache.hadoop.hbase.client.Connection conn)
     
     
    QuotaRetriever(org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.hbase.client.Scan scan)
     
     
    QuotaRetriever(org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.hbase.quotas.QuotaFilter filter)
     
     
    SpaceQuotaRefresherChore(org.apache.hadoop.hbase.quotas.RegionServerSpaceQuotaManager manager, org.apache.hadoop.hbase.client.Connection conn)
     
     
    TableQuotaSnapshotStore(org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.hbase.quotas.QuotaObserverChore chore, Map<org.apache.hadoop.hbase.client.RegionInfo,Long> regionUsage)
     

  • Uses of org.apache.hadoop.hbase.client.Connection in org.apache.hadoop.hbase.replication

    Methods in org.apache.hadoop.hbase.replication with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier and Type
    Method
    Description
    static org.apache.hadoop.hbase.replication.ReplicationBarrierFamilyFormat.ReplicationBarrierResult
    ReplicationBarrierFamilyFormat.getReplicationBarrierResult(org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.hbase.TableName tableName, byte[] row, byte[] encodedRegionName)
     
    static long[]
    ReplicationBarrierFamilyFormat.getReplicationBarriers(org.apache.hadoop.hbase.client.Connection conn, byte[] regionName)
     
    static org.apache.hadoop.hbase.replication.ReplicationQueueStorage
    ReplicationStorageFactory.getReplicationQueueStorage(org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.conf.Configuration conf)
    Create a new ReplicationQueueStorage.
    static org.apache.hadoop.hbase.replication.ReplicationQueueStorage
    ReplicationStorageFactory.getReplicationQueueStorage(org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.TableName tableName)
    Create a new ReplicationQueueStorage.
    static List<org.apache.hadoop.hbase.util.Pair<String,Long>>
    ReplicationBarrierFamilyFormat.getTableEncodedRegionNameAndLastBarrier(org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.hbase.TableName tableName)
     
    static List<String>
    ReplicationBarrierFamilyFormat.getTableEncodedRegionNamesForSerialReplication(org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.hbase.TableName tableName)
     
    Constructors in org.apache.hadoop.hbase.replication with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier
    Constructor
    Description
     
    TableReplicationQueueStorage(org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.hbase.TableName tableName)
     

  • Uses of org.apache.hadoop.hbase.client.Connection in org.apache.hadoop.hbase.rsgroup

    Constructors in org.apache.hadoop.hbase.rsgroup with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier
    Constructor
    Description
     
    RSGroupAdminClient(org.apache.hadoop.hbase.client.Connection conn)
    Deprecated.
     

  • Uses of org.apache.hadoop.hbase.client.Connection in org.apache.hadoop.hbase.slowlog

    Methods in org.apache.hadoop.hbase.slowlog with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier and Type
    Method
    Description
    static void
    SlowLogTableAccessor.addSlowLogRecords(List<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload> slowLogPayloads, org.apache.hadoop.hbase.client.Connection connection)
    Add slow/large log records to hbase:slowlog table

  • Uses of org.apache.hadoop.hbase.client.Connection in org.apache.hadoop.hbase.snapshot

    Methods in org.apache.hadoop.hbase.snapshot with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier and Type
    Method
    Description
    void
    RestoreSnapshotHelper.RestoreMetaChanges.updateMetaParentRegions(org.apache.hadoop.hbase.client.Connection connection, List<org.apache.hadoop.hbase.client.RegionInfo> regionInfos)
     

  • Uses of org.apache.hadoop.hbase.client.Connection in org.apache.hadoop.hbase.util

    Fields in org.apache.hadoop.hbase.util declared as org.apache.hadoop.hbase.client.Connection in in
    Modifier and Type
    Field
    Description
    protected final org.apache.hadoop.hbase.client.Connection
    MultiThreadedAction.connection
     
    Methods in org.apache.hadoop.hbase.util with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier and Type
    Method
    Description
    static void
    HBaseFsckRepair.closeRegionSilentlyAndWait(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.ServerName server, org.apache.hadoop.hbase.client.RegionInfo region)
    Contacts a region server and waits up to hbase.hbck.close.timeout ms (default 120s) to close the region.
    static void
    HBaseFsckRepair.fixMultiAssignment(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.client.RegionInfo region, List<org.apache.hadoop.hbase.ServerName> servers)
    Fix multiple assignment by doing silent closes on each RS hosting the region and then force ZK unassigned node to OFFLINE to trigger assignment by master.

  • Uses of org.apache.hadoop.hbase.client.Connection in org.apache.hadoop.hbase.util.compaction

    Fields in org.apache.hadoop.hbase.util.compaction declared as org.apache.hadoop.hbase.client.Connection in in
    Modifier and Type
    Field
    Description
    protected final org.apache.hadoop.hbase.client.Connection
    MajorCompactionRequest.connection
     
    protected org.apache.hadoop.hbase.client.Connection
    MajorCompactor.connection
     

  • Uses of org.apache.hadoop.hbase.client.Connection in org.apache.hadoop.hbase.util.hbck

    Constructors in org.apache.hadoop.hbase.util.hbck with parameters of type org.apache.hadoop.hbase.client.Connection in in
    Modifier
    Constructor
    Description
     
    ReplicationChecker(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.zookeeper.ZKWatcher zkw, org.apache.hadoop.hbase.client.Connection conn, org.apache.hadoop.hbase.util.HbckErrorReporter errorReporter)