Modifier and Type | Method and Description |
---|---|
TableDescriptor |
HBaseTestingUtility.createTableDescriptor(TableName name)
Deprecated.
Create a table of name
name . |
TableDescriptor |
HBaseTestingUtility.createTableDescriptor(TableName tableName,
byte[] family)
Deprecated.
|
TableDescriptor |
HBaseTestingUtility.createTableDescriptor(TableName tableName,
byte[][] families,
int maxVersions)
Deprecated.
|
TableDescriptor |
HBaseTestingUtility.createTableDescriptor(TableName name,
int minVersions,
int versions,
int ttl,
KeepDeletedCells keepDeleted)
Deprecated.
|
TableDescriptor |
TableDescriptors.get(TableName tableName)
Returns TableDescriptor for tablename
|
TableDescriptor |
TableDescriptors.remove(TableName tablename)
Returns Instance of table descriptor or null if none found.
|
Modifier and Type | Method and Description |
---|---|
Map<String,TableDescriptor> |
TableDescriptors.getAll()
Get Map of all TableDescriptors.
|
Map<String,TableDescriptor> |
TableDescriptors.getByNamespace(String name)
Get Map of all NamespaceDescriptors for a given namespace.
|
Modifier and Type | Method and Description |
---|---|
HRegion |
HBaseTestingUtility.createLocalHRegion(RegionInfo info,
org.apache.hadoop.conf.Configuration conf,
TableDescriptor desc,
WAL wal)
Deprecated.
Create an HRegion that writes to the local tmp dirs with specified wal
|
HRegion |
HBaseTestingUtility.createLocalHRegion(RegionInfo info,
TableDescriptor desc)
Deprecated.
Create an HRegion that writes to the local tmp dirs.
|
HRegion |
HBaseTestingUtility.createLocalHRegion(TableDescriptor desc,
byte[] startKey,
byte[] endKey)
Deprecated.
Create an HRegion that writes to the local tmp dirs
|
List<RegionInfo> |
HBaseTestingUtility.createMultiRegionsInMeta(org.apache.hadoop.conf.Configuration conf,
TableDescriptor htd,
byte[][] startKeys)
Deprecated.
Create rows in hbase:meta for regions of the specified table with the specified start keys.
|
static int |
HBaseTestingUtility.createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
TableDescriptor desc,
ColumnFamilyDescriptor hcd)
Deprecated.
Creates a pre-split table for load testing.
|
static int |
HBaseTestingUtility.createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
TableDescriptor desc,
ColumnFamilyDescriptor[] hcds,
int numRegionsPerServer)
Deprecated.
Creates a pre-split table for load testing.
|
static int |
HBaseTestingUtility.createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
TableDescriptor td,
ColumnFamilyDescriptor[] cds,
RegionSplitter.SplitAlgorithm splitter,
int numRegionsPerServer)
Deprecated.
Creates a pre-split table for load testing.
|
static int |
HBaseTestingUtility.createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
TableDescriptor desc,
ColumnFamilyDescriptor hcd,
int numRegionsPerServer)
Deprecated.
Creates a pre-split table for load testing.
|
static HRegion |
HBaseTestingUtility.createRegionAndWAL(RegionInfo info,
org.apache.hadoop.fs.Path rootDir,
org.apache.hadoop.conf.Configuration conf,
TableDescriptor htd)
Deprecated.
Create a region with it's own WAL.
|
static HRegion |
HBaseTestingUtility.createRegionAndWAL(RegionInfo info,
org.apache.hadoop.fs.Path rootDir,
org.apache.hadoop.conf.Configuration conf,
TableDescriptor htd,
BlockCache blockCache)
Deprecated.
Create a region with it's own WAL.
|
static HRegion |
HBaseTestingUtility.createRegionAndWAL(RegionInfo info,
org.apache.hadoop.fs.Path rootDir,
org.apache.hadoop.conf.Configuration conf,
TableDescriptor htd,
boolean initialize)
Deprecated.
Create a region with it's own WAL.
|
static HRegion |
HBaseTestingUtility.createRegionAndWAL(RegionInfo info,
org.apache.hadoop.fs.Path rootDir,
org.apache.hadoop.conf.Configuration conf,
TableDescriptor htd,
MobFileCache mobFileCache)
Deprecated.
Create a region with it's own WAL.
|
Table |
HBaseTestingUtility.createTable(TableDescriptor htd,
byte[][] splitRows)
Deprecated.
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableDescriptor htd,
byte[][] families,
byte[][] splitKeys,
BloomType type,
int blockSize,
org.apache.hadoop.conf.Configuration c)
Deprecated.
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableDescriptor htd,
byte[][] families,
byte[][] splitKeys,
org.apache.hadoop.conf.Configuration c)
Deprecated.
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableDescriptor htd,
byte[][] families,
org.apache.hadoop.conf.Configuration c)
Deprecated.
Create a table.
|
static void |
HBaseTestingUtility.modifyTableSync(Admin admin,
TableDescriptor desc)
Deprecated.
since 3.0.0 and will be removed in 4.0.0. Just use
Admin.modifyTable(TableDescriptor) directly as it is synchronous now. |
default void |
TableDescriptors.update(TableDescriptor htd)
Add or update descriptor.
|
void |
TableDescriptors.update(TableDescriptor htd,
boolean cacheOnly)
Add or update descriptor
|
void |
HBaseTestingUtility.verifyTableDescriptorIgnoreTableName(TableDescriptor ltd,
TableDescriptor rtd)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static TableDescriptor |
BackupSystemTable.getSystemTableDescriptor(org.apache.hadoop.conf.Configuration conf)
Get backup system table descriptor
|
static TableDescriptor |
BackupSystemTable.getSystemTableForBulkLoadedDataDescriptor(org.apache.hadoop.conf.Configuration conf)
Get backup system table descriptor
|
Modifier and Type | Method and Description |
---|---|
private void |
BackupSystemTable.createSystemTable(Admin admin,
TableDescriptor descriptor) |
Modifier and Type | Method and Description |
---|---|
(package private) TableDescriptor |
RestoreTool.getTableDesc(TableName tableName)
Get table descriptor
|
private TableDescriptor |
RestoreTool.getTableDescriptor(org.apache.hadoop.fs.FileSystem fileSys,
TableName tableName,
String lastIncrBackupId) |
Modifier and Type | Method and Description |
---|---|
private void |
RestoreTool.checkAndCreateTable(Connection conn,
TableName targetTableName,
ArrayList<org.apache.hadoop.fs.Path> regionDirList,
TableDescriptor htd,
boolean truncateIfExists)
Prepare the table for bulkload, most codes copied from
createTable method in
BulkLoadHFilesTool . |
(package private) void |
RestoreTool.modifyTableSync(Connection conn,
TableDescriptor desc) |
Modifier and Type | Class and Description |
---|---|
private static class |
TableDescriptorBuilder.ModifyableTableDescriptor |
Modifier and Type | Field and Description |
---|---|
private TableDescriptor |
TableSnapshotScanner.htd |
static TableDescriptor |
TableDescriptorBuilder.NAMESPACE_TABLEDESC
Deprecated.
since 3.0.0 and will be removed in 4.0.0. We have folded the data in namespace
table into meta table, so do not use it any more.
|
Modifier and Type | Field and Description |
---|---|
static Comparator<TableDescriptor> |
TableDescriptor.COMPARATOR |
static Comparator<TableDescriptor> |
TableDescriptor.COMPARATOR_IGNORE_REPLICATION |
Modifier and Type | Method and Description |
---|---|
TableDescriptor |
TableDescriptorBuilder.build() |
static TableDescriptor |
TableDescriptorBuilder.copy(TableDescriptor desc) |
static TableDescriptor |
TableDescriptorBuilder.copy(TableName name,
TableDescriptor desc) |
TableDescriptor |
Table.getDescriptor()
Gets the
table descriptor for this
table. |
TableDescriptor |
TableOverAsyncTable.getDescriptor() |
TableDescriptor |
Admin.getDescriptor(TableName tableName)
Get a table descriptor.
|
TableDescriptor |
AdminOverAsyncAdmin.getDescriptor(TableName tableName) |
static TableDescriptor |
TableDescriptorBuilder.parseFrom(byte[] pbBytes)
The input should be created by
TableDescriptorBuilder.toByteArray(org.apache.hadoop.hbase.client.TableDescriptor) . |
private static TableDescriptor |
TableDescriptorBuilder.ModifyableTableDescriptor.parseFrom(byte[] bytes) |
Modifier and Type | Method and Description |
---|---|
static Comparator<TableDescriptor> |
TableDescriptor.getComparator(Comparator<ColumnFamilyDescriptor> cfComparator) |
CompletableFuture<TableDescriptor> |
AsyncTableImpl.getDescriptor() |
CompletableFuture<TableDescriptor> |
AsyncTable.getDescriptor()
Gets the
TableDescriptor for this table. |
CompletableFuture<TableDescriptor> |
RawAsyncTableImpl.getDescriptor() |
CompletableFuture<TableDescriptor> |
AsyncAdmin.getDescriptor(TableName tableName)
Method for getting the tableDescriptor
|
CompletableFuture<TableDescriptor> |
RawAsyncHBaseAdmin.getDescriptor(TableName tableName) |
CompletableFuture<TableDescriptor> |
AsyncHBaseAdmin.getDescriptor(TableName tableName) |
private CompletableFuture<List<TableDescriptor>> |
RawAsyncHBaseAdmin.getTableDescriptors(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetTableDescriptorsRequest request) |
default CompletableFuture<List<TableDescriptor>> |
AsyncAdmin.listTableDescriptors()
List all the userspace tables.
|
List<TableDescriptor> |
Admin.listTableDescriptors()
List all the userspace tables.
|
List<TableDescriptor> |
AdminOverAsyncAdmin.listTableDescriptors() |
CompletableFuture<List<TableDescriptor>> |
AsyncAdmin.listTableDescriptors(boolean includeSysTables)
List all the tables.
|
CompletableFuture<List<TableDescriptor>> |
RawAsyncHBaseAdmin.listTableDescriptors(boolean includeSysTables) |
List<TableDescriptor> |
Admin.listTableDescriptors(boolean includeSysTables)
List all userspace tables and whether or not include system tables.
|
List<TableDescriptor> |
AdminOverAsyncAdmin.listTableDescriptors(boolean includeSysTables) |
CompletableFuture<List<TableDescriptor>> |
AsyncHBaseAdmin.listTableDescriptors(boolean includeSysTables) |
CompletableFuture<List<TableDescriptor>> |
AsyncAdmin.listTableDescriptors(List<TableName> tableNames)
List specific tables including system tables.
|
CompletableFuture<List<TableDescriptor>> |
RawAsyncHBaseAdmin.listTableDescriptors(List<TableName> tableNames) |
List<TableDescriptor> |
Admin.listTableDescriptors(List<TableName> tableNames)
Get tableDescriptors.
|
List<TableDescriptor> |
AdminOverAsyncAdmin.listTableDescriptors(List<TableName> tableNames) |
CompletableFuture<List<TableDescriptor>> |
AsyncHBaseAdmin.listTableDescriptors(List<TableName> tableNames) |
default List<TableDescriptor> |
Admin.listTableDescriptors(Pattern pattern)
List all the userspace tables that match the given pattern.
|
CompletableFuture<List<TableDescriptor>> |
AsyncAdmin.listTableDescriptors(Pattern pattern,
boolean includeSysTables)
List all the tables matching the given pattern.
|
CompletableFuture<List<TableDescriptor>> |
RawAsyncHBaseAdmin.listTableDescriptors(Pattern pattern,
boolean includeSysTables)
|
List<TableDescriptor> |
Admin.listTableDescriptors(Pattern pattern,
boolean includeSysTables)
List all the tables matching the given pattern.
|
List<TableDescriptor> |
AdminOverAsyncAdmin.listTableDescriptors(Pattern pattern,
boolean includeSysTables) |
CompletableFuture<List<TableDescriptor>> |
AsyncHBaseAdmin.listTableDescriptors(Pattern pattern,
boolean includeSysTables) |
List<TableDescriptor> |
Admin.listTableDescriptorsByNamespace(byte[] name)
Get list of table descriptors by namespace.
|
List<TableDescriptor> |
AdminOverAsyncAdmin.listTableDescriptorsByNamespace(byte[] name) |
CompletableFuture<List<TableDescriptor>> |
AsyncAdmin.listTableDescriptorsByNamespace(String name)
Get list of table descriptors by namespace.
|
CompletableFuture<List<TableDescriptor>> |
RawAsyncHBaseAdmin.listTableDescriptorsByNamespace(String name) |
CompletableFuture<List<TableDescriptor>> |
AsyncHBaseAdmin.listTableDescriptorsByNamespace(String name) |
CompletableFuture<List<TableDescriptor>> |
AsyncAdmin.listTableDescriptorsByState(boolean isEnabled)
List all enabled or disabled table descriptors
|
CompletableFuture<List<TableDescriptor>> |
RawAsyncHBaseAdmin.listTableDescriptorsByState(boolean isEnabled) |
List<TableDescriptor> |
Admin.listTableDescriptorsByState(boolean isEnabled)
List all enabled or disabled tables
|
List<TableDescriptor> |
AdminOverAsyncAdmin.listTableDescriptorsByState(boolean isEnabled) |
CompletableFuture<List<TableDescriptor>> |
AsyncHBaseAdmin.listTableDescriptorsByState(boolean isEnabled) |
Modifier and Type | Method and Description |
---|---|
private CompletableFuture<Void> |
RawAsyncHBaseAdmin.compareTableWithPeerCluster(TableName tableName,
TableDescriptor tableDesc,
ReplicationPeerDescription peer,
AsyncAdmin peerAdmin) |
static TableDescriptorUtils.TableDescriptorDelta |
TableDescriptorUtils.computeDelta(TableDescriptor oldTD,
TableDescriptor newTD)
Compares two
TableDescriptor and indicate which columns were added, deleted, or
modified from oldTD to newTD |
static TableDescriptor |
TableDescriptorBuilder.copy(TableDescriptor desc) |
static TableDescriptor |
TableDescriptorBuilder.copy(TableName name,
TableDescriptor desc) |
CompletableFuture<Void> |
AsyncAdmin.createTable(TableDescriptor desc)
Creates a new table.
|
CompletableFuture<Void> |
RawAsyncHBaseAdmin.createTable(TableDescriptor desc) |
default void |
Admin.createTable(TableDescriptor desc)
Creates a new table.
|
CompletableFuture<Void> |
AsyncHBaseAdmin.createTable(TableDescriptor desc) |
CompletableFuture<Void> |
AsyncAdmin.createTable(TableDescriptor desc,
byte[][] splitKeys)
Creates a new table with an initial set of empty regions defined by the specified split keys.
|
CompletableFuture<Void> |
RawAsyncHBaseAdmin.createTable(TableDescriptor desc,
byte[][] splitKeys) |
default void |
Admin.createTable(TableDescriptor desc,
byte[][] splitKeys)
Creates a new table with an initial set of empty regions defined by the specified split keys.
|
CompletableFuture<Void> |
AsyncHBaseAdmin.createTable(TableDescriptor desc,
byte[][] splitKeys) |
CompletableFuture<Void> |
AsyncAdmin.createTable(TableDescriptor desc,
byte[] startKey,
byte[] endKey,
int numRegions)
Creates a new table with the specified number of regions.
|
CompletableFuture<Void> |
RawAsyncHBaseAdmin.createTable(TableDescriptor desc,
byte[] startKey,
byte[] endKey,
int numRegions) |
void |
Admin.createTable(TableDescriptor desc,
byte[] startKey,
byte[] endKey,
int numRegions)
Creates a new table with the specified number of regions.
|
void |
AdminOverAsyncAdmin.createTable(TableDescriptor desc,
byte[] startKey,
byte[] endKey,
int numRegions) |
CompletableFuture<Void> |
AsyncHBaseAdmin.createTable(TableDescriptor desc,
byte[] startKey,
byte[] endKey,
int numRegions) |
Future<Void> |
Admin.createTableAsync(TableDescriptor desc)
Creates a new table but does not block and wait for it to come online.
|
Future<Void> |
AdminOverAsyncAdmin.createTableAsync(TableDescriptor desc) |
Future<Void> |
Admin.createTableAsync(TableDescriptor desc,
byte[][] splitKeys)
Creates a new table but does not block and wait for it to come online.
|
Future<Void> |
AdminOverAsyncAdmin.createTableAsync(TableDescriptor desc,
byte[][] splitKeys) |
default CompletableFuture<Void> |
AsyncAdmin.modifyTable(TableDescriptor desc)
Modify an existing table, more IRB friendly version.
|
CompletableFuture<Void> |
RawAsyncHBaseAdmin.modifyTable(TableDescriptor desc) |
default void |
Admin.modifyTable(TableDescriptor td)
Modify an existing table, more IRB friendly version.
|
CompletableFuture<Void> |
AsyncHBaseAdmin.modifyTable(TableDescriptor desc) |
CompletableFuture<Void> |
AsyncAdmin.modifyTable(TableDescriptor desc,
boolean reopenRegions)
Modify an existing table, more IRB friendly version.
|
CompletableFuture<Void> |
RawAsyncHBaseAdmin.modifyTable(TableDescriptor desc,
boolean reopenRegions) |
CompletableFuture<Void> |
AsyncHBaseAdmin.modifyTable(TableDescriptor desc,
boolean reopenRegions) |
default Future<Void> |
Admin.modifyTableAsync(TableDescriptor td)
Modify an existing table, more IRB (ruby) friendly version.
|
Future<Void> |
AdminOverAsyncAdmin.modifyTableAsync(TableDescriptor td) |
Future<Void> |
Admin.modifyTableAsync(TableDescriptor td,
boolean reopenRegions)
The same as
Admin.modifyTableAsync(TableDescriptor td) , except for the reopenRegions
parameter, which controls whether the process of modifying the table should reopen all regions. |
Future<Void> |
AdminOverAsyncAdmin.modifyTableAsync(TableDescriptor td,
boolean reopenRegions) |
static TableDescriptorBuilder |
TableDescriptorBuilder.newBuilder(TableDescriptor desc)
Copy all values, families, and name from the input.
|
static byte[] |
TableDescriptorBuilder.toByteArray(TableDescriptor desc)
Returns This instance serialized with pb with pb magic prefix
|
Constructor and Description |
---|
ClientSideRegionScanner(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path rootDir,
TableDescriptor htd,
RegionInfo hri,
Scan scan,
ScanMetrics scanMetrics) |
ModifyableTableDescriptor(TableDescriptor desc) |
ModifyableTableDescriptor(TableName name,
TableDescriptor desc)
Construct a table descriptor by cloning the descriptor passed as a parameter.
|
TableDescriptorBuilder(TableDescriptor desc) |
TableDescriptorDelta(TableDescriptor oldTD,
TableDescriptor newTD) |
Modifier and Type | Method and Description |
---|---|
static boolean |
Constraints.enabled(TableDescriptor desc,
Class<? extends Constraint> clazz)
Check to see if the given constraint is enabled.
|
(package private) static List<? extends Constraint> |
Constraints.getConstraints(TableDescriptor desc,
ClassLoader classloader)
Get the constraints stored in the table descriptor
|
private static Pair<String,String> |
Constraints.getKeyValueForClass(TableDescriptor desc,
Class<? extends Constraint> clazz)
Get the kv
Map.Entry in the descriptor for the specified class |
static boolean |
Constraints.has(TableDescriptor desc,
Class<? extends Constraint> clazz)
Check to see if the Constraint is currently set.
|
Modifier and Type | Method and Description |
---|---|
default TableDescriptor |
MasterObserver.preCreateTableRegionsInfos(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableDescriptor desc)
Called before we create the region infos for this table.
|
default TableDescriptor |
MasterObserver.preModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
TableDescriptor currentDescriptor,
TableDescriptor newDescriptor)
Called prior to modifying a table's properties.
|
Modifier and Type | Method and Description |
---|---|
default void |
MasterObserver.postCloneSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx,
SnapshotDescription snapshot,
TableDescriptor tableDescriptor)
Called after a snapshot clone operation has been requested.
|
default void |
MasterObserver.postCompletedCreateTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableDescriptor desc,
RegionInfo[] regions)
Called after the createTable operation has been requested.
|
default void |
MasterObserver.postCompletedModifyTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
TableDescriptor oldDescriptor,
TableDescriptor currentDescriptor)
Called after to modifying a table's properties.
|
default void |
MasterObserver.postCompletedSnapshotAction(ObserverContext<MasterCoprocessorEnvironment> ctx,
SnapshotDescription snapshot,
TableDescriptor tableDescriptor)
Called after the snapshot operation has been completed.
|
default void |
MasterObserver.postCreateTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableDescriptor desc,
RegionInfo[] regions)
Called after the createTable operation has been requested.
|
default void |
MasterObserver.postModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
TableDescriptor oldDescriptor,
TableDescriptor currentDescriptor)
Called after the modifyTable operation has been requested.
|
default void |
MasterObserver.postRestoreSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx,
SnapshotDescription snapshot,
TableDescriptor tableDescriptor)
Called after a snapshot restore operation has been requested.
|
default void |
MasterObserver.postSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx,
SnapshotDescription snapshot,
TableDescriptor tableDescriptor)
Called after the snapshot operation has been requested.
|
default void |
MasterObserver.preCloneSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx,
SnapshotDescription snapshot,
TableDescriptor tableDescriptor)
Called before a snapshot is cloned.
|
default void |
MasterObserver.preCreateTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableDescriptor desc,
RegionInfo[] regions)
Called before a new table is created by
HMaster . |
default void |
MasterObserver.preCreateTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableDescriptor desc,
RegionInfo[] regions)
Called before a new table is created by
HMaster . |
default TableDescriptor |
MasterObserver.preCreateTableRegionsInfos(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableDescriptor desc)
Called before we create the region infos for this table.
|
default TableDescriptor |
MasterObserver.preModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
TableDescriptor currentDescriptor,
TableDescriptor newDescriptor)
Called prior to modifying a table's properties.
|
default void |
MasterObserver.preModifyTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
TableDescriptor currentDescriptor,
TableDescriptor newDescriptor)
Called prior to modifying a table's properties.
|
default void |
MasterObserver.preRestoreSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx,
SnapshotDescription snapshot,
TableDescriptor tableDescriptor)
Called before a snapshot is restored.
|
default void |
MasterObserver.preSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx,
SnapshotDescription snapshot,
TableDescriptor tableDescriptor)
Called before a new snapshot is taken.
|
Modifier and Type | Method and Description |
---|---|
default void |
MasterObserver.postGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
List<TableName> tableNamesList,
List<TableDescriptor> descriptors,
String regex)
Called after a getTableDescriptors request has been processed.
|
default void |
MasterObserver.postGetTableNames(ObserverContext<MasterCoprocessorEnvironment> ctx,
List<TableDescriptor> descriptors,
String regex)
Called after a getTableNames request has been processed.
|
default void |
MasterObserver.preGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
List<TableName> tableNamesList,
List<TableDescriptor> descriptors,
String regex)
Called before a getTableDescriptors request has been processed.
|
default void |
MasterObserver.preGetTableNames(ObserverContext<MasterCoprocessorEnvironment> ctx,
List<TableDescriptor> descriptors,
String regex)
Called before a getTableNames request has been processed.
|
Modifier and Type | Method and Description |
---|---|
void |
ExampleMasterObserverWithMetrics.postCreateTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableDescriptor desc,
RegionInfo[] regions) |
void |
ExampleMasterObserverWithMetrics.preCreateTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableDescriptor desc,
RegionInfo[] regions) |
Modifier and Type | Method and Description |
---|---|
static boolean |
ErasureCodingUtils.needsSync(TableDescriptor oldDescriptor,
TableDescriptor newDescriptor)
Check if EC policy is different between two descriptors
|
static void |
ErasureCodingUtils.sync(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path rootDir,
TableDescriptor newDescriptor)
Sync the EC policy state from the newDescriptor onto the FS for the table dir of the provided
table descriptor.
|
Constructor and Description |
---|
TableSnapshotRegionSplit(TableDescriptor htd,
RegionInfo regionInfo,
List<String> locations,
Scan scan,
org.apache.hadoop.fs.Path restoreDir) |
Modifier and Type | Field and Description |
---|---|
private TableDescriptor |
TableSnapshotInputFormatImpl.InputSplit.htd |
private TableDescriptor |
HFileOutputFormat2.TableInfo.tableDesctiptor |
Modifier and Type | Method and Description |
---|---|
TableDescriptor |
TableSnapshotInputFormatImpl.InputSplit.getHtd() |
TableDescriptor |
HFileOutputFormat2.TableInfo.getTableDescriptor() |
TableDescriptor |
TableSnapshotInputFormatImpl.InputSplit.getTableDescriptor() |
Modifier and Type | Method and Description |
---|---|
private static List<String> |
TableSnapshotInputFormatImpl.calculateLocationsForInputSplit(org.apache.hadoop.conf.Configuration conf,
TableDescriptor htd,
RegionInfo hri,
org.apache.hadoop.fs.Path tableDir)
Compute block locations for snapshot files (which will get the locations for referred hfiles)
only when localityEnabled is true.
|
static void |
HFileOutputFormat2.configureIncrementalLoad(org.apache.hadoop.mapreduce.Job job,
TableDescriptor tableDescriptor,
RegionLocator regionLocator)
Configure a MapReduce Job to perform an incremental load into the given table.
|
static void |
HFileOutputFormat2.configureIncrementalLoadMap(org.apache.hadoop.mapreduce.Job job,
TableDescriptor tableDescriptor) |
Modifier and Type | Method and Description |
---|---|
(package private) static String |
HFileOutputFormat2.serializeColumnFamilyAttribute(Function<ColumnFamilyDescriptor,String> fn,
List<TableDescriptor> allTables) |
Constructor and Description |
---|
InputSplit(TableDescriptor htd,
RegionInfo regionInfo,
List<String> locations,
Scan scan,
org.apache.hadoop.fs.Path restoreDir) |
TableInfo(TableDescriptor tableDesctiptor,
RegionLocator regionLocator) |
TableSnapshotRegionSplit(TableDescriptor htd,
RegionInfo regionInfo,
List<String> locations,
Scan scan,
org.apache.hadoop.fs.Path restoreDir) |
Modifier and Type | Method and Description |
---|---|
TableDescriptor |
HMaster.TableDescriptorGetter.get() |
TableDescriptor |
MasterCoprocessorHost.preCreateTableRegionsInfos(TableDescriptor desc) |
TableDescriptor |
MasterCoprocessorHost.preModifyTable(TableName tableName,
TableDescriptor currentDescriptor,
TableDescriptor newDescriptor) |
Modifier and Type | Method and Description |
---|---|
private List<TableDescriptor> |
HMaster.getTableDescriptors(List<TableDescriptor> htds,
String namespace,
String regex,
List<TableName> tableNameList,
boolean includeSysTables)
Return a list of table table descriptors after applying any provided filter parameters.
|
List<TableDescriptor> |
HMaster.listTableDescriptors(String namespace,
String regex,
List<TableName> tableNameList,
boolean includeSysTables)
Returns the list of table descriptors that match the specified request
|
List<TableDescriptor> |
HMaster.listTableDescriptorsByNamespace(String name) |
List<TableDescriptor> |
MasterServices.listTableDescriptorsByNamespace(String name)
Get list of table descriptors by namespace
|
Modifier and Type | Method and Description |
---|---|
private void |
HMaster.createMissingCFsInMetaDuringUpgrade(TableDescriptor metaDescriptor) |
long |
HMaster.createSystemTable(TableDescriptor tableDescriptor) |
long |
MasterServices.createSystemTable(TableDescriptor tableDescriptor)
Create a system table using the given table definition.
|
long |
HMaster.createTable(TableDescriptor tableDescriptor,
byte[][] splitKeys,
long nonceGroup,
long nonce) |
long |
MasterServices.createTable(TableDescriptor desc,
byte[][] splitKeys,
long nonceGroup,
long nonce)
Create a table using the given table definition.
|
default long |
MasterServices.modifyTable(TableName tableName,
TableDescriptor descriptor,
long nonceGroup,
long nonce)
Modify the descriptor of an existing table
|
long |
HMaster.modifyTable(TableName tableName,
TableDescriptor newDescriptor,
long nonceGroup,
long nonce,
boolean reopenRegions) |
long |
MasterServices.modifyTable(TableName tableName,
TableDescriptor descriptor,
long nonceGroup,
long nonce,
boolean reopenRegions)
Modify the descriptor of an existing table
|
void |
MasterCoprocessorHost.postCloneSnapshot(SnapshotDescription snapshot,
TableDescriptor hTableDescriptor) |
void |
MasterCoprocessorHost.postCompletedCreateTableAction(TableDescriptor htd,
RegionInfo[] regions,
User user) |
void |
MasterCoprocessorHost.postCompletedModifyTableAction(TableName tableName,
TableDescriptor oldDescriptor,
TableDescriptor currentDescriptor,
User user) |
void |
MasterCoprocessorHost.postCompletedSnapshotAction(SnapshotDescription snapshot,
TableDescriptor hTableDescriptor) |
void |
MasterCoprocessorHost.postCreateTable(TableDescriptor htd,
RegionInfo[] regions) |
void |
MasterCoprocessorHost.postModifyTable(TableName tableName,
TableDescriptor oldDescriptor,
TableDescriptor currentDescriptor) |
void |
MasterCoprocessorHost.postRestoreSnapshot(SnapshotDescription snapshot,
TableDescriptor hTableDescriptor) |
void |
MasterCoprocessorHost.postSnapshot(SnapshotDescription snapshot,
TableDescriptor hTableDescriptor,
User user) |
void |
MasterCoprocessorHost.preCloneSnapshot(SnapshotDescription snapshot,
TableDescriptor hTableDescriptor) |
void |
MasterCoprocessorHost.preCreateTable(TableDescriptor htd,
RegionInfo[] regions) |
void |
MasterCoprocessorHost.preCreateTableAction(TableDescriptor htd,
RegionInfo[] regions,
User user) |
TableDescriptor |
MasterCoprocessorHost.preCreateTableRegionsInfos(TableDescriptor desc) |
TableDescriptor |
MasterCoprocessorHost.preModifyTable(TableName tableName,
TableDescriptor currentDescriptor,
TableDescriptor newDescriptor) |
void |
MasterCoprocessorHost.preModifyTableAction(TableName tableName,
TableDescriptor currentDescriptor,
TableDescriptor newDescriptor,
User user) |
void |
MasterCoprocessorHost.preRestoreSnapshot(SnapshotDescription snapshot,
TableDescriptor hTableDescriptor) |
void |
MasterCoprocessorHost.preSnapshot(SnapshotDescription snapshot,
TableDescriptor hTableDescriptor,
User user) |
Modifier and Type | Method and Description |
---|---|
private static void |
HMaster.filterTablesByRegex(Collection<TableDescriptor> descriptors,
Pattern pattern)
Removes the table descriptors that don't match the pattern.
|
private List<TableDescriptor> |
HMaster.getTableDescriptors(List<TableDescriptor> htds,
String namespace,
String regex,
List<TableName> tableNameList,
boolean includeSysTables)
Return a list of table table descriptors after applying any provided filter parameters.
|
void |
MasterCoprocessorHost.postGetTableDescriptors(List<TableName> tableNamesList,
List<TableDescriptor> descriptors,
String regex) |
void |
MasterCoprocessorHost.postGetTableNames(List<TableDescriptor> descriptors,
String regex) |
void |
MasterCoprocessorHost.preGetTableDescriptors(List<TableName> tableNamesList,
List<TableDescriptor> descriptors,
String regex) |
void |
MasterCoprocessorHost.preGetTableNames(List<TableDescriptor> descriptors,
String regex) |
Modifier and Type | Method and Description |
---|---|
private TableDescriptor |
RegionStateStore.getDescriptor(TableName tableName) |
Modifier and Type | Method and Description |
---|---|
private int |
RegionStateStore.getRegionReplication(TableDescriptor htd) |
private boolean |
RegionStateStore.hasGlobalReplicationScope(TableDescriptor htd) |
void |
RegionStateStore.mergeRegions(RegionInfo child,
RegionInfo[] parents,
ServerName serverName,
TableDescriptor htd) |
void |
RegionStateStore.splitRegion(RegionInfo parent,
RegionInfo splitA,
RegionInfo splitB,
ServerName serverName,
TableDescriptor htd)
Splits the region into two in an atomic operation.
|
Modifier and Type | Method and Description |
---|---|
private TableDescriptor |
RegionHDFSBlockLocationFinder.getDescriptor(TableName tableName)
return TableDescriptor for a given tableName
|
TableDescriptor |
ClusterInfoProvider.getTableDescriptor(TableName tableName)
Get the table descriptor for the given table.
|
TableDescriptor |
MasterClusterInfoProvider.getTableDescriptor(TableName tableName) |
Modifier and Type | Method and Description |
---|---|
HDFSBlocksDistribution |
ClusterInfoProvider.computeHDFSBlocksDistribution(org.apache.hadoop.conf.Configuration conf,
TableDescriptor tableDescriptor,
RegionInfo regionInfo)
Compute the block distribution for the given region.
|
HDFSBlocksDistribution |
MasterClusterInfoProvider.computeHDFSBlocksDistribution(org.apache.hadoop.conf.Configuration conf,
TableDescriptor tableDescriptor,
RegionInfo regionInfo) |
Modifier and Type | Field and Description |
---|---|
private TableDescriptor |
SimpleRegionNormalizer.NormalizeContext.tableDescriptor |
Modifier and Type | Method and Description |
---|---|
List<NormalizationPlan> |
RegionNormalizer.computePlansForTable(TableDescriptor tableDescriptor)
Computes a list of normalizer actions to perform on the target table.
|
List<NormalizationPlan> |
SimpleRegionNormalizer.computePlansForTable(TableDescriptor tableDescriptor) |
private double |
SimpleRegionNormalizer.getAverageRegionSizeMb(List<RegionInfo> tableRegions,
TableDescriptor tableDescriptor)
Also make sure tableRegions contains regions of the same table
|
private boolean |
SimpleRegionNormalizer.proceedWithMergePlanning(TableDescriptor tableDescriptor) |
private boolean |
SimpleRegionNormalizer.proceedWithSplitPlanning(TableDescriptor tableDescriptor) |
Constructor and Description |
---|
NormalizeContext(TableDescriptor tableDescriptor) |
Modifier and Type | Field and Description |
---|---|
private TableDescriptor |
SnapshotProcedure.htd |
private TableDescriptor |
ModifyTableProcedure.modifiedTableDescriptor |
private TableDescriptor |
RestoreSnapshotProcedure.modifiedTableDescriptor |
private TableDescriptor |
ModifyTableDescriptorProcedure.modifiedTableDescriptor |
private TableDescriptor |
RestoreSnapshotProcedure.oldTableDescriptor |
private TableDescriptor |
CreateTableProcedure.tableDescriptor |
private TableDescriptor |
CloneSnapshotProcedure.tableDescriptor |
private TableDescriptor |
TruncateTableProcedure.tableDescriptor |
private TableDescriptor |
ModifyTableProcedure.unmodifiedTableDescriptor |
Modifier and Type | Method and Description |
---|---|
private TableDescriptor |
SnapshotProcedure.loadTableDescriptorSnapshot(MasterProcedureEnv env) |
private static TableDescriptor |
InitMetaProcedure.writeFsLayout(org.apache.hadoop.fs.Path rootDir,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
protected abstract Optional<TableDescriptor> |
ModifyTableDescriptorProcedure.modify(MasterProcedureEnv env,
TableDescriptor current)
Sub class should implement this method to modify the table descriptor, such as storing the rs
group information.
|
Modifier and Type | Method and Description |
---|---|
private static void |
CreateTableProcedure.addRegionsToMeta(MasterProcedureEnv env,
TableDescriptor tableDescriptor,
List<RegionInfo> regionInfos)
Add the specified set of regions to the hbase:meta table.
|
protected static List<RegionInfo> |
CreateTableProcedure.addTableToMeta(MasterProcedureEnv env,
TableDescriptor tableDescriptor,
List<RegionInfo> regions) |
private List<RegionInfo> |
CloneSnapshotProcedure.createFilesystemLayout(MasterProcedureEnv env,
TableDescriptor tableDescriptor,
List<RegionInfo> newRegions)
Create regions in file system.
|
protected static List<RegionInfo> |
CreateTableProcedure.createFsLayout(MasterProcedureEnv env,
TableDescriptor tableDescriptor,
List<RegionInfo> newRegions) |
protected static List<RegionInfo> |
CreateTableProcedure.createFsLayout(MasterProcedureEnv env,
TableDescriptor tableDescriptor,
List<RegionInfo> newRegions,
CreateTableProcedure.CreateHdfsRegions hdfsRegionHandler) |
private List<RegionInfo> |
CloneSnapshotProcedure.createFsLayout(MasterProcedureEnv env,
TableDescriptor tableDescriptor,
List<RegionInfo> newRegions,
CreateTableProcedure.CreateHdfsRegions hdfsRegionHandler)
Create region layout in file system.
|
private void |
ModifyTableProcedure.deleteFromFs(MasterProcedureEnv env,
TableDescriptor oldTableDescriptor,
TableDescriptor newTableDescriptor)
Removes from hdfs the families that are not longer present in the new table descriptor.
|
private void |
ModifyTableProcedure.initialize(TableDescriptor unmodifiedTableDescriptor,
boolean shouldCheckDescriptor) |
private static boolean |
ModifyTableProcedure.isDeleteColumnFamily(TableDescriptor originalDescriptor,
TableDescriptor newDescriptor)
Find out whether all column families in unmodifiedTableDescriptor also exists in the
modifiedTableDescriptor.
|
private boolean |
ModifyTableProcedure.isTablePropertyModified(TableDescriptor oldDescriptor,
TableDescriptor newDescriptor,
String key)
Comparing the value associated with a given key across two TableDescriptor instances'
properties.
|
protected abstract Optional<TableDescriptor> |
ModifyTableDescriptorProcedure.modify(MasterProcedureEnv env,
TableDescriptor current)
Sub class should implement this method to modify the table descriptor, such as storing the rs
group information.
|
Constructor and Description |
---|
CloneSnapshotProcedure(MasterProcedureEnv env,
TableDescriptor tableDescriptor,
org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot) |
CloneSnapshotProcedure(MasterProcedureEnv env,
TableDescriptor tableDescriptor,
org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot,
boolean restoreAcl)
Constructor
|
CloneSnapshotProcedure(MasterProcedureEnv env,
TableDescriptor tableDescriptor,
org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot,
boolean restoreAcl,
String customSFT) |
CreateTableProcedure(MasterProcedureEnv env,
TableDescriptor tableDescriptor,
RegionInfo[] newRegions) |
CreateTableProcedure(MasterProcedureEnv env,
TableDescriptor tableDescriptor,
RegionInfo[] newRegions,
ProcedurePrepareLatch syncLatch) |
ModifyTableProcedure(MasterProcedureEnv env,
TableDescriptor htd) |
ModifyTableProcedure(MasterProcedureEnv env,
TableDescriptor htd,
ProcedurePrepareLatch latch) |
ModifyTableProcedure(MasterProcedureEnv env,
TableDescriptor newTableDescriptor,
ProcedurePrepareLatch latch,
TableDescriptor oldTableDescriptor,
boolean shouldCheckDescriptor,
boolean reopenRegions) |
RestoreSnapshotProcedure(MasterProcedureEnv env,
TableDescriptor tableDescriptor,
org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot) |
RestoreSnapshotProcedure(MasterProcedureEnv env,
TableDescriptor tableDescriptor,
org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot,
boolean restoreAcl) |
RestoreSnapshotProcedure(MasterProcedureEnv env,
TableDescriptor oldTableDescriptor,
TableDescriptor modifiedTableDescriptor,
org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot,
boolean restoreAcl)
Constructor
|
Modifier and Type | Field and Description |
---|---|
private static TableDescriptor |
MasterRegionFactory.TABLE_DESC |
private TableDescriptor |
MasterRegionParams.tableDescriptor |
Modifier and Type | Method and Description |
---|---|
TableDescriptor |
MasterRegionParams.tableDescriptor() |
private static TableDescriptor |
MasterRegionFactory.withTrackerConfigs(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
private static HRegion |
MasterRegion.bootstrap(org.apache.hadoop.conf.Configuration conf,
TableDescriptor td,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path rootDir,
org.apache.hadoop.fs.FileSystem walFs,
org.apache.hadoop.fs.Path walRootDir,
WALFactory walFactory,
MasterRegionWALRoller walRoller,
String serverName,
boolean touchInitializingFlag) |
private static HRegion |
MasterRegion.open(org.apache.hadoop.conf.Configuration conf,
TableDescriptor td,
RegionInfo regionInfo,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path rootDir,
org.apache.hadoop.fs.FileSystem walFs,
org.apache.hadoop.fs.Path walRootDir,
WALFactory walFactory,
MasterRegionWALRoller walRoller,
String serverName) |
MasterRegionParams |
MasterRegionParams.tableDescriptor(TableDescriptor tableDescriptor) |
private static void |
MasterRegion.tryMigrate(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path tableDir,
RegionInfo regionInfo,
TableDescriptor oldTd,
TableDescriptor newTd) |
Modifier and Type | Field and Description |
---|---|
protected TableDescriptor |
TakeSnapshotHandler.htd |
Modifier and Type | Method and Description |
---|---|
private TableDescriptor |
TakeSnapshotHandler.loadTableDescriptor() |
private TableDescriptor |
SnapshotManager.sanityCheckBeforeSnapshot(org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot,
boolean checkTable)
Check if the snapshot can be taken.
|
Modifier and Type | Method and Description |
---|---|
(package private) long |
SnapshotManager.cloneSnapshot(org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot,
TableDescriptor tableDescriptor,
NonceKey nonceKey,
boolean restoreAcl,
String customSFT)
Clone the specified snapshot into a new table.
|
private long |
SnapshotManager.cloneSnapshot(org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription reqSnapshot,
TableName tableName,
org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot,
TableDescriptor snapshotTableDesc,
NonceKey nonceKey,
boolean restoreAcl,
String customSFT)
Clone the specified snapshot.
|
private long |
SnapshotManager.restoreSnapshot(org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot,
TableDescriptor tableDescriptor,
NonceKey nonceKey,
boolean restoreAcl)
Restore the specified snapshot.
|
private long |
SnapshotManager.restoreSnapshot(org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription reqSnapshot,
TableName tableName,
org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot,
TableDescriptor snapshotTableDesc,
NonceKey nonceKey,
boolean restoreAcl)
Restore the specified snapshot.
|
Modifier and Type | Method and Description |
---|---|
static List<ColumnFamilyDescriptor> |
MobUtils.getMobColumnFamilies(TableDescriptor htd)
Get list of Mob column families (if any exists)
|
static boolean |
MobUtils.hasMobColumns(TableDescriptor htd)
Checks whether this table has mob-enabled columns.
|
void |
MobFileCompactionChore.performMajorCompactionInBatches(Admin admin,
TableDescriptor htd,
ColumnFamilyDescriptor hcd) |
Modifier and Type | Field and Description |
---|---|
static TableDescriptor |
QuotaUtil.QUOTA_TABLE_DESC
Table descriptor for Quota internal table
|
Modifier and Type | Field and Description |
---|---|
private TableDescriptor |
HRegion.htableDescriptor |
Modifier and Type | Method and Description |
---|---|
TableDescriptor |
HRegion.getTableDescriptor() |
TableDescriptor |
Region.getTableDescriptor()
Returns table descriptor for this region
|
Modifier and Type | Method and Description |
---|---|
private void |
CompactionTool.CompactionWorker.compactRegion(org.apache.hadoop.fs.Path tableDir,
TableDescriptor htd,
org.apache.hadoop.fs.Path regionDir,
boolean compactOnce,
boolean major) |
private void |
CompactionTool.CompactionWorker.compactStoreFiles(org.apache.hadoop.fs.Path tableDir,
TableDescriptor htd,
RegionInfo hri,
String familyName,
boolean compactOnce,
boolean major)
Execute the actual compaction job.
|
static HDFSBlocksDistribution |
HRegion.computeHDFSBlocksDistribution(org.apache.hadoop.conf.Configuration conf,
TableDescriptor tableDescriptor,
RegionInfo regionInfo)
This is a helper function to compute HDFS block distribution on demand
|
static HDFSBlocksDistribution |
HRegion.computeHDFSBlocksDistribution(org.apache.hadoop.conf.Configuration conf,
TableDescriptor tableDescriptor,
RegionInfo regionInfo,
org.apache.hadoop.fs.Path tablePath)
This is a helper function to compute HDFS block distribution on demand
|
static RegionSplitRestriction |
RegionSplitRestriction.create(TableDescriptor tableDescriptor,
org.apache.hadoop.conf.Configuration conf)
Create the RegionSplitRestriction configured for the given table.
|
static HRegion |
HRegion.createHRegion(org.apache.hadoop.conf.Configuration conf,
RegionInfo regionInfo,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path tableDir,
TableDescriptor tableDesc)
Create a region under the given table directory.
|
static HRegion |
HRegion.createHRegion(RegionInfo info,
org.apache.hadoop.fs.Path rootDir,
org.apache.hadoop.conf.Configuration conf,
TableDescriptor hTableDescriptor,
WAL wal) |
static HRegion |
HRegion.createHRegion(RegionInfo info,
org.apache.hadoop.fs.Path rootDir,
org.apache.hadoop.conf.Configuration conf,
TableDescriptor hTableDescriptor,
WAL wal,
boolean initialize)
Convenience method creating new HRegions.
|
static HRegion |
HRegion.createHRegion(RegionInfo info,
org.apache.hadoop.fs.Path rootDir,
org.apache.hadoop.conf.Configuration conf,
TableDescriptor hTableDescriptor,
WAL wal,
boolean initialize,
RegionServerServices rsRpcServices)
Convenience method creating new HRegions.
|
static org.apache.hadoop.conf.Configuration |
StoreUtils.createStoreConfiguration(org.apache.hadoop.conf.Configuration conf,
TableDescriptor td,
ColumnFamilyDescriptor cfd) |
static Class<? extends FlushPolicy> |
FlushPolicyFactory.getFlushPolicyClass(TableDescriptor htd,
org.apache.hadoop.conf.Configuration conf)
Get FlushPolicy class for the given table.
|
static Class<? extends RegionSplitPolicy> |
RegionSplitPolicy.getSplitPolicyClass(TableDescriptor htd,
org.apache.hadoop.conf.Configuration conf) |
private static HStore |
CompactionTool.CompactionWorker.getStore(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path tableDir,
TableDescriptor htd,
RegionInfo hri,
String familyName) |
(package private) static List<RegionCoprocessorHost.TableCoprocessorAttribute> |
RegionCoprocessorHost.getTableCoprocessorAttrsFromSchema(org.apache.hadoop.conf.Configuration conf,
TableDescriptor htd) |
boolean |
HRegionFileSystem.hasReferences(TableDescriptor htd)
Check whether region has Reference file
|
void |
KeyPrefixRegionSplitRestriction.initialize(TableDescriptor tableDescriptor,
org.apache.hadoop.conf.Configuration conf) |
abstract void |
RegionSplitRestriction.initialize(TableDescriptor tableDescriptor,
org.apache.hadoop.conf.Configuration conf)
Initialize the RegionSplitRestriction instance
|
void |
NoRegionSplitRestriction.initialize(TableDescriptor tableDescriptor,
org.apache.hadoop.conf.Configuration conf) |
void |
DelimitedKeyPrefixRegionSplitRestriction.initialize(TableDescriptor tableDescriptor,
org.apache.hadoop.conf.Configuration conf) |
static HRegion |
HRegion.newHRegion(org.apache.hadoop.fs.Path tableDir,
WAL wal,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.conf.Configuration conf,
RegionInfo regionInfo,
TableDescriptor htd,
RegionServerServices rsServices)
A utility method to create new instances of HRegion based on the
HConstants.REGION_IMPL
configuration property. |
static HRegion |
HRegion.openHRegion(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path rootDir,
RegionInfo info,
TableDescriptor htd,
WAL wal)
Open a Region.
|
static HRegion |
HRegion.openHRegion(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path rootDir,
RegionInfo info,
TableDescriptor htd,
WAL wal,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static HRegion |
HRegion.openHRegion(org.apache.hadoop.fs.Path rootDir,
RegionInfo info,
TableDescriptor htd,
WAL wal,
org.apache.hadoop.conf.Configuration conf)
Open a Region.
|
static HRegion |
HRegion.openHRegion(org.apache.hadoop.fs.Path rootDir,
RegionInfo info,
TableDescriptor htd,
WAL wal,
org.apache.hadoop.conf.Configuration conf,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static HRegion |
HRegion.openHRegion(RegionInfo info,
TableDescriptor htd,
WAL wal,
org.apache.hadoop.conf.Configuration conf)
Open a Region.
|
static HRegion |
HRegion.openHRegion(RegionInfo info,
TableDescriptor htd,
WAL wal,
org.apache.hadoop.conf.Configuration conf,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static HRegion |
HRegion.openHRegionFromTableDir(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path tableDir,
RegionInfo info,
TableDescriptor htd,
WAL wal,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static HRegion |
HRegion.openReadOnlyFileSystemHRegion(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path tableDir,
RegionInfo info,
TableDescriptor htd)
Open a Region on a read-only file-system (like hdfs snapshots)
|
void |
HRegion.setTableDescriptor(TableDescriptor desc) |
static void |
RegionCoprocessorHost.testTableCoprocessorAttrs(org.apache.hadoop.conf.Configuration conf,
TableDescriptor htd)
Sanity check the table coprocessor attributes of the supplied schema.
|
static HRegion |
HRegion.warmupHRegion(RegionInfo info,
TableDescriptor htd,
WAL wal,
org.apache.hadoop.conf.Configuration conf,
RegionServerServices rsServices,
CancelableProgressable reporter) |
Modifier and Type | Method and Description |
---|---|
private void |
RSRpcServices.executeOpenRegionProcedures(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionRequest request,
Map<TableName,TableDescriptor> tdCache) |
Constructor and Description |
---|
HRegion(HRegionFileSystem fs,
WAL wal,
org.apache.hadoop.conf.Configuration confParam,
TableDescriptor htd,
RegionServerServices rsServices)
HRegion constructor.
|
HRegion(org.apache.hadoop.fs.Path tableDir,
WAL wal,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.conf.Configuration confParam,
RegionInfo regionInfo,
TableDescriptor htd,
RegionServerServices rsServices)
Deprecated.
Use other constructors.
|
Modifier and Type | Field and Description |
---|---|
private TableDescriptor |
OpenRegionHandler.htd
Deprecated.
|
private TableDescriptor |
AssignRegionHandler.tableDesc |
Modifier and Type | Method and Description |
---|---|
static AssignRegionHandler |
AssignRegionHandler.create(HRegionServer server,
RegionInfo regionInfo,
long openProcId,
TableDescriptor tableDesc,
long masterSystemTime) |
Constructor and Description |
---|
AssignRegionHandler(HRegionServer server,
RegionInfo regionInfo,
long openProcId,
TableDescriptor tableDesc,
long masterSystemTime,
EventType eventType) |
OpenMetaHandler(Server server,
RegionServerServices rsServices,
RegionInfo regionInfo,
TableDescriptor htd,
long masterSystemTime) |
OpenPriorityRegionHandler(Server server,
RegionServerServices rsServices,
RegionInfo regionInfo,
TableDescriptor htd,
long masterSystemTime) |
OpenRegionHandler(Server server,
RegionServerServices rsServices,
RegionInfo regionInfo,
TableDescriptor htd,
long masterSystemTime)
Deprecated.
|
OpenRegionHandler(Server server,
RegionServerServices rsServices,
RegionInfo regionInfo,
TableDescriptor htd,
long masterSystemTime,
EventType eventType)
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
private TableDescriptor |
RegionReplicationSink.tableDesc |
Constructor and Description |
---|
RegionReplicationSink(org.apache.hadoop.conf.Configuration conf,
RegionInfo primary,
TableDescriptor td,
RegionReplicationBufferManager manager,
Runnable flushRequester,
AsyncClusterConnection conn) |
Modifier and Type | Method and Description |
---|---|
protected TableDescriptor |
ModifyTableStoreFileTrackerProcedure.createFinishTableDescriptor(TableDescriptor current) |
protected abstract TableDescriptor |
ModifyStoreFileTrackerProcedure.createFinishTableDescriptor(TableDescriptor current) |
protected TableDescriptor |
ModifyColumnFamilyStoreFileTrackerProcedure.createFinishTableDescriptor(TableDescriptor current) |
protected TableDescriptor |
ModifyTableStoreFileTrackerProcedure.createMigrationTableDescriptor(org.apache.hadoop.conf.Configuration conf,
TableDescriptor current) |
protected abstract TableDescriptor |
ModifyStoreFileTrackerProcedure.createMigrationTableDescriptor(org.apache.hadoop.conf.Configuration conf,
TableDescriptor current) |
protected TableDescriptor |
ModifyColumnFamilyStoreFileTrackerProcedure.createMigrationTableDescriptor(org.apache.hadoop.conf.Configuration conf,
TableDescriptor current) |
protected TableDescriptor |
ModifyTableStoreFileTrackerProcedure.createRestoreTableDescriptor(TableDescriptor current,
String restoreSFT) |
protected abstract TableDescriptor |
ModifyStoreFileTrackerProcedure.createRestoreTableDescriptor(TableDescriptor current,
String restoreSFT) |
protected TableDescriptor |
ModifyColumnFamilyStoreFileTrackerProcedure.createRestoreTableDescriptor(TableDescriptor current,
String restoreSFT) |
static TableDescriptor |
StoreFileTrackerFactory.updateWithTrackerConfigs(org.apache.hadoop.conf.Configuration conf,
TableDescriptor descriptor) |
Modifier and Type | Method and Description |
---|---|
protected Optional<TableDescriptor> |
InitializeStoreFileTrackerProcedure.modify(MasterProcedureEnv env,
TableDescriptor current) |
Modifier and Type | Method and Description |
---|---|
static void |
StoreFileTrackerValidationUtils.checkForCreateTable(org.apache.hadoop.conf.Configuration conf,
TableDescriptor table)
Pre check when creating a new table.
|
static void |
StoreFileTrackerValidationUtils.checkForModifyTable(org.apache.hadoop.conf.Configuration conf,
TableDescriptor oldTable,
TableDescriptor newTable,
boolean isTableDisabled)
Pre check when modifying a table.
|
private static void |
StoreFileTrackerValidationUtils.checkForNewFamily(org.apache.hadoop.conf.Configuration conf,
TableDescriptor table,
ColumnFamilyDescriptor family) |
static StoreFileTracker |
StoreFileTrackerFactory.create(org.apache.hadoop.conf.Configuration conf,
TableDescriptor td,
ColumnFamilyDescriptor cfd,
HRegionFileSystem regionFs)
Used at master side when splitting/merging regions, as we do not have a Store, thus no
StoreContext at master side.
|
protected org.apache.hadoop.conf.Configuration |
ModifyTableStoreFileTrackerProcedure.createConf(org.apache.hadoop.conf.Configuration conf,
TableDescriptor current) |
protected abstract org.apache.hadoop.conf.Configuration |
ModifyStoreFileTrackerProcedure.createConf(org.apache.hadoop.conf.Configuration conf,
TableDescriptor current) |
protected org.apache.hadoop.conf.Configuration |
ModifyColumnFamilyStoreFileTrackerProcedure.createConf(org.apache.hadoop.conf.Configuration conf,
TableDescriptor current) |
protected TableDescriptor |
ModifyTableStoreFileTrackerProcedure.createFinishTableDescriptor(TableDescriptor current) |
protected abstract TableDescriptor |
ModifyStoreFileTrackerProcedure.createFinishTableDescriptor(TableDescriptor current) |
protected TableDescriptor |
ModifyColumnFamilyStoreFileTrackerProcedure.createFinishTableDescriptor(TableDescriptor current) |
protected TableDescriptor |
ModifyTableStoreFileTrackerProcedure.createMigrationTableDescriptor(org.apache.hadoop.conf.Configuration conf,
TableDescriptor current) |
protected abstract TableDescriptor |
ModifyStoreFileTrackerProcedure.createMigrationTableDescriptor(org.apache.hadoop.conf.Configuration conf,
TableDescriptor current) |
protected TableDescriptor |
ModifyColumnFamilyStoreFileTrackerProcedure.createMigrationTableDescriptor(org.apache.hadoop.conf.Configuration conf,
TableDescriptor current) |
protected TableDescriptor |
ModifyTableStoreFileTrackerProcedure.createRestoreTableDescriptor(TableDescriptor current,
String restoreSFT) |
protected abstract TableDescriptor |
ModifyStoreFileTrackerProcedure.createRestoreTableDescriptor(TableDescriptor current,
String restoreSFT) |
protected TableDescriptor |
ModifyColumnFamilyStoreFileTrackerProcedure.createRestoreTableDescriptor(TableDescriptor current,
String restoreSFT) |
private static org.apache.hadoop.conf.Configuration |
StoreFileTrackerFactory.mergeConfigurations(org.apache.hadoop.conf.Configuration global,
TableDescriptor table,
ColumnFamilyDescriptor family) |
protected Optional<TableDescriptor> |
InitializeStoreFileTrackerProcedure.modify(MasterProcedureEnv env,
TableDescriptor current) |
protected void |
ModifyTableStoreFileTrackerProcedure.preCheck(TableDescriptor current) |
protected abstract void |
ModifyStoreFileTrackerProcedure.preCheck(TableDescriptor current) |
protected void |
ModifyColumnFamilyStoreFileTrackerProcedure.preCheck(TableDescriptor current) |
static TableDescriptor |
StoreFileTrackerFactory.updateWithTrackerConfigs(org.apache.hadoop.conf.Configuration conf,
TableDescriptor descriptor) |
static void |
StoreFileTrackerValidationUtils.validatePreRestoreSnapshot(TableDescriptor currentTableDesc,
TableDescriptor snapshotTableDesc,
org.apache.hadoop.conf.Configuration baseConf)
Makes sure restoring a snapshot does not break the current SFT setup follows
StoreUtils.createStoreConfiguration
|
Modifier and Type | Method and Description |
---|---|
static TableDescriptor |
ReplicationStorageFactory.createReplicationQueueTableDescriptor(TableName tableName) |
Modifier and Type | Method and Description |
---|---|
private TableDescriptor |
SchemaResource.getTableSchema() |
Modifier and Type | Method and Description |
---|---|
TableDescriptor |
TableSchemaModel.getTableDescriptor()
Returns a table descriptor
|
Constructor and Description |
---|
TableSchemaModel(TableDescriptor tableDescriptor)
Constructor
|
Modifier and Type | Field and Description |
---|---|
private static TableDescriptor |
RSGroupInfoManagerImpl.RSGROUP_TABLE_DESC
Table descriptor for
hbase:rsgroup catalog table |
Modifier and Type | Method and Description |
---|---|
protected Optional<TableDescriptor> |
MigrateRSGroupProcedure.modify(MasterProcedureEnv env,
TableDescriptor current) |
Modifier and Type | Method and Description |
---|---|
protected Optional<TableDescriptor> |
MigrateRSGroupProcedure.modify(MasterProcedureEnv env,
TableDescriptor current) |
Modifier and Type | Method and Description |
---|---|
static RSGroupInfo |
RSGroupUtil.fillTables(RSGroupInfo rsGroupInfo,
Collection<TableDescriptor> tds)
Fill the tables field for
RSGroupInfo , for backward compatibility. |
Modifier and Type | Method and Description |
---|---|
TableDescriptor |
CoprocessorWhitelistMasterObserver.preModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
TableDescriptor currentDesc,
TableDescriptor newDesc) |
TableDescriptor |
AccessController.preModifyTable(ObserverContext<MasterCoprocessorEnvironment> c,
TableName tableName,
TableDescriptor currentDesc,
TableDescriptor newDesc) |
Modifier and Type | Method and Description |
---|---|
void |
AccessController.postGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
List<TableName> tableNamesList,
List<TableDescriptor> descriptors,
String regex) |
void |
AccessController.postGetTableNames(ObserverContext<MasterCoprocessorEnvironment> ctx,
List<TableDescriptor> descriptors,
String regex) |
void |
AccessController.preGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
List<TableName> tableNamesList,
List<TableDescriptor> descriptors,
String regex) |
Modifier and Type | Method and Description |
---|---|
TableDescriptor |
VisibilityController.preModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
TableDescriptor currentDescriptor,
TableDescriptor newDescriptor) |
Modifier and Type | Method and Description |
---|---|
TableDescriptor |
VisibilityController.preModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
TableDescriptor currentDescriptor,
TableDescriptor newDescriptor) |
Modifier and Type | Field and Description |
---|---|
private TableDescriptor |
RestoreSnapshotHelper.RestoreMetaChanges.htd |
private TableDescriptor |
SnapshotManifest.htd |
private TableDescriptor |
RestoreSnapshotHelper.tableDesc |
Modifier and Type | Method and Description |
---|---|
TableDescriptor |
RestoreSnapshotHelper.RestoreMetaChanges.getTableDescriptor() |
TableDescriptor |
SnapshotManifest.getTableDescriptor()
Get the table descriptor from the Snapshot
|
Modifier and Type | Method and Description |
---|---|
void |
SnapshotManifest.addTableDescriptor(TableDescriptor htd)
Add the table descriptor to the snapshot manifest
|
Constructor and Description |
---|
RestoreMetaChanges(TableDescriptor htd,
Map<String,Pair<String,String>> parentsMap) |
RestoreSnapshotHelper(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
SnapshotManifest manifest,
TableDescriptor tableDescriptor,
org.apache.hadoop.fs.Path rootDir,
ForeignExceptionDispatcher monitor,
MonitoredTask status) |
RestoreSnapshotHelper(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
SnapshotManifest manifest,
TableDescriptor tableDescriptor,
org.apache.hadoop.fs.Path rootDir,
ForeignExceptionDispatcher monitor,
MonitoredTask status,
boolean createBackRefs) |
Modifier and Type | Method and Description |
---|---|
static TableDescriptor |
ThriftUtilities.tableDescriptorFromThrift(org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor in) |
Modifier and Type | Method and Description |
---|---|
static List<TableDescriptor> |
ThriftUtilities.tableDescriptorsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor> in) |
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor |
ThriftUtilities.tableDescriptorFromHBase(TableDescriptor in) |
static List<org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor> |
ThriftUtilities.tableDescriptorsFromHBase(TableDescriptor[] in) |
Modifier and Type | Method and Description |
---|---|
static List<org.apache.hadoop.hbase.thrift2.generated.TTableDescriptor> |
ThriftUtilities.tableDescriptorsFromHBase(List<TableDescriptor> in) |
Modifier and Type | Method and Description |
---|---|
TableDescriptor |
ThriftTable.getDescriptor() |
TableDescriptor |
ThriftAdmin.getDescriptor(TableName tableName) |
Modifier and Type | Method and Description |
---|---|
List<TableDescriptor> |
ThriftAdmin.listTableDescriptors() |
List<TableDescriptor> |
ThriftAdmin.listTableDescriptors(boolean includeSysTables) |
List<TableDescriptor> |
ThriftAdmin.listTableDescriptors(List<TableName> tableNames) |
List<TableDescriptor> |
ThriftAdmin.listTableDescriptors(Pattern pattern) |
List<TableDescriptor> |
ThriftAdmin.listTableDescriptors(Pattern pattern,
boolean includeSysTables) |
List<TableDescriptor> |
ThriftAdmin.listTableDescriptorsByNamespace(byte[] name) |
List<TableDescriptor> |
ThriftAdmin.listTableDescriptorsByState(boolean isEnabled) |
Modifier and Type | Method and Description |
---|---|
void |
ThriftAdmin.createTable(TableDescriptor desc) |
void |
ThriftAdmin.createTable(TableDescriptor desc,
byte[][] splitKeys) |
void |
ThriftAdmin.createTable(TableDescriptor desc,
byte[] startKey,
byte[] endKey,
int numRegions) |
Future<Void> |
ThriftAdmin.createTableAsync(TableDescriptor desc) |
Future<Void> |
ThriftAdmin.createTableAsync(TableDescriptor desc,
byte[][] splitKeys) |
void |
ThriftAdmin.modifyTable(TableDescriptor td) |
Future<Void> |
ThriftAdmin.modifyTableAsync(TableDescriptor td) |
Future<Void> |
ThriftAdmin.modifyTableAsync(TableDescriptor td,
boolean reopenRegions) |
Modifier and Type | Method and Description |
---|---|
private static List<Future<Void>> |
CanaryTool.sniff(Admin admin,
CanaryTool.Sink sink,
TableDescriptor tableDesc,
ExecutorService executor,
CanaryTool.RegionTask.TaskType taskType,
boolean rawScanEnabled,
LongAdder rwLatency,
boolean readAllCF) |
private List<BulkLoadHFiles.LoadQueueItem> |
BulkLoadHFilesTool.splitStoreFile(AsyncTableRegionLocator loc,
BulkLoadHFiles.LoadQueueItem item,
TableDescriptor tableDesc,
byte[] splitKey) |
private static void |
BulkLoadHFilesTool.validateFamiliesInHFiles(TableDescriptor tableDesc,
Deque<BulkLoadHFiles.LoadQueueItem> queue,
boolean silence)
Checks whether there is any invalid family name in HFiles to be bulk loaded.
|
Modifier and Type | Field and Description |
---|---|
private Map<TableName,TableDescriptor> |
FSTableDescriptors.cache |
(package private) Set<TableDescriptor> |
HbckTableInfo.htds |
Modifier and Type | Method and Description |
---|---|
TableDescriptor |
FSTableDescriptors.get(TableName tableName)
Get the current table descriptor for the given table, or null if none exists.
|
(package private) TableDescriptor |
HbckTableInfo.getTableDescriptor()
Returns descriptor common to all regions.
|
static TableDescriptor |
FSTableDescriptors.getTableDescriptorFromFs(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path tableDir)
Returns the latest table descriptor for the table located at the given directory directly from
the file system if it exists.
|
static TableDescriptor |
FSTableDescriptors.getTableDescriptorFromFs(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path hbaseRootDir,
TableName tableName)
Returns the latest table descriptor for the given table directly from the file system if it
exists, bypassing the local cache.
|
(package private) TableDescriptor[] |
HBaseFsck.getTableDescriptors(List<TableName> tableNames)
Deprecated.
|
(package private) TableDescriptor[] |
HBaseFsck.getTables(AtomicInteger numSkipped)
Deprecated.
Return a list of user-space table names whose metadata have not been modified in the last few
milliseconds specified by timelag if any of the REGIONINFO_QUALIFIER, SERVER_QUALIFIER,
STARTCODE_QUALIFIER, SPLITA_QUALIFIER, SPLITB_QUALIFIER have not changed in the last
milliseconds specified by timelag, then the table is a candidate to be returned.
|
TableDescriptor |
FSTableDescriptors.remove(TableName tablename)
Removes the table descriptor from the local cache and returns it.
|
static TableDescriptor |
FSTableDescriptors.tryUpdateAndGetMetaTableDescriptor(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path rootdir) |
Modifier and Type | Method and Description |
---|---|
Map<String,TableDescriptor> |
FSTableDescriptors.getAll()
Returns a map from table name to table descriptor for all tables.
|
Map<String,TableDescriptor> |
FSTableDescriptors.getByNamespace(String name)
Find descriptors by namespace.
|
private static Optional<Pair<org.apache.hadoop.fs.FileStatus,TableDescriptor>> |
FSTableDescriptors.getTableDescriptorFromFs(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path tableDir,
boolean readonly) |
Modifier and Type | Method and Description |
---|---|
private static void |
TableDescriptorChecker.checkBloomFilterType(org.apache.hadoop.conf.Configuration conf,
TableDescriptor td) |
static void |
TableDescriptorChecker.checkClassLoading(org.apache.hadoop.conf.Configuration conf,
TableDescriptor td) |
private static void |
TableDescriptorChecker.checkCompactionPolicy(org.apache.hadoop.conf.Configuration conf,
TableDescriptor td) |
static void |
TableDescriptorChecker.checkCompression(org.apache.hadoop.conf.Configuration conf,
TableDescriptor td) |
static void |
TableDescriptorChecker.checkEncryption(org.apache.hadoop.conf.Configuration conf,
TableDescriptor td) |
private static void |
TableDescriptorChecker.checkReplicationScope(org.apache.hadoop.conf.Configuration conf,
TableDescriptor td) |
static HRegion |
HBaseFsckRepair.createHDFSRegionDir(org.apache.hadoop.conf.Configuration conf,
RegionInfo hri,
TableDescriptor htd)
Creates, flushes, and closes a new region.
|
static RegionInfo |
ModifyRegionUtils.createRegion(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.Path rootDir,
TableDescriptor tableDescriptor,
RegionInfo newRegion,
ModifyRegionUtils.RegionFillTask task)
Create new set of regions on the specified file-system.
|
static RegionInfo[] |
ModifyRegionUtils.createRegionInfos(TableDescriptor tableDescriptor,
byte[][] splitKeys) |
static List<RegionInfo> |
ModifyRegionUtils.createRegions(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.Path rootDir,
TableDescriptor tableDescriptor,
RegionInfo[] newRegions,
ModifyRegionUtils.RegionFillTask task)
Create new set of regions on the specified file-system.
|
static List<RegionInfo> |
ModifyRegionUtils.createRegions(ThreadPoolExecutor exec,
org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.Path rootDir,
TableDescriptor tableDescriptor,
RegionInfo[] newRegions,
ModifyRegionUtils.RegionFillTask task)
Create new set of regions on the specified file-system.
|
boolean |
FSTableDescriptors.createTableDescriptor(TableDescriptor htd)
Create new TableDescriptor in HDFS.
|
boolean |
FSTableDescriptors.createTableDescriptor(TableDescriptor htd,
boolean forceCreation)
Create new TableDescriptor in HDFS.
|
static boolean |
FSTableDescriptors.createTableDescriptorForTableDirectory(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path tableDir,
TableDescriptor htd,
boolean forceCreation)
Create a new TableDescriptor in HDFS in the specified table directory.
|
boolean |
FSTableDescriptors.createTableDescriptorForTableDirectory(org.apache.hadoop.fs.Path tableDir,
TableDescriptor htd,
boolean forceCreation)
Create a new TableDescriptor in HDFS in the specified table directory.
|
static void |
TableDescriptorChecker.sanityCheck(org.apache.hadoop.conf.Configuration c,
TableDescriptor td)
Checks whether the table conforms to some sane limits, and configured values (compression, etc)
work.
|
void |
FSTableDescriptors.update(TableDescriptor td,
boolean cacheOnly) |
(package private) org.apache.hadoop.fs.Path |
FSTableDescriptors.updateTableDescriptor(TableDescriptor td) |
private static org.apache.hadoop.fs.Path |
FSTableDescriptors.writeTableDescriptor(org.apache.hadoop.fs.FileSystem fs,
TableDescriptor td,
org.apache.hadoop.fs.Path tableDir,
org.apache.hadoop.fs.FileStatus currentDescriptorFile)
Attempts to write a new table descriptor to the given table's directory.
|
Modifier and Type | Method and Description |
---|---|
private void |
FSTableDescriptors.internalGet(org.apache.hadoop.fs.Path dir,
Map<String,TableDescriptor> tds,
AtomicBoolean allvisited) |
Modifier and Type | Field and Description |
---|---|
private TableDescriptor |
MajorCompactorTTL.htd |
Modifier and Type | Method and Description |
---|---|
private Optional<MajorCompactionRequest> |
MajorCompactionTTLRequest.createRequest(Connection connection,
TableDescriptor htd) |
private boolean |
MajorCompactorTTL.doesAnyColFamilyHaveTTL(TableDescriptor htd) |
(package private) Map<String,Long> |
MajorCompactionTTLRequest.getStoresRequiringCompaction(TableDescriptor htd) |
(package private) static Optional<MajorCompactionRequest> |
MajorCompactionTTLRequest.newRequest(Connection connection,
RegionInfo info,
TableDescriptor htd) |
Constructor and Description |
---|
MajorCompactorTTL(org.apache.hadoop.conf.Configuration conf,
TableDescriptor htd,
int concurrency,
long sleepForMs) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.