| Package | Description |
|---|---|
| co.cask.cdap.data2.datafabric.dataset.service | |
| co.cask.cdap.data2.dataset2.lib.hbase |
This package contains HBase implementations of the dataset system v2.
|
| co.cask.cdap.data2.dataset2.lib.table.hbase |
This package contains HBase implementations of the table dataset.
|
| co.cask.cdap.data2.metrics | |
| co.cask.cdap.data2.transaction.queue.hbase |
This package contains an HBase implementation of queues.
|
| co.cask.cdap.data2.transaction.stream.hbase |
This package contains class for stream consumer implementation that uses HBase as state store.
|
| co.cask.cdap.data2.util.hbase |
| Constructor and Description |
|---|
DistributedStorageProviderNamespaceAdmin(CConfiguration cConf,
NamespacedLocationFactory namespacedLocationFactory,
ExploreFacade exploreFacade,
HBaseTableUtil tableUtil) |
| Modifier and Type | Field and Description |
|---|---|
protected HBaseTableUtil |
AbstractHBaseDataSetAdmin.tableUtil |
| Constructor and Description |
|---|
AbstractHBaseDataSetAdmin(TableId tableId,
Configuration hConf,
HBaseTableUtil tableUtil) |
| Modifier and Type | Method and Description |
|---|---|
static AbstractHBaseDataSetAdmin.CoprocessorJar |
HBaseTableAdmin.createCoprocessorJarInternal(CConfiguration conf,
LocationFactory locationFactory,
HBaseTableUtil tableUtil,
boolean transactional,
boolean supportsReadlessIncrement) |
| Constructor and Description |
|---|
HBaseMetricsTable(co.cask.cdap.api.dataset.DatasetContext datasetContext,
co.cask.cdap.api.dataset.DatasetSpecification spec,
Configuration hConf,
HBaseTableUtil tableUtil) |
HBaseTable(co.cask.cdap.api.dataset.DatasetContext datasetContext,
co.cask.cdap.api.dataset.DatasetSpecification spec,
CConfiguration cConf,
Configuration hConf,
HBaseTableUtil tableUtil) |
HBaseTableAdmin(co.cask.cdap.api.dataset.DatasetContext datasetContext,
co.cask.cdap.api.dataset.DatasetSpecification spec,
Configuration hConf,
HBaseTableUtil tableUtil,
CConfiguration conf,
LocationFactory locationFactory) |
MetricHBaseTableUtil(HBaseTableUtil tableUtil) |
| Constructor and Description |
|---|
HBaseDatasetMetricsReporter(MetricsCollectionService metricsService,
HBaseTableUtil hBaseTableUtil,
Configuration hConf,
CConfiguration conf,
DatasetFramework dsFramework) |
| Modifier and Type | Field and Description |
|---|---|
protected HBaseTableUtil |
HBaseQueueAdmin.tableUtil |
| Constructor and Description |
|---|
HBaseQueueAdmin(Configuration hConf,
CConfiguration cConf,
LocationFactory locationFactory,
HBaseTableUtil tableUtil,
DatasetFramework datasetFramework,
co.cask.tephra.TransactionExecutorFactory txExecutorFactory) |
HBaseQueueAdmin(Configuration hConf,
CConfiguration cConf,
LocationFactory locationFactory,
HBaseTableUtil tableUtil,
DatasetFramework datasetFramework,
co.cask.tephra.TransactionExecutorFactory txExecutorFactory,
QueueConstants.QueueType type) |
HBaseQueueClientFactory(CConfiguration cConf,
Configuration hConf,
HBaseTableUtil hBaseTableUtil,
QueueAdmin queueAdmin,
co.cask.tephra.TransactionExecutorFactory txExecutorFactory) |
ShardedHBaseQueueStrategy(HBaseTableUtil tableUtil,
int distributorBuckets)
Constructs a new instance with the given number of buckets for distributed scan.
|
| Constructor and Description |
|---|
HBaseStreamFileConsumer(CConfiguration cConf,
StreamConfig streamConfig,
ConsumerConfig consumerConfig,
HBaseTableUtil tableUtil,
org.apache.hadoop.hbase.client.HTable hTable,
FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader,
StreamConsumerStateStore stateStore,
StreamConsumerState beginConsumerState,
ReadFilter extraFilter,
AbstractRowKeyDistributor keyDistributor)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
protected HBaseTableUtil |
HBaseTableUtilFactory.createInstance(String className) |
| Modifier and Type | Method and Description |
|---|---|
static Class<? extends HBaseTableUtil> |
HBaseTableUtilFactory.getHBaseTableUtilClass() |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.