co.cask.cdap.data2.dataset2.lib.table.hbase

Class HBaseTableAdmin

java.lang.Object

co.cask.cdap.data2.dataset2.lib.hbase.AbstractHBaseDataSetAdmin

co.cask.cdap.data2.dataset2.lib.table.hbase.HBaseTableAdmin

All Implemented Interfaces:

co.cask.cdap.api.dataset.DatasetAdmin, Closeable, AutoCloseable

public class HBaseTableAdmin
extends AbstractHBaseDataSetAdmin

Nested Class Summary

Nested classes/interfaces inherited from class co.cask.cdap.data2.dataset2.lib.hbase.AbstractHBaseDataSetAdmin

AbstractHBaseDataSetAdmin.CoprocessorJar

Field Summary

Fields

Modifier and Type	Field and Description
static String	PROPERTY_SPLITS

Fields inherited from class co.cask.cdap.data2.dataset2.lib.hbase.AbstractHBaseDataSetAdmin

hConf, SYSTEM_PROPERTY_FORCE_HBASE_UPGRADE, tableId, tableUtil

Constructor Summary

Constructors

Constructor and Description
HBaseTableAdmin(co.cask.cdap.api.dataset.DatasetContext datasetContext, co.cask.cdap.api.dataset.DatasetSpecification spec, Configuration hConf, HBaseTableUtil tableUtil, CConfiguration conf, LocationFactory locationFactory)

Method Summary

Methods

Modifier and Type	Method and Description
void	create()
protected AbstractHBaseDataSetAdmin.CoprocessorJar	createCoprocessorJar()
static AbstractHBaseDataSetAdmin.CoprocessorJar	createCoprocessorJarInternal(CConfiguration conf, LocationFactory locationFactory, HBaseTableUtil tableUtil, boolean transactional, boolean supportsReadlessIncrement)
static byte[]	getColumnFamily(co.cask.cdap.api.dataset.DatasetSpecification spec) Returns the column family as being set in the given specification.
static boolean	isTransactional(co.cask.cdap.api.dataset.DatasetSpecification spec) Returns whether or not the dataset defined in the given specification is transactional.
static boolean	isTransactional(org.apache.hadoop.hbase.HTableDescriptor desc) Returns whether or not the table defined by the given descriptor has transactions enabled.
static boolean	supportsReadlessIncrements(co.cask.cdap.api.dataset.DatasetSpecification spec) Returns whether or not the dataset defined in the given specification should enable read-less increments.
static boolean	supportsReadlessIncrements(org.apache.hadoop.hbase.HTableDescriptor desc) Returns whether or not the table defined by the given descriptor has read-less increments enabled.
protected boolean	upgradeTable(org.apache.hadoop.hbase.HTableDescriptor tableDescriptor) Modifies the table descriptor for upgrade.

Methods inherited from class co.cask.cdap.data2.dataset2.lib.hbase.AbstractHBaseDataSetAdmin

addCoprocessor, close, drop, exists, getAdmin, getVersion, setVersion, truncate, upgrade, upgradeTable

Methods inherited from class java.lang.Object

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

Field Detail

PROPERTY_SPLITS

public static final String PROPERTY_SPLITS

See Also:

Constant Field Values

Constructor Detail

HBaseTableAdmin

public HBaseTableAdmin(co.cask.cdap.api.dataset.DatasetContext datasetContext,
               co.cask.cdap.api.dataset.DatasetSpecification spec,
               Configuration hConf,
               HBaseTableUtil tableUtil,
               CConfiguration conf,
               LocationFactory locationFactory)
                throws IOException

Throws:

IOException

Method Detail

create

public void create()
            throws IOException

Throws:

IOException

upgradeTable

protected boolean upgradeTable(org.apache.hadoop.hbase.HTableDescriptor tableDescriptor)

Description copied from class: AbstractHBaseDataSetAdmin

Modifies the table descriptor for upgrade.

Specified by:

upgradeTable in class AbstractHBaseDataSetAdmin

Returns:

true if the table descriptor is modified.

createCoprocessorJar

protected AbstractHBaseDataSetAdmin.CoprocessorJar createCoprocessorJar()
                                                                 throws IOException

Specified by:

createCoprocessorJar in class AbstractHBaseDataSetAdmin

Throws:

IOException

createCoprocessorJarInternal

public static AbstractHBaseDataSetAdmin.CoprocessorJar createCoprocessorJarInternal(CConfiguration conf,
                                                                    LocationFactory locationFactory,
                                                                    HBaseTableUtil tableUtil,
                                                                    boolean transactional,
                                                                    boolean supportsReadlessIncrement)
                                                                             throws IOException

Throws:

IOException

supportsReadlessIncrements

public static boolean supportsReadlessIncrements(co.cask.cdap.api.dataset.DatasetSpecification spec)

Returns whether or not the dataset defined in the given specification should enable read-less increments. Defaults to false.

isTransactional

public static boolean isTransactional(co.cask.cdap.api.dataset.DatasetSpecification spec)

Returns whether or not the dataset defined in the given specification is transactional. Defaults to true.

getColumnFamily

public static byte[] getColumnFamily(co.cask.cdap.api.dataset.DatasetSpecification spec)

Returns the column family as being set in the given specification. If it is not set, the DEFAULT_DATA_COLUMN_FAMILY will be returned.

supportsReadlessIncrements

public static boolean supportsReadlessIncrements(org.apache.hadoop.hbase.HTableDescriptor desc)

Returns whether or not the table defined by the given descriptor has read-less increments enabled. Defaults to false.

isTransactional

public static boolean isTransactional(org.apache.hadoop.hbase.HTableDescriptor desc)

Returns whether or not the table defined by the given descriptor has transactions enabled. Defaults to true.