HBASE-4486 Improve Javadoc for HTableDescriptor
git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1186559 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
9dce8043bd
commit
e6c422defe
|
@ -630,6 +630,7 @@ Release 0.92.0 - Unreleased
|
||||||
HBASE-4606 Remove spam in HCM and fix a list.size == 0
|
HBASE-4606 Remove spam in HCM and fix a list.size == 0
|
||||||
HBASE-3581 hbase rpc should send size of response
|
HBASE-3581 hbase rpc should send size of response
|
||||||
HBASE-4585 Avoid seek operation when current kv is deleted(Liyin Tang)
|
HBASE-4585 Avoid seek operation when current kv is deleted(Liyin Tang)
|
||||||
|
HBASE-4486 Improve Javadoc for HTableDescriptor (Akash Ashok)
|
||||||
|
|
||||||
|
|
||||||
TASKS
|
TASKS
|
||||||
|
|
|
@ -39,82 +39,137 @@ import org.apache.hadoop.hbase.util.Bytes;
|
||||||
import org.apache.hadoop.io.WritableComparable;
|
import org.apache.hadoop.io.WritableComparable;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* HTableDescriptor contains the name of an HTable, and its
|
* HTableDescriptor contains the details about an HBase table such as the descriptors of
|
||||||
* column families.
|
* all the column families, is the table a catalog table, <code> -ROOT- </code> or
|
||||||
|
* <code> .META. </code>, is the table is read only, the maximum size of the memstore,
|
||||||
|
* when the region split should occur, coprocessors associated with it etc...
|
||||||
*/
|
*/
|
||||||
public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
|
|
||||||
// Changes prior to version 3 were not recorded here.
|
/**
|
||||||
// Version 3 adds metadata as a map where keys and values are byte[].
|
* Changes prior to version 3 were not recorded here.
|
||||||
// Version 4 adds indexes
|
* Version 3 adds metadata as a map where keys and values are byte[].
|
||||||
// Version 5 removed transactional pollution -- e.g. indexes
|
* Version 4 adds indexes
|
||||||
public static final byte TABLE_DESCRIPTOR_VERSION = 5;
|
* Version 5 removed transactional pollution -- e.g. indexes
|
||||||
|
*/
|
||||||
|
private static final byte TABLE_DESCRIPTOR_VERSION = 5;
|
||||||
|
|
||||||
private byte [] name = HConstants.EMPTY_BYTE_ARRAY;
|
private byte [] name = HConstants.EMPTY_BYTE_ARRAY;
|
||||||
|
|
||||||
private String nameAsString = "";
|
private String nameAsString = "";
|
||||||
|
|
||||||
// Table metadata
|
/**
|
||||||
|
* A map which holds the metadata information of the table. This metadata
|
||||||
|
* includes values like IS_ROOT, IS_META, DEFERRED_LOG_FLUSH, SPLIT_POLICY,
|
||||||
|
* MAX_FILE_SIZE, READONLY, MEMSTORE_FLUSHSIZE etc...
|
||||||
|
*/
|
||||||
protected Map<ImmutableBytesWritable, ImmutableBytesWritable> values =
|
protected Map<ImmutableBytesWritable, ImmutableBytesWritable> values =
|
||||||
new HashMap<ImmutableBytesWritable, ImmutableBytesWritable>();
|
new HashMap<ImmutableBytesWritable, ImmutableBytesWritable>();
|
||||||
|
|
||||||
public static final String FAMILIES = "FAMILIES";
|
private static final String FAMILIES = "FAMILIES";
|
||||||
public static final ImmutableBytesWritable FAMILIES_KEY =
|
|
||||||
new ImmutableBytesWritable(Bytes.toBytes(FAMILIES));
|
private static final String SPLIT_POLICY = "SPLIT_POLICY";
|
||||||
|
|
||||||
|
/**
|
||||||
|
* <em>INTERNAL</em> Used by HBase Shell interface to access this metadata
|
||||||
|
* attribute which denotes the maximum size of the store file after which
|
||||||
|
* a region split occurs
|
||||||
|
*
|
||||||
|
* @see #getMaxFileSize()
|
||||||
|
*/
|
||||||
public static final String MAX_FILESIZE = "MAX_FILESIZE";
|
public static final String MAX_FILESIZE = "MAX_FILESIZE";
|
||||||
public static final ImmutableBytesWritable MAX_FILESIZE_KEY =
|
private static final ImmutableBytesWritable MAX_FILESIZE_KEY =
|
||||||
new ImmutableBytesWritable(Bytes.toBytes(MAX_FILESIZE));
|
new ImmutableBytesWritable(Bytes.toBytes(MAX_FILESIZE));
|
||||||
|
|
||||||
// The class which determines when a region should split
|
/**
|
||||||
public static final String SPLIT_POLICY = "SPLIT_POLICY";
|
* <em>INTERNAL</em> Used by rest interface to access this metadata
|
||||||
public static final ImmutableBytesWritable SPLIT_POLICY_KEY =
|
* attribute which denotes if the table is Read Only
|
||||||
new ImmutableBytesWritable(Bytes.toBytes(SPLIT_POLICY));
|
*
|
||||||
|
* @see #isReadOnly()
|
||||||
|
*/
|
||||||
public static final String READONLY = "READONLY";
|
public static final String READONLY = "READONLY";
|
||||||
public static final ImmutableBytesWritable READONLY_KEY =
|
private static final ImmutableBytesWritable READONLY_KEY =
|
||||||
new ImmutableBytesWritable(Bytes.toBytes(READONLY));
|
new ImmutableBytesWritable(Bytes.toBytes(READONLY));
|
||||||
public static final String MEMSTORE_FLUSHSIZE = "MEMSTORE_FLUSHSIZE";
|
|
||||||
public static final ImmutableBytesWritable MEMSTORE_FLUSHSIZE_KEY =
|
|
||||||
new ImmutableBytesWritable(Bytes.toBytes(MEMSTORE_FLUSHSIZE));
|
|
||||||
public static final String IS_ROOT = "IS_ROOT";
|
|
||||||
public static final ImmutableBytesWritable IS_ROOT_KEY =
|
|
||||||
new ImmutableBytesWritable(Bytes.toBytes(IS_ROOT));
|
|
||||||
public static final String IS_META = "IS_META";
|
|
||||||
|
|
||||||
public static final ImmutableBytesWritable IS_META_KEY =
|
/**
|
||||||
|
* <em>INTERNAL</em> Used by HBase Shell interface to access this metadata
|
||||||
|
* attribute which represents the maximum size of the memstore after which
|
||||||
|
* its contents are flushed onto the disk
|
||||||
|
*
|
||||||
|
* @see #getMemStoreFlushSize()
|
||||||
|
*/
|
||||||
|
public static final String MEMSTORE_FLUSHSIZE = "MEMSTORE_FLUSHSIZE";
|
||||||
|
private static final ImmutableBytesWritable MEMSTORE_FLUSHSIZE_KEY =
|
||||||
|
new ImmutableBytesWritable(Bytes.toBytes(MEMSTORE_FLUSHSIZE));
|
||||||
|
|
||||||
|
/**
|
||||||
|
* <em>INTERNAL</em> Used by rest interface to access this metadata
|
||||||
|
* attribute which denotes if the table is a -ROOT- region or not
|
||||||
|
*
|
||||||
|
* @see #isRootRegion()
|
||||||
|
*/
|
||||||
|
public static final String IS_ROOT = "IS_ROOT";
|
||||||
|
private static final ImmutableBytesWritable IS_ROOT_KEY =
|
||||||
|
new ImmutableBytesWritable(Bytes.toBytes(IS_ROOT));
|
||||||
|
|
||||||
|
/**
|
||||||
|
* <em>INTERNAL</em> Used by rest interface to access this metadata
|
||||||
|
* attribute which denotes if it is a catalog table, either
|
||||||
|
* <code> .META. </code> or <code> -ROOT- </code>
|
||||||
|
*
|
||||||
|
* @see #isMetaRegion()
|
||||||
|
*/
|
||||||
|
public static final String IS_META = "IS_META";
|
||||||
|
private static final ImmutableBytesWritable IS_META_KEY =
|
||||||
new ImmutableBytesWritable(Bytes.toBytes(IS_META));
|
new ImmutableBytesWritable(Bytes.toBytes(IS_META));
|
||||||
|
|
||||||
|
/**
|
||||||
|
* <em>INTERNAL</em> Used by HBase Shell interface to access this metadata
|
||||||
|
* attribute which denotes if the deferred log flush option is enabled
|
||||||
|
*
|
||||||
|
* @see #getDeferredLogFlush()
|
||||||
|
*/
|
||||||
public static final String DEFERRED_LOG_FLUSH = "DEFERRED_LOG_FLUSH";
|
public static final String DEFERRED_LOG_FLUSH = "DEFERRED_LOG_FLUSH";
|
||||||
public static final ImmutableBytesWritable DEFERRED_LOG_FLUSH_KEY =
|
private static final ImmutableBytesWritable DEFERRED_LOG_FLUSH_KEY =
|
||||||
new ImmutableBytesWritable(Bytes.toBytes(DEFERRED_LOG_FLUSH));
|
new ImmutableBytesWritable(Bytes.toBytes(DEFERRED_LOG_FLUSH));
|
||||||
|
|
||||||
|
/*
|
||||||
// The below are ugly but better than creating them each time till we
|
* The below are ugly but better than creating them each time till we
|
||||||
// replace booleans being saved as Strings with plain booleans. Need a
|
* replace booleans being saved as Strings with plain booleans. Need a
|
||||||
// migration script to do this. TODO.
|
* migration script to do this. TODO.
|
||||||
|
*/
|
||||||
private static final ImmutableBytesWritable FALSE =
|
private static final ImmutableBytesWritable FALSE =
|
||||||
new ImmutableBytesWritable(Bytes.toBytes(Boolean.FALSE.toString()));
|
new ImmutableBytesWritable(Bytes.toBytes(Boolean.FALSE.toString()));
|
||||||
|
|
||||||
private static final ImmutableBytesWritable TRUE =
|
private static final ImmutableBytesWritable TRUE =
|
||||||
new ImmutableBytesWritable(Bytes.toBytes(Boolean.TRUE.toString()));
|
new ImmutableBytesWritable(Bytes.toBytes(Boolean.TRUE.toString()));
|
||||||
|
|
||||||
|
private static final boolean DEFAULT_DEFERRED_LOG_FLUSH = false;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Constant that denotes whether the table is READONLY by default and is false
|
||||||
|
*/
|
||||||
public static final boolean DEFAULT_READONLY = false;
|
public static final boolean DEFAULT_READONLY = false;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Constant that denotes the maximum default size of the memstore after which
|
||||||
|
* the contents are flushed to the store files
|
||||||
|
*/
|
||||||
public static final long DEFAULT_MEMSTORE_FLUSH_SIZE = 1024*1024*64L;
|
public static final long DEFAULT_MEMSTORE_FLUSH_SIZE = 1024*1024*64L;
|
||||||
|
|
||||||
public static final long DEFAULT_MAX_FILESIZE = 1024*1024*256L;
|
|
||||||
|
|
||||||
public static final boolean DEFAULT_DEFERRED_LOG_FLUSH = false;
|
|
||||||
|
|
||||||
private volatile Boolean meta = null;
|
private volatile Boolean meta = null;
|
||||||
private volatile Boolean root = null;
|
private volatile Boolean root = null;
|
||||||
private Boolean isDeferredLog = null;
|
private Boolean isDeferredLog = null;
|
||||||
|
|
||||||
// Key is hash of the family name.
|
/**
|
||||||
public final Map<byte [], HColumnDescriptor> families =
|
* Maps column family name to the respective HColumnDescriptors
|
||||||
|
*/
|
||||||
|
private final Map<byte [], HColumnDescriptor> families =
|
||||||
new TreeMap<byte [], HColumnDescriptor>(Bytes.BYTES_RAWCOMPARATOR);
|
new TreeMap<byte [], HColumnDescriptor>(Bytes.BYTES_RAWCOMPARATOR);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Private constructor used internally creating table descriptors for
|
* <em> INTERNAL </em> Private constructor used internally creating table descriptors for
|
||||||
* catalog tables: e.g. .META. and -ROOT-.
|
* catalog tables, <code>.META.</code> and <code>-ROOT-</code>.
|
||||||
*/
|
*/
|
||||||
protected HTableDescriptor(final byte [] name, HColumnDescriptor[] families) {
|
protected HTableDescriptor(final byte [] name, HColumnDescriptor[] families) {
|
||||||
this.name = name.clone();
|
this.name = name.clone();
|
||||||
|
@ -126,8 +181,8 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Private constructor used internally creating table descriptors for
|
* <em> INTERNAL </em>Private constructor used internally creating table descriptors for
|
||||||
* catalog tables: e.g. .META. and -ROOT-.
|
* catalog tables, <code>.META.</code> and <code>-ROOT-</code>.
|
||||||
*/
|
*/
|
||||||
protected HTableDescriptor(final byte [] name, HColumnDescriptor[] families,
|
protected HTableDescriptor(final byte [] name, HColumnDescriptor[] families,
|
||||||
Map<ImmutableBytesWritable,ImmutableBytesWritable> values) {
|
Map<ImmutableBytesWritable,ImmutableBytesWritable> values) {
|
||||||
|
@ -143,9 +198,8 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Constructs an empty object.
|
* Default constructor which constructs an empty object.
|
||||||
* For deserializing an HTableDescriptor instance only.
|
* For deserializing an HTableDescriptor instance only.
|
||||||
* @see #HTableDescriptor(byte[])
|
* @see #HTableDescriptor(byte[])
|
||||||
*/
|
*/
|
||||||
|
@ -154,7 +208,7 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Constructor.
|
* Construct a table descriptor specifying table name.
|
||||||
* @param name Table name.
|
* @param name Table name.
|
||||||
* @throws IllegalArgumentException if passed a table name
|
* @throws IllegalArgumentException if passed a table name
|
||||||
* that is made of other than 'word' characters, underscore or period: i.e.
|
* that is made of other than 'word' characters, underscore or period: i.e.
|
||||||
|
@ -166,8 +220,8 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Constructor.
|
* Construct a table descriptor specifying a byte array table name
|
||||||
* @param name Table name.
|
* @param name - Table name as a byte array.
|
||||||
* @throws IllegalArgumentException if passed a table name
|
* @throws IllegalArgumentException if passed a table name
|
||||||
* that is made of other than 'word' characters, underscore or period: i.e.
|
* that is made of other than 'word' characters, underscore or period: i.e.
|
||||||
* <code>[a-zA-Z_0-9-.].
|
* <code>[a-zA-Z_0-9-.].
|
||||||
|
@ -181,7 +235,7 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Constructor.
|
* Construct a table descriptor by cloning the descriptor passed as a parameter.
|
||||||
* <p>
|
* <p>
|
||||||
* Makes a deep copy of the supplied descriptor.
|
* Makes a deep copy of the supplied descriptor.
|
||||||
* Can make a modifiable descriptor from an UnmodifyableHTableDescriptor.
|
* Can make a modifiable descriptor from an UnmodifyableHTableDescriptor.
|
||||||
|
@ -203,6 +257,8 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Set meta flags on this table.
|
* Set meta flags on this table.
|
||||||
|
* IS_ROOT_KEY is set if its a -ROOT- table
|
||||||
|
* IS_META_KEY is set either if its a -ROOT- or a .META. table
|
||||||
* Called by constructors.
|
* Called by constructors.
|
||||||
* @param name
|
* @param name
|
||||||
*/
|
*/
|
||||||
|
@ -212,7 +268,11 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
Bytes.equals(name, HConstants.META_TABLE_NAME));
|
Bytes.equals(name, HConstants.META_TABLE_NAME));
|
||||||
}
|
}
|
||||||
|
|
||||||
/** @return true if this is the root region */
|
/**
|
||||||
|
* Check if the descriptor represents a <code> -ROOT- </code> region.
|
||||||
|
*
|
||||||
|
* @return true if this is a <code> -ROOT- </code> region
|
||||||
|
*/
|
||||||
public boolean isRootRegion() {
|
public boolean isRootRegion() {
|
||||||
if (this.root == null) {
|
if (this.root == null) {
|
||||||
this.root = isSomething(IS_ROOT_KEY, false)? Boolean.TRUE: Boolean.FALSE;
|
this.root = isSomething(IS_ROOT_KEY, false)? Boolean.TRUE: Boolean.FALSE;
|
||||||
|
@ -220,13 +280,25 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
return this.root.booleanValue();
|
return this.root.booleanValue();
|
||||||
}
|
}
|
||||||
|
|
||||||
/** @param isRoot true if this is the root region */
|
/**
|
||||||
|
* <em> INTERNAL </em> Used to denote if the current table represents
|
||||||
|
* <code> -ROOT- </code> region. This is used internally by the
|
||||||
|
* HTableDescriptor constructors
|
||||||
|
*
|
||||||
|
* @param isRoot true if this is the <code> -ROOT- </code> region
|
||||||
|
*/
|
||||||
protected void setRootRegion(boolean isRoot) {
|
protected void setRootRegion(boolean isRoot) {
|
||||||
// TODO: Make the value a boolean rather than String of boolean.
|
// TODO: Make the value a boolean rather than String of boolean.
|
||||||
values.put(IS_ROOT_KEY, isRoot? TRUE: FALSE);
|
values.put(IS_ROOT_KEY, isRoot? TRUE: FALSE);
|
||||||
}
|
}
|
||||||
|
|
||||||
/** @return true if this is a meta region (part of the root or meta tables) */
|
/**
|
||||||
|
* Checks if this table is either <code> -ROOT- </code> or <code> .META. </code>
|
||||||
|
* region.
|
||||||
|
*
|
||||||
|
* @return true if this is either a <code> -ROOT- </code> or <code> .META. </code>
|
||||||
|
* region
|
||||||
|
*/
|
||||||
public boolean isMetaRegion() {
|
public boolean isMetaRegion() {
|
||||||
if (this.meta == null) {
|
if (this.meta == null) {
|
||||||
this.meta = calculateIsMetaRegion();
|
this.meta = calculateIsMetaRegion();
|
||||||
|
@ -250,61 +322,73 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param isMeta true if this is a meta region (part of the root or meta
|
* <em> INTERNAL </em> Used to denote if the current table represents
|
||||||
* tables) */
|
* <code> -ROOT- </code> or <code> .META. </code> region. This is used
|
||||||
|
* internally by the HTableDescriptor constructors
|
||||||
|
*
|
||||||
|
* @param isMeta true if its either <code> -ROOT- </code> or
|
||||||
|
* <code> .META. </code> region
|
||||||
|
*/
|
||||||
protected void setMetaRegion(boolean isMeta) {
|
protected void setMetaRegion(boolean isMeta) {
|
||||||
values.put(IS_META_KEY, isMeta? TRUE: FALSE);
|
values.put(IS_META_KEY, isMeta? TRUE: FALSE);
|
||||||
}
|
}
|
||||||
|
|
||||||
/** @return true if table is a meta table, either <code>.META.</code> or
|
/**
|
||||||
* <code>-ROOT-</code>
|
* Checks if the table is a <code>.META.</code> table
|
||||||
|
*
|
||||||
|
* @return true if table is <code> .META. </code> region.
|
||||||
*/
|
*/
|
||||||
public boolean isMetaTable() {
|
public boolean isMetaTable() {
|
||||||
return isMetaRegion() && !isRootRegion();
|
return isMetaRegion() && !isRootRegion();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param n Table name.
|
* Checks of the tableName being passed represents either
|
||||||
* @return True if a catalog table, -ROOT- or .META.
|
* <code > -ROOT- </code> or <code> .META. </code>
|
||||||
|
*
|
||||||
|
* @return true if a tablesName is either <code> -ROOT- </code>
|
||||||
|
* or <code> .META. </code>
|
||||||
*/
|
*/
|
||||||
public static boolean isMetaTable(final byte [] n) {
|
public static boolean isMetaTable(final byte [] tableName) {
|
||||||
return Bytes.equals(n, HConstants.ROOT_TABLE_NAME) ||
|
return Bytes.equals(tableName, HConstants.ROOT_TABLE_NAME) ||
|
||||||
Bytes.equals(n, HConstants.META_TABLE_NAME);
|
Bytes.equals(tableName, HConstants.META_TABLE_NAME);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Check passed buffer is legal user-space table name.
|
* Check passed byte buffer, "tableName", is legal user-space table name.
|
||||||
* @param b Table name.
|
* @return Returns passed <code>tableName</code> param
|
||||||
* @return Returns passed <code>b</code> param
|
* @throws NullPointerException If passed <code>tableName</code> is null
|
||||||
* @throws NullPointerException If passed <code>b</code> is null
|
* @throws IllegalArgumentException if passed a tableName
|
||||||
* @throws IllegalArgumentException if passed a table name
|
|
||||||
* that is made of other than 'word' characters or underscores: i.e.
|
* that is made of other than 'word' characters or underscores: i.e.
|
||||||
* <code>[a-zA-Z_0-9].
|
* <code>[a-zA-Z_0-9].
|
||||||
*/
|
*/
|
||||||
public static byte [] isLegalTableName(final byte [] b) {
|
public static byte [] isLegalTableName(final byte [] tableName) {
|
||||||
if (b == null || b.length <= 0) {
|
if (tableName == null || tableName.length <= 0) {
|
||||||
throw new IllegalArgumentException("Name is null or empty");
|
throw new IllegalArgumentException("Name is null or empty");
|
||||||
}
|
}
|
||||||
if (b[0] == '.' || b[0] == '-') {
|
if (tableName[0] == '.' || tableName[0] == '-') {
|
||||||
throw new IllegalArgumentException("Illegal first character <" + b[0] +
|
throw new IllegalArgumentException("Illegal first character <" + tableName[0] +
|
||||||
"> at 0. User-space table names can only start with 'word " +
|
"> at 0. User-space table names can only start with 'word " +
|
||||||
"characters': i.e. [a-zA-Z_0-9]: " + Bytes.toString(b));
|
"characters': i.e. [a-zA-Z_0-9]: " + Bytes.toString(tableName));
|
||||||
}
|
}
|
||||||
for (int i = 0; i < b.length; i++) {
|
for (int i = 0; i < tableName.length; i++) {
|
||||||
if (Character.isLetterOrDigit(b[i]) || b[i] == '_' || b[i] == '-' ||
|
if (Character.isLetterOrDigit(tableName[i]) || tableName[i] == '_' ||
|
||||||
b[i] == '.') {
|
tableName[i] == '-' || tableName[i] == '.') {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
throw new IllegalArgumentException("Illegal character <" + b[i] +
|
throw new IllegalArgumentException("Illegal character <" + tableName[i] +
|
||||||
"> at " + i + ". User-space table names can only contain " +
|
"> at " + i + ". User-space table names can only contain " +
|
||||||
"'word characters': i.e. [a-zA-Z_0-9-.]: " + Bytes.toString(b));
|
"'word characters': i.e. [a-zA-Z_0-9-.]: " + Bytes.toString(tableName));
|
||||||
}
|
}
|
||||||
return b;
|
return tableName;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
* Getter for accessing the metadata associated with the key
|
||||||
|
*
|
||||||
* @param key The key.
|
* @param key The key.
|
||||||
* @return The value.
|
* @return The value.
|
||||||
|
* @see #values
|
||||||
*/
|
*/
|
||||||
public byte[] getValue(byte[] key) {
|
public byte[] getValue(byte[] key) {
|
||||||
return getValue(new ImmutableBytesWritable(key));
|
return getValue(new ImmutableBytesWritable(key));
|
||||||
|
@ -318,8 +402,11 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
* Getter for accessing the metadata associated with the key
|
||||||
|
*
|
||||||
* @param key The key.
|
* @param key The key.
|
||||||
* @return The value as a string.
|
* @return The value.
|
||||||
|
* @see #values
|
||||||
*/
|
*/
|
||||||
public String getValue(String key) {
|
public String getValue(String key) {
|
||||||
byte[] value = getValue(Bytes.toBytes(key));
|
byte[] value = getValue(Bytes.toBytes(key));
|
||||||
|
@ -329,15 +416,21 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @return All values.
|
* Getter for fetching an unmodifiable {@link #values} map.
|
||||||
|
*
|
||||||
|
* @return unmodifiable map {@link #values}.
|
||||||
|
* @see #values
|
||||||
*/
|
*/
|
||||||
public Map<ImmutableBytesWritable,ImmutableBytesWritable> getValues() {
|
public Map<ImmutableBytesWritable,ImmutableBytesWritable> getValues() {
|
||||||
return Collections.unmodifiableMap(values);
|
return Collections.unmodifiableMap(values);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
* Setter for storing metadata as a (key, value) pair in {@link #values} map
|
||||||
|
*
|
||||||
* @param key The key.
|
* @param key The key.
|
||||||
* @param value The value.
|
* @param value The value.
|
||||||
|
* @see #values
|
||||||
*/
|
*/
|
||||||
public void setValue(byte[] key, byte[] value) {
|
public void setValue(byte[] key, byte[] value) {
|
||||||
setValue(new ImmutableBytesWritable(key), value);
|
setValue(new ImmutableBytesWritable(key), value);
|
||||||
|
@ -362,21 +455,30 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
* Setter for storing metadata as a (key, value) pair in {@link #values} map
|
||||||
|
*
|
||||||
* @param key The key.
|
* @param key The key.
|
||||||
* @param value The value.
|
* @param value The value.
|
||||||
|
* @see #values
|
||||||
*/
|
*/
|
||||||
public void setValue(String key, String value) {
|
public void setValue(String key, String value) {
|
||||||
setValue(Bytes.toBytes(key), Bytes.toBytes(value));
|
setValue(Bytes.toBytes(key), Bytes.toBytes(value));
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param key Key whose key and value we're to remove from HTD parameters.
|
* Remove metadata represented by the key from the {@link #values} map
|
||||||
|
*
|
||||||
|
* @param key Key whose key and value we're to remove from HTableDescriptor
|
||||||
|
* parameters.
|
||||||
*/
|
*/
|
||||||
public void remove(final byte [] key) {
|
public void remove(final byte [] key) {
|
||||||
values.remove(new ImmutableBytesWritable(key));
|
values.remove(new ImmutableBytesWritable(key));
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
* Check if the readOnly flag of the table is set. If the readOnly flag is
|
||||||
|
* set then the contents of the table can only be read from but not modified.
|
||||||
|
*
|
||||||
* @return true if all columns in the table should be read only
|
* @return true if all columns in the table should be read only
|
||||||
*/
|
*/
|
||||||
public boolean isReadOnly() {
|
public boolean isReadOnly() {
|
||||||
|
@ -384,6 +486,10 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
* Setting the table as read only sets all the columns in the table as read
|
||||||
|
* only. By default all tables are modifiable, but if the readOnly flag is
|
||||||
|
* set to true then the contents of the table can only be read but not modified.
|
||||||
|
*
|
||||||
* @param readOnly True if all of the columns in the table should be read
|
* @param readOnly True if all of the columns in the table should be read
|
||||||
* only.
|
* only.
|
||||||
*/
|
*/
|
||||||
|
@ -392,7 +498,11 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @return true if that table's log is hflush by other means
|
* Check if deferred log edits are enabled on the table.
|
||||||
|
*
|
||||||
|
* @return true if that deferred log flush is enabled on the table
|
||||||
|
*
|
||||||
|
* @see #setDeferredLogFlush(boolean)
|
||||||
*/
|
*/
|
||||||
public synchronized boolean isDeferredLogFlush() {
|
public synchronized boolean isDeferredLogFlush() {
|
||||||
if(this.isDeferredLog == null) {
|
if(this.isDeferredLog == null) {
|
||||||
|
@ -403,33 +513,48 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param isDeferredLogFlush true if that table's log is hlfush by oter means
|
* This is used to defer the log edits syncing to the file system. Everytime
|
||||||
* only.
|
* an edit is sent to the server it is first sync'd to the file system by the
|
||||||
|
* log writer. This sync is an expensive operation and thus can be deferred so
|
||||||
|
* that the edits are kept in memory for a specified period of time as represented
|
||||||
|
* by <code> hbase.regionserver.optionallogflushinterval </code> and not flushed
|
||||||
|
* for every edit.
|
||||||
|
* <p>
|
||||||
|
* NOTE:- This option might result in data loss if the region server crashes
|
||||||
|
* before these deferred edits in memory are flushed onto the filesystem.
|
||||||
|
* </p>
|
||||||
|
*
|
||||||
|
* @param true if that deferred log flush is enabled on the table.
|
||||||
*/
|
*/
|
||||||
public void setDeferredLogFlush(final boolean isDeferredLogFlush) {
|
public void setDeferredLogFlush(final boolean isDeferredLogFlush) {
|
||||||
setValue(DEFERRED_LOG_FLUSH_KEY, isDeferredLogFlush? TRUE: FALSE);
|
setValue(DEFERRED_LOG_FLUSH_KEY, isDeferredLogFlush? TRUE: FALSE);
|
||||||
this.isDeferredLog = isDeferredLogFlush;
|
this.isDeferredLog = isDeferredLogFlush;
|
||||||
}
|
}
|
||||||
|
|
||||||
/** @return name of table */
|
/**
|
||||||
|
* Get the name of the table as a byte array.
|
||||||
|
*
|
||||||
|
* @return name of table
|
||||||
|
*/
|
||||||
public byte [] getName() {
|
public byte [] getName() {
|
||||||
return name;
|
return name;
|
||||||
}
|
}
|
||||||
|
|
||||||
/** @return name of table */
|
/**
|
||||||
|
* Get the name of the table as a String
|
||||||
|
*
|
||||||
|
* @return name of table as a String
|
||||||
|
*/
|
||||||
public String getNameAsString() {
|
public String getNameAsString() {
|
||||||
return this.nameAsString;
|
return this.nameAsString;
|
||||||
}
|
}
|
||||||
|
|
||||||
/** @return max hregion size for table */
|
|
||||||
public long getMaxFileSize() {
|
|
||||||
byte [] value = getValue(MAX_FILESIZE_KEY);
|
|
||||||
if (value != null)
|
|
||||||
return Long.valueOf(Bytes.toString(value)).longValue();
|
|
||||||
return HConstants.DEFAULT_MAX_FILE_SIZE;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
* This get the class associated with the region split policy which
|
||||||
|
* determines when a region split should occur. The class used by
|
||||||
|
* default is {@link ConstantSizeRegionSplitPolicy} which split the
|
||||||
|
* region base on a constant {@link #getMaxFileSize()}
|
||||||
|
*
|
||||||
* @return the class name of the region split policy for this table.
|
* @return the class name of the region split policy for this table.
|
||||||
* If this returns null, the default constant size based split policy
|
* If this returns null, the default constant size based split policy
|
||||||
* is used.
|
* is used.
|
||||||
|
@ -438,7 +563,11 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
return getValue(SPLIT_POLICY);
|
return getValue(SPLIT_POLICY);
|
||||||
}
|
}
|
||||||
|
|
||||||
/** @param name name of table */
|
/**
|
||||||
|
* Set the name of the table.
|
||||||
|
*
|
||||||
|
* @param name name of table
|
||||||
|
*/
|
||||||
public void setName(byte[] name) {
|
public void setName(byte[] name) {
|
||||||
this.name = name;
|
this.name = name;
|
||||||
this.nameAsString = Bytes.toString(this.name);
|
this.nameAsString = Bytes.toString(this.name);
|
||||||
|
@ -446,6 +575,33 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
* Returns the maximum size upto which a region can grow to after which a region
|
||||||
|
* split is triggered. The region size is represented by the size of the biggest
|
||||||
|
* store file in that region.
|
||||||
|
*
|
||||||
|
* @return max hregion size for table
|
||||||
|
*
|
||||||
|
* @see #setMaxFileSize(long)
|
||||||
|
*/
|
||||||
|
public long getMaxFileSize() {
|
||||||
|
byte [] value = getValue(MAX_FILESIZE_KEY);
|
||||||
|
if (value != null)
|
||||||
|
return Long.valueOf(Bytes.toString(value)).longValue();
|
||||||
|
return HConstants.DEFAULT_MAX_FILE_SIZE;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Sets the maximum size upto which a region can grow to after which a region
|
||||||
|
* split is triggered. The region size is represented by the size of the biggest
|
||||||
|
* store file in that region, i.e. If the biggest store file grows beyond the
|
||||||
|
* maxFileSize, then the region split is triggered. This defaults to a value of
|
||||||
|
* 256 MB.
|
||||||
|
* <p>
|
||||||
|
* This is not an absolute value and might vary. Assume that a single row exceeds
|
||||||
|
* the maxFileSize then the storeFileSize will be greater than maxFileSize since
|
||||||
|
* a single row cannot be split across multiple regions
|
||||||
|
* </p>
|
||||||
|
*
|
||||||
* @param maxFileSize The maximum file size that a store file can grow to
|
* @param maxFileSize The maximum file size that a store file can grow to
|
||||||
* before a split is triggered.
|
* before a split is triggered.
|
||||||
*/
|
*/
|
||||||
|
@ -454,7 +610,11 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
* Returns the size of the memstore after which a flush to filesystem is triggered.
|
||||||
|
*
|
||||||
* @return memory cache flush size for each hregion
|
* @return memory cache flush size for each hregion
|
||||||
|
*
|
||||||
|
* @see #setMemStoreFlushSize(long)
|
||||||
*/
|
*/
|
||||||
public long getMemStoreFlushSize() {
|
public long getMemStoreFlushSize() {
|
||||||
byte [] value = getValue(MEMSTORE_FLUSHSIZE_KEY);
|
byte [] value = getValue(MEMSTORE_FLUSHSIZE_KEY);
|
||||||
|
@ -464,6 +624,9 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
* Represents the maximum size of the memstore after which the contents of the
|
||||||
|
* memstore are flushed to the filesystem. This defaults to a size of 64 MB.
|
||||||
|
*
|
||||||
* @param memstoreFlushSize memory cache flush size for each hregion
|
* @param memstoreFlushSize memory cache flush size for each hregion
|
||||||
*/
|
*/
|
||||||
public void setMemStoreFlushSize(long memstoreFlushSize) {
|
public void setMemStoreFlushSize(long memstoreFlushSize) {
|
||||||
|
@ -473,7 +636,7 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Adds a column family.
|
* Adds a column family.
|
||||||
* @param family HColumnDescriptor of familyto add.
|
* @param family HColumnDescriptor of family to add.
|
||||||
*/
|
*/
|
||||||
public void addFamily(final HColumnDescriptor family) {
|
public void addFamily(final HColumnDescriptor family) {
|
||||||
if (family.getName() == null || family.getName().length <= 0) {
|
if (family.getName() == null || family.getName().length <= 0) {
|
||||||
|
@ -484,11 +647,11 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Checks to see if this table contains the given column family
|
* Checks to see if this table contains the given column family
|
||||||
* @param c Family name or column name.
|
* @param familyName Family name or column name.
|
||||||
* @return true if the table contains the specified family name
|
* @return true if the table contains the specified family name
|
||||||
*/
|
*/
|
||||||
public boolean hasFamily(final byte [] c) {
|
public boolean hasFamily(final byte [] familyName) {
|
||||||
return families.containsKey(c);
|
return families.containsKey(familyName);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -579,6 +742,12 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
* Compare the contents of the descriptor with another one passed as a parameter.
|
||||||
|
* Checks if the obj passed is an instance of HTableDescriptor, if yes then the
|
||||||
|
* contents of the descriptors are compared.
|
||||||
|
*
|
||||||
|
* @return true if the contents of the the two descriptors exactly match
|
||||||
|
*
|
||||||
* @see java.lang.Object#equals(java.lang.Object)
|
* @see java.lang.Object#equals(java.lang.Object)
|
||||||
*/
|
*/
|
||||||
@Override
|
@Override
|
||||||
|
@ -612,7 +781,10 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
}
|
}
|
||||||
|
|
||||||
// Writable
|
// Writable
|
||||||
|
/**
|
||||||
|
* <em> INTERNAL </em> This method is a part of {@link WritableComparable} interface
|
||||||
|
* and is used for de-serialization of the HTableDescriptor over RPC
|
||||||
|
*/
|
||||||
public void readFields(DataInput in) throws IOException {
|
public void readFields(DataInput in) throws IOException {
|
||||||
int version = in.readInt();
|
int version = in.readInt();
|
||||||
if (version < 3)
|
if (version < 3)
|
||||||
|
@ -643,6 +815,10 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* <em> INTERNAL </em> This method is a part of {@link WritableComparable} interface
|
||||||
|
* and is used for serialization of the HTableDescriptor over RPC
|
||||||
|
*/
|
||||||
public void write(DataOutput out) throws IOException {
|
public void write(DataOutput out) throws IOException {
|
||||||
out.writeInt(TABLE_DESCRIPTOR_VERSION);
|
out.writeInt(TABLE_DESCRIPTOR_VERSION);
|
||||||
Bytes.writeByteArray(out, name);
|
Bytes.writeByteArray(out, name);
|
||||||
|
@ -664,6 +840,13 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
|
|
||||||
// Comparable
|
// Comparable
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Compares the descriptor with another descriptor which is passed as a parameter.
|
||||||
|
* This compares the content of the two descriptors and not the reference.
|
||||||
|
*
|
||||||
|
* @return 0 if the contents of the descriptors are exactly matching,
|
||||||
|
* 1 if there is a mismatch in the contents
|
||||||
|
*/
|
||||||
public int compareTo(final HTableDescriptor other) {
|
public int compareTo(final HTableDescriptor other) {
|
||||||
int result = Bytes.compareTo(this.name, other.name);
|
int result = Bytes.compareTo(this.name, other.name);
|
||||||
if (result == 0) {
|
if (result == 0) {
|
||||||
|
@ -694,25 +877,46 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @return Immutable sorted map of families.
|
* Returns an unmodifiable collection of all the {@link HColumnDescriptors}
|
||||||
|
* of all the column families of the table.
|
||||||
|
*
|
||||||
|
* @return Immutable collection of {@link HColumnDescriptor} of all the
|
||||||
|
* column families.
|
||||||
*/
|
*/
|
||||||
public Collection<HColumnDescriptor> getFamilies() {
|
public Collection<HColumnDescriptor> getFamilies() {
|
||||||
return Collections.unmodifiableCollection(this.families.values());
|
return Collections.unmodifiableCollection(this.families.values());
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
* Returns all the column family names of the current table. The map of
|
||||||
|
* HTableDescriptor contains mapping of family name to HColumnDescriptors.
|
||||||
|
* This returns all the keys of the family map which represents the column
|
||||||
|
* family names of the table.
|
||||||
|
*
|
||||||
* @return Immutable sorted set of the keys of the families.
|
* @return Immutable sorted set of the keys of the families.
|
||||||
*/
|
*/
|
||||||
public Set<byte[]> getFamiliesKeys() {
|
public Set<byte[]> getFamiliesKeys() {
|
||||||
return Collections.unmodifiableSet(this.families.keySet());
|
return Collections.unmodifiableSet(this.families.keySet());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Returns an array all the {@link HColumnDescriptor} of the column families
|
||||||
|
* of the table.
|
||||||
|
*
|
||||||
|
* @return Array of all the HColumnDescriptors of the current table
|
||||||
|
*
|
||||||
|
* @see #getFamilies()
|
||||||
|
*/
|
||||||
public HColumnDescriptor[] getColumnFamilies() {
|
public HColumnDescriptor[] getColumnFamilies() {
|
||||||
return getFamilies().toArray(new HColumnDescriptor[0]);
|
return getFamilies().toArray(new HColumnDescriptor[0]);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param column
|
* Returns the HColumnDescriptor for a specific column family with name as
|
||||||
|
* specified by the parameter column.
|
||||||
|
*
|
||||||
|
* @param column Column family name
|
||||||
* @return Column descriptor for the passed family name or the family on
|
* @return Column descriptor for the passed family name or the family on
|
||||||
* passed in column.
|
* passed in column.
|
||||||
*/
|
*/
|
||||||
|
@ -720,8 +924,12 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
return this.families.get(column);
|
return this.families.get(column);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param column
|
* Removes the HColumnDescriptor with name specified by the parameter column
|
||||||
|
* from the table descriptor
|
||||||
|
*
|
||||||
|
* @param column Name of the column family to be removed.
|
||||||
* @return Column descriptor for the passed family name or the family on
|
* @return Column descriptor for the passed family name or the family on
|
||||||
* passed in column.
|
* passed in column.
|
||||||
*/
|
*/
|
||||||
|
@ -729,6 +937,7 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
return this.families.remove(column);
|
return this.families.remove(column);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Add a table coprocessor to this table. The coprocessor
|
* Add a table coprocessor to this table. The coprocessor
|
||||||
* type must be {@link org.apache.hadoop.hbase.coprocessor.RegionObserver}
|
* type must be {@link org.apache.hadoop.hbase.coprocessor.RegionObserver}
|
||||||
|
@ -743,6 +952,7 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
addCoprocessor(className, null, Coprocessor.PRIORITY_USER, null);
|
addCoprocessor(className, null, Coprocessor.PRIORITY_USER, null);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Add a table coprocessor to this table. The coprocessor
|
* Add a table coprocessor to this table. The coprocessor
|
||||||
* type must be {@link org.apache.hadoop.hbase.coprocessor.RegionObserver}
|
* type must be {@link org.apache.hadoop.hbase.coprocessor.RegionObserver}
|
||||||
|
@ -806,6 +1016,13 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
setValue(key, value);
|
setValue(key, value);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Check if the table has an attached co-processor represented by the name className
|
||||||
|
*
|
||||||
|
* @param className - Class name of the co-processor
|
||||||
|
* @return true of the table has a co-processor className
|
||||||
|
*/
|
||||||
public boolean hasCoprocessor(String className) {
|
public boolean hasCoprocessor(String className) {
|
||||||
Matcher keyMatcher;
|
Matcher keyMatcher;
|
||||||
Matcher valueMatcher;
|
Matcher valueMatcher;
|
||||||
|
@ -832,10 +1049,14 @@ public class HTableDescriptor implements WritableComparable<HTableDescriptor> {
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
* Returns the {@link Path} object representing the table directory under
|
||||||
|
* path rootdir
|
||||||
|
*
|
||||||
* @param rootdir qualified path of HBase root directory
|
* @param rootdir qualified path of HBase root directory
|
||||||
* @param tableName name of table
|
* @param tableName name of table
|
||||||
* @return path for table
|
* @return {@link Path} for table
|
||||||
*/
|
*/
|
||||||
public static Path getTableDir(Path rootdir, final byte [] tableName) {
|
public static Path getTableDir(Path rootdir, final byte [] tableName) {
|
||||||
return new Path(rootdir, Bytes.toString(tableName));
|
return new Path(rootdir, Bytes.toString(tableName));
|
||||||
|
|
|
@ -372,7 +372,7 @@ public class MasterFileSystem {
|
||||||
|
|
||||||
private static void setInfoFamilyCachingForRoot(final boolean b) {
|
private static void setInfoFamilyCachingForRoot(final boolean b) {
|
||||||
for (HColumnDescriptor hcd:
|
for (HColumnDescriptor hcd:
|
||||||
HTableDescriptor.ROOT_TABLEDESC.families.values()) {
|
HTableDescriptor.ROOT_TABLEDESC.getColumnFamilies()) {
|
||||||
if (Bytes.equals(hcd.getName(), HConstants.CATALOG_FAMILY)) {
|
if (Bytes.equals(hcd.getName(), HConstants.CATALOG_FAMILY)) {
|
||||||
hcd.setBlockCacheEnabled(b);
|
hcd.setBlockCacheEnabled(b);
|
||||||
hcd.setInMemory(b);
|
hcd.setInMemory(b);
|
||||||
|
@ -382,7 +382,7 @@ public class MasterFileSystem {
|
||||||
|
|
||||||
private static void setInfoFamilyCachingForMeta(final boolean b) {
|
private static void setInfoFamilyCachingForMeta(final boolean b) {
|
||||||
for (HColumnDescriptor hcd:
|
for (HColumnDescriptor hcd:
|
||||||
HTableDescriptor.META_TABLEDESC.families.values()) {
|
HTableDescriptor.META_TABLEDESC.getColumnFamilies()) {
|
||||||
if (Bytes.equals(hcd.getName(), HConstants.CATALOG_FAMILY)) {
|
if (Bytes.equals(hcd.getName(), HConstants.CATALOG_FAMILY)) {
|
||||||
hcd.setBlockCacheEnabled(b);
|
hcd.setBlockCacheEnabled(b);
|
||||||
hcd.setInMemory(b);
|
hcd.setInMemory(b);
|
||||||
|
|
Loading…
Reference in New Issue