co.cask.cdap.data2.transaction.queue.hbase

Class HBaseQueueDatasetModule.HBaseConsumerStateStoreDefinition

java.lang.Object

co.cask.cdap.api.dataset.lib.AbstractDatasetDefinition<HBaseConsumerStateStore,co.cask.cdap.api.dataset.DatasetAdmin>

co.cask.cdap.data2.transaction.queue.hbase.HBaseQueueDatasetModule.HBaseConsumerStateStoreDefinition

All Implemented Interfaces:

co.cask.cdap.api.dataset.DatasetDefinition<HBaseConsumerStateStore,co.cask.cdap.api.dataset.DatasetAdmin>

Enclosing class:

HBaseQueueDatasetModule

public static final class HBaseQueueDatasetModule.HBaseConsumerStateStoreDefinition
extends co.cask.cdap.api.dataset.lib.AbstractDatasetDefinition<HBaseConsumerStateStore,co.cask.cdap.api.dataset.DatasetAdmin>

Dataset definition for the HBaseConsumerStateStore.

Field Summary

Fields inherited from interface co.cask.cdap.api.dataset.DatasetDefinition

NO_ARGUMENTS

Constructor Summary

Constructors

Constructor and Description
HBaseQueueDatasetModule.HBaseConsumerStateStoreDefinition(String name, co.cask.cdap.api.dataset.DatasetDefinition<? extends co.cask.cdap.api.dataset.table.Table,?> tableDefinition)

Method Summary

Methods

Modifier and Type	Method and Description
co.cask.cdap.api.dataset.DatasetSpecification	configure(String name, co.cask.cdap.api.dataset.DatasetProperties properties)
co.cask.cdap.api.dataset.DatasetAdmin	getAdmin(co.cask.cdap.api.dataset.DatasetContext datasetContext, co.cask.cdap.api.dataset.DatasetSpecification spec, ClassLoader classLoader)
HBaseConsumerStateStore	getDataset(co.cask.cdap.api.dataset.DatasetContext datasetContext, co.cask.cdap.api.dataset.DatasetSpecification spec, Map<String,String> arguments, ClassLoader classLoader)

Methods inherited from class co.cask.cdap.api.dataset.lib.AbstractDatasetDefinition

getName

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseQueueDatasetModule.HBaseConsumerStateStoreDefinition

public HBaseQueueDatasetModule.HBaseConsumerStateStoreDefinition(String name,
                                                         co.cask.cdap.api.dataset.DatasetDefinition<? extends co.cask.cdap.api.dataset.table.Table,?> tableDefinition)

Method Detail

configure

public co.cask.cdap.api.dataset.DatasetSpecification configure(String name,
                                                      co.cask.cdap.api.dataset.DatasetProperties properties)

getAdmin

public co.cask.cdap.api.dataset.DatasetAdmin getAdmin(co.cask.cdap.api.dataset.DatasetContext datasetContext,
                                             co.cask.cdap.api.dataset.DatasetSpecification spec,
                                             ClassLoader classLoader)
                                               throws IOException

Throws:

IOException

getDataset

public HBaseConsumerStateStore getDataset(co.cask.cdap.api.dataset.DatasetContext datasetContext,
                                 co.cask.cdap.api.dataset.DatasetSpecification spec,
                                 Map<String,String> arguments,
                                 ClassLoader classLoader)
                                   throws IOException

Throws:

IOException