Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.io.hfile |
Provides implementations of
HFile and HFile
BlockCache . |
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.mob | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.storefiletracker | |
org.apache.hadoop.hbase.security | |
org.apache.hadoop.hbase.thrift |
Provides an HBase Thrift
service.
|
org.apache.hadoop.hbase.thrift2 |
Provides an HBase Thrift
service.
|
org.apache.hadoop.hbase.thrift2.client | |
org.apache.hadoop.hbase.tool | |
org.apache.hadoop.hbase.util | |
org.apache.hadoop.hbase.util.compaction |
Modifier and Type | Method and Description |
---|---|
static List<ColumnFamilyDescriptor> |
HBaseTestingUtility.generateColumnDescriptors()
Deprecated.
Create a set of column descriptors with the combination of compression, encoding, bloom codecs
available.
|
static List<ColumnFamilyDescriptor> |
HBaseTestingUtility.generateColumnDescriptors(String prefix)
Deprecated.
Create a set of column descriptors with the combination of compression, encoding, bloom codecs
available.
|
Modifier and Type | Method and Description |
---|---|
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.
|
HRegion |
HBaseTestingUtility.createTestRegion(String tableName,
ColumnFamilyDescriptor cd)
Deprecated.
|
HRegion |
HBaseTestingUtility.createTestRegion(String tableName,
ColumnFamilyDescriptor cd,
BlockCache blockCache)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
private static class |
ColumnFamilyDescriptorBuilder.ModifyableColumnFamilyDescriptor
An ModifyableFamilyDescriptor contains information about a column family such as the number of
versions, compression settings, etc.
|
Modifier and Type | Field and Description |
---|---|
static Comparator<ColumnFamilyDescriptor> |
ColumnFamilyDescriptor.COMPARATOR |
static Comparator<ColumnFamilyDescriptor> |
ColumnFamilyDescriptor.COMPARATOR_IGNORE_REPLICATION |
private Map<byte[],ColumnFamilyDescriptor> |
TableDescriptorBuilder.ModifyableTableDescriptor.families
Maps column family name to the respective FamilyDescriptors
|
Modifier and Type | Method and Description |
---|---|
ColumnFamilyDescriptor |
ColumnFamilyDescriptorBuilder.build() |
static ColumnFamilyDescriptor |
ColumnFamilyDescriptorBuilder.copy(ColumnFamilyDescriptor desc) |
ColumnFamilyDescriptor[] |
TableDescriptor.getColumnFamilies()
Returns an unmodifiable collection of all the
ColumnFamilyDescriptor of all the column
families of the table. |
ColumnFamilyDescriptor[] |
TableDescriptorBuilder.ModifyableTableDescriptor.getColumnFamilies() |
ColumnFamilyDescriptor |
TableDescriptor.getColumnFamily(byte[] name)
Returns the ColumnDescriptor for a specific column family with name as specified by the
parameter column.
|
ColumnFamilyDescriptor |
TableDescriptorBuilder.ModifyableTableDescriptor.getColumnFamily(byte[] column)
Returns the ColumnFamilyDescriptor for a specific column family with name as specified by the
parameter column.
|
static ColumnFamilyDescriptor |
ColumnFamilyDescriptorBuilder.of(byte[] name) |
static ColumnFamilyDescriptor |
ColumnFamilyDescriptorBuilder.of(String name) |
static ColumnFamilyDescriptor |
ColumnFamilyDescriptorBuilder.parseFrom(byte[] pbBytes) |
private static ColumnFamilyDescriptor |
ColumnFamilyDescriptorBuilder.ModifyableColumnFamilyDescriptor.parseFrom(byte[] bytes)
Parse the serialized representation of a
ColumnFamilyDescriptorBuilder.ModifyableColumnFamilyDescriptor |
ColumnFamilyDescriptor |
TableDescriptorBuilder.ModifyableTableDescriptor.removeColumnFamily(byte[] column)
Removes the ColumnFamilyDescriptor with name specified by the parameter column from the table
descriptor
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
AsyncAdmin.addColumnFamily(TableName tableName,
ColumnFamilyDescriptor columnFamily)
Add a column family to an existing table.
|
CompletableFuture<Void> |
RawAsyncHBaseAdmin.addColumnFamily(TableName tableName,
ColumnFamilyDescriptor columnFamily) |
default void |
Admin.addColumnFamily(TableName tableName,
ColumnFamilyDescriptor columnFamily)
Add a column family to an existing table.
|
CompletableFuture<Void> |
AsyncHBaseAdmin.addColumnFamily(TableName tableName,
ColumnFamilyDescriptor columnFamily) |
Future<Void> |
Admin.addColumnFamilyAsync(TableName tableName,
ColumnFamilyDescriptor columnFamily)
Add a column family to an existing table.
|
Future<Void> |
AdminOverAsyncAdmin.addColumnFamilyAsync(TableName tableName,
ColumnFamilyDescriptor columnFamily) |
static ColumnFamilyDescriptor |
ColumnFamilyDescriptorBuilder.copy(ColumnFamilyDescriptor desc) |
TableDescriptorBuilder |
TableDescriptorBuilder.modifyColumnFamily(ColumnFamilyDescriptor family) |
TableDescriptorBuilder.ModifyableTableDescriptor |
TableDescriptorBuilder.ModifyableTableDescriptor.modifyColumnFamily(ColumnFamilyDescriptor family)
Modifies the existing column family.
|
CompletableFuture<Void> |
AsyncAdmin.modifyColumnFamily(TableName tableName,
ColumnFamilyDescriptor columnFamily)
Modify an existing column family on a table.
|
CompletableFuture<Void> |
RawAsyncHBaseAdmin.modifyColumnFamily(TableName tableName,
ColumnFamilyDescriptor columnFamily) |
default void |
Admin.modifyColumnFamily(TableName tableName,
ColumnFamilyDescriptor columnFamily)
Modify an existing column family on a table.
|
CompletableFuture<Void> |
AsyncHBaseAdmin.modifyColumnFamily(TableName tableName,
ColumnFamilyDescriptor columnFamily) |
Future<Void> |
Admin.modifyColumnFamilyAsync(TableName tableName,
ColumnFamilyDescriptor columnFamily)
Modify an existing column family on a table.
|
Future<Void> |
AdminOverAsyncAdmin.modifyColumnFamilyAsync(TableName tableName,
ColumnFamilyDescriptor columnFamily) |
static ColumnFamilyDescriptorBuilder |
ColumnFamilyDescriptorBuilder.newBuilder(ColumnFamilyDescriptor desc) |
private TableDescriptorBuilder.ModifyableTableDescriptor |
TableDescriptorBuilder.ModifyableTableDescriptor.putColumnFamily(ColumnFamilyDescriptor family) |
TableDescriptorBuilder |
TableDescriptorBuilder.setColumnFamily(ColumnFamilyDescriptor family) |
TableDescriptorBuilder.ModifyableTableDescriptor |
TableDescriptorBuilder.ModifyableTableDescriptor.setColumnFamily(ColumnFamilyDescriptor family)
Adds a column family.
|
static byte[] |
ColumnFamilyDescriptorBuilder.toByteArray(ColumnFamilyDescriptor desc)
Serialize the table descriptor to a byte array.
|
Modifier and Type | Method and Description |
---|---|
static Comparator<TableDescriptor> |
TableDescriptor.getComparator(Comparator<ColumnFamilyDescriptor> cfComparator) |
TableDescriptorBuilder |
TableDescriptorBuilder.setColumnFamilies(Collection<ColumnFamilyDescriptor> families) |
Constructor and Description |
---|
ColumnFamilyDescriptorBuilder(ColumnFamilyDescriptor desc) |
ModifyableColumnFamilyDescriptor(ColumnFamilyDescriptor desc)
Constructor.
|
Constructor and Description |
---|
ModifyableTableDescriptor(TableName name,
Collection<ColumnFamilyDescriptor> families,
Map<Bytes,Bytes> values) |
Constructor and Description |
---|
CacheConfig(org.apache.hadoop.conf.Configuration conf,
ColumnFamilyDescriptor family,
BlockCache blockCache,
ByteBuffAllocator byteBuffAllocator)
Create a cache configuration using the specified configuration object and family descriptor.
|
Modifier and Type | Field and Description |
---|---|
(package private) static Function<ColumnFamilyDescriptor,String> |
HFileOutputFormat2.blockSizeDetails
Serialize column family to block size map to configuration.
|
(package private) static Function<ColumnFamilyDescriptor,String> |
HFileOutputFormat2.bloomParamDetails
Serialize column family to bloom param map to configuration.
|
(package private) static Function<ColumnFamilyDescriptor,String> |
HFileOutputFormat2.bloomTypeDetails
Serialize column family to bloom type map to configuration.
|
(package private) static Function<ColumnFamilyDescriptor,String> |
HFileOutputFormat2.compressionDetails
Serialize column family to compression algorithm map to configuration.
|
(package private) static Function<ColumnFamilyDescriptor,String> |
HFileOutputFormat2.dataBlockEncodingDetails
Serialize column family to data block encoding map to configuration.
|
Modifier and Type | Method and Description |
---|---|
(package private) static String |
HFileOutputFormat2.serializeColumnFamilyAttribute(Function<ColumnFamilyDescriptor,String> fn,
List<TableDescriptor> allTables) |
Modifier and Type | Method and Description |
---|---|
long |
HMaster.addColumn(TableName tableName,
ColumnFamilyDescriptor column,
long nonceGroup,
long nonce) |
long |
MasterServices.addColumn(TableName tableName,
ColumnFamilyDescriptor column,
long nonceGroup,
long nonce)
Add a new column to an existing table
|
long |
HMaster.modifyColumn(TableName tableName,
ColumnFamilyDescriptor descriptor,
long nonceGroup,
long nonce) |
long |
MasterServices.modifyColumn(TableName tableName,
ColumnFamilyDescriptor descriptor,
long nonceGroup,
long nonce)
Modify the column descriptor of an existing column in an existing table
|
Modifier and Type | Method and Description |
---|---|
static List<ColumnFamilyDescriptor> |
MobUtils.getMobColumnFamilies(TableDescriptor htd)
Get list of Mob column families (if any exists)
|
Modifier and Type | Method and Description |
---|---|
static void |
MobUtils.cleanExpiredMobFiles(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.conf.Configuration conf,
TableName tableName,
ColumnFamilyDescriptor columnDescriptor,
CacheConfig cacheConfig,
long current)
Cleans the expired mob files.
|
void |
ExpiredMobFileCleaner.cleanExpiredMobFiles(String tableName,
ColumnFamilyDescriptor family)
Cleans the MOB files when they're expired and their min versions are 0.
|
static StoreFileWriter |
MobUtils.createWriter(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
ColumnFamilyDescriptor family,
MobFileName mobFileName,
org.apache.hadoop.fs.Path basePath,
long maxKeyCount,
Compression.Algorithm compression,
CacheConfig cacheConfig,
Encryption.Context cryptoContext,
boolean isCompaction)
Creates a writer for the mob file in temp directory.
|
static StoreFileWriter |
MobUtils.createWriter(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
ColumnFamilyDescriptor family,
org.apache.hadoop.fs.Path path,
long maxKeyCount,
Compression.Algorithm compression,
CacheConfig cacheConfig,
Encryption.Context cryptoContext,
ChecksumType checksumType,
int bytesPerChecksum,
int blocksize,
BloomType bloomType,
boolean isCompaction)
Creates a writer for the mob file in temp directory.
|
static StoreFileWriter |
MobUtils.createWriter(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
ColumnFamilyDescriptor family,
org.apache.hadoop.fs.Path path,
long maxKeyCount,
Compression.Algorithm compression,
CacheConfig cacheConfig,
Encryption.Context cryptoContext,
ChecksumType checksumType,
int bytesPerChecksum,
int blocksize,
BloomType bloomType,
boolean isCompaction,
Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)
Creates a writer for the mob file in temp directory.
|
static StoreFileWriter |
MobUtils.createWriter(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
ColumnFamilyDescriptor family,
String date,
org.apache.hadoop.fs.Path basePath,
long maxKeyCount,
Compression.Algorithm compression,
String startKey,
CacheConfig cacheConfig,
Encryption.Context cryptoContext,
boolean isCompaction,
String regionName)
Creates a writer for the mob file in temp directory.
|
static boolean |
MobUtils.isMobFileExpired(ColumnFamilyDescriptor column,
long current,
String fileDate)
Checks if the mob file is expired.
|
void |
MobFileCompactionChore.performMajorCompactionInBatches(Admin admin,
TableDescriptor htd,
ColumnFamilyDescriptor hcd) |
Modifier and Type | Field and Description |
---|---|
private ColumnFamilyDescriptor |
StoreContext.family |
private ColumnFamilyDescriptor |
StoreContext.Builder.family |
Modifier and Type | Method and Description |
---|---|
ColumnFamilyDescriptor |
Store.getColumnFamilyDescriptor() |
ColumnFamilyDescriptor |
HStore.getColumnFamilyDescriptor() |
ColumnFamilyDescriptor |
StoreContext.getFamily() |
Modifier and Type | Method and Description |
---|---|
protected CacheConfig |
HStore.createCacheConf(ColumnFamilyDescriptor family)
Creates the cache config.
|
static org.apache.hadoop.conf.Configuration |
StoreUtils.createStoreConfiguration(org.apache.hadoop.conf.Configuration conf,
TableDescriptor td,
ColumnFamilyDescriptor cfd) |
static long |
HStore.determineTTLFromFamily(ColumnFamilyDescriptor family)
Returns TTL in seconds of the specified family
|
private StoreContext |
HStore.initializeStoreContext(ColumnFamilyDescriptor family) |
protected HStore |
HRegion.instantiateHStore(ColumnFamilyDescriptor family,
boolean warmup) |
StoreContext.Builder |
StoreContext.Builder.withColumnFamilyDescriptor(ColumnFamilyDescriptor family) |
Constructor and Description |
---|
HMobStore(HRegion region,
ColumnFamilyDescriptor family,
org.apache.hadoop.conf.Configuration confParam,
boolean warmup) |
HStore(HRegion region,
ColumnFamilyDescriptor family,
org.apache.hadoop.conf.Configuration confParam,
boolean warmup)
Constructor
|
ScanInfo(org.apache.hadoop.conf.Configuration conf,
ColumnFamilyDescriptor family,
long ttl,
long timeToPurgeDeletes,
CellComparator comparator) |
Modifier and Type | Method and Description |
---|---|
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.
|
private static org.apache.hadoop.conf.Configuration |
StoreFileTrackerFactory.mergeConfigurations(org.apache.hadoop.conf.Configuration global,
TableDescriptor table,
ColumnFamilyDescriptor family) |
Modifier and Type | Method and Description |
---|---|
static Encryption.Context |
EncryptionUtil.createEncryptionContext(org.apache.hadoop.conf.Configuration conf,
ColumnFamilyDescriptor family)
Helper to create an encyption context.
|
Modifier and Type | Method and Description |
---|---|
static ColumnFamilyDescriptor |
ThriftUtilities.colDescFromThrift(org.apache.hadoop.hbase.thrift.generated.ColumnDescriptor in)
This utility method creates a new Hbase HColumnDescriptor object based on a Thrift
ColumnDescriptor "struct".
|
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.hbase.thrift.generated.ColumnDescriptor |
ThriftUtilities.colDescFromHbase(ColumnFamilyDescriptor in)
This utility method creates a new Thrift ColumnDescriptor "struct" based on an Hbase
HColumnDescriptor object.
|
Modifier and Type | Method and Description |
---|---|
static ColumnFamilyDescriptor |
ThriftUtilities.columnFamilyDescriptorFromThrift(org.apache.hadoop.hbase.thrift2.generated.TColumnFamilyDescriptor in) |
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.hbase.thrift2.generated.TColumnFamilyDescriptor |
ThriftUtilities.columnFamilyDescriptorFromHBase(ColumnFamilyDescriptor in) |
Modifier and Type | Method and Description |
---|---|
void |
ThriftAdmin.addColumnFamily(TableName tableName,
ColumnFamilyDescriptor columnFamily) |
Future<Void> |
ThriftAdmin.addColumnFamilyAsync(TableName tableName,
ColumnFamilyDescriptor columnFamily) |
void |
ThriftAdmin.modifyColumnFamily(TableName tableName,
ColumnFamilyDescriptor columnFamily) |
Future<Void> |
ThriftAdmin.modifyColumnFamilyAsync(TableName tableName,
ColumnFamilyDescriptor columnFamily) |
Modifier and Type | Field and Description |
---|---|
private ColumnFamilyDescriptor |
CanaryTool.RegionTaskResult.column |
Modifier and Type | Method and Description |
---|---|
ColumnFamilyDescriptor |
CanaryTool.RegionTaskResult.getColumnFamily() |
private ColumnFamilyDescriptor |
CanaryTool.RegionTask.randomPickOneColumnFamily(ColumnFamilyDescriptor[] cfs) |
Modifier and Type | Method and Description |
---|---|
private static void |
BulkLoadHFilesTool.copyHFileHalf(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.Path inFile,
org.apache.hadoop.fs.Path outFile,
Reference reference,
ColumnFamilyDescriptor familyDescriptor,
AsyncTableRegionLocator loc)
Copy half of an HFile into a new HFile with favored nodes.
|
void |
CanaryTool.RegionStdOutSink.publishReadFailure(ServerName serverName,
RegionInfo region,
ColumnFamilyDescriptor column,
Exception e) |
void |
CanaryTool.RegionStdOutSink.publishReadTiming(ServerName serverName,
RegionInfo region,
ColumnFamilyDescriptor column,
long msTime) |
void |
CanaryTool.RegionStdOutSink.publishWriteFailure(ServerName serverName,
RegionInfo region,
ColumnFamilyDescriptor column,
Exception e) |
void |
CanaryTool.RegionStdOutSink.publishWriteTiming(ServerName serverName,
RegionInfo region,
ColumnFamilyDescriptor column,
long msTime) |
private ColumnFamilyDescriptor |
CanaryTool.RegionTask.randomPickOneColumnFamily(ColumnFamilyDescriptor[] cfs) |
private Void |
CanaryTool.RegionTask.readColumnFamily(Table table,
ColumnFamilyDescriptor column) |
(package private) static void |
BulkLoadHFilesTool.splitStoreFile(AsyncTableRegionLocator loc,
org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.Path inFile,
ColumnFamilyDescriptor familyDesc,
byte[] splitKey,
org.apache.hadoop.fs.Path bottomOut,
org.apache.hadoop.fs.Path topOut)
Split a storefile into a top and bottom half with favored nodes, maintaining the metadata,
recreating bloom filters, etc.
|
Constructor and Description |
---|
RegionTaskResult(RegionInfo region,
TableName tableName,
ServerName serverName,
ColumnFamilyDescriptor column) |
Modifier and Type | Method and Description |
---|---|
static ColumnFamilyDescriptor |
FSTableDescriptors.getReplBarrierFamilyDescForMeta() |
static ColumnFamilyDescriptor |
FSTableDescriptors.getTableFamilyDescForMeta(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
private long |
MajorCompactionTTLRequest.getColFamilyCutoffTime(ColumnFamilyDescriptor colDesc) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.