| Package | Description |
|---|---|
| co.cask.cdap.data.dataset |
This package contains implementations of the data set framework and built-in data sets.
|
| co.cask.cdap.data.stream.service |
This package contains class for running stream http service as well as twill runnable for running the service in
YARN.
|
| co.cask.cdap.data.view | |
| co.cask.cdap.data2.datafabric.dataset | |
| co.cask.cdap.data2.datafabric.dataset.service.mds | |
| co.cask.cdap.data2.dataset2 |
This package contains implementations of the dataset system v2.
|
| co.cask.cdap.data2.dataset2.lib.table | |
| co.cask.cdap.data2.metadata.lineage | |
| co.cask.cdap.data2.metadata.store | |
| co.cask.cdap.data2.metadata.writer | |
| co.cask.cdap.data2.metrics | |
| co.cask.cdap.data2.registry | |
| co.cask.cdap.data2.transaction.queue.hbase |
This package contains an HBase implementation of queues.
|
| Constructor and Description |
|---|
SystemDatasetInstantiator(DatasetFramework datasetFramework,
ClassLoader classLoader,
Iterable<? extends Id> owners) |
SystemDatasetInstantiatorFactory(LocationFactory locationFactory,
DatasetFramework datasetFramework,
CConfiguration cConf) |
| Constructor and Description |
|---|
MDSStreamMetaStore(co.cask.tephra.TransactionExecutorFactory txExecutorFactory,
DatasetFramework dsFramework) |
| Constructor and Description |
|---|
MDSViewStore(DatasetFramework datasetFramework,
co.cask.tephra.TransactionExecutorFactory executorFactory) |
| Modifier and Type | Class and Description |
|---|---|
class |
RemoteDatasetFramework
DatasetFramework implementation that talks to DatasetFramework Service |
| Modifier and Type | Method and Description |
|---|---|
static void |
DatasetsUtil.createIfNotExists(DatasetFramework datasetFramework,
Id.DatasetInstance datasetInstanceId,
String typeName,
co.cask.cdap.api.dataset.DatasetProperties props)
Creates instance of the data set if not exists
|
static <T extends co.cask.cdap.api.dataset.Dataset> |
DatasetsUtil.getOrCreateDataset(DatasetFramework datasetFramework,
Id.DatasetInstance datasetInstanceId,
String typeName,
co.cask.cdap.api.dataset.DatasetProperties props,
Map<String,String> arguments,
ClassLoader cl)
Gets instance of
Dataset, while add instance to
DatasetFramework and creating the physical data set
if that one doesn't exist. |
static void |
DatasetMetaTableUtil.setupDatasets(DatasetFramework datasetFramework)
Adds datasets and types to the given
DatasetFramework used by dataset service mds. |
| Constructor and Description |
|---|
DatasetMetaTableUtil(DatasetFramework framework) |
DefaultDatasetProvider(DatasetFramework framework) |
| Constructor and Description |
|---|
MDSDatasetsRegistry(TransactionSystemClientService txClient,
DatasetFramework framework) |
| Modifier and Type | Class and Description |
|---|---|
class |
InMemoryDatasetFramework
A simple implementation of
DatasetFramework that keeps its state in
memory |
class |
StaticDatasetFramework
In memory
DatasetFramework implementation that has fixed set of DatasetModules. |
| Modifier and Type | Field and Description |
|---|---|
protected DatasetFramework |
MetaTableUtil.dsFramework |
| Constructor and Description |
|---|
MetaTableUtil(DatasetFramework framework,
CConfiguration conf) |
| Modifier and Type | Method and Description |
|---|---|
static void |
LineageStore.setupDatasets(DatasetFramework framework)
Adds datasets and types to the given
DatasetFramework. |
| Constructor and Description |
|---|
LineageStore(co.cask.tephra.TransactionExecutorFactory executorFactory,
DatasetFramework datasetFramework) |
LineageStore(co.cask.tephra.TransactionExecutorFactory executorFactory,
DatasetFramework datasetFramework,
Id.DatasetInstance lineageDatasetId) |
| Modifier and Type | Method and Description |
|---|---|
static void |
DefaultMetadataStore.setupDatasets(DatasetFramework framework)
Adds datasets and types to the given
DatasetFramework. |
| Modifier and Type | Class and Description |
|---|---|
class |
LineageWriterDatasetFramework
DatasetFramework that also records lineage (program-dataset access) records. |
| Constructor and Description |
|---|
HBaseDatasetMetricsReporter(MetricsCollectionService metricsService,
HBaseTableUtil hBaseTableUtil,
Configuration hConf,
CConfiguration conf,
DatasetFramework dsFramework) |
LevelDBDatasetMetricsReporter(MetricsCollectionService metricsService,
LevelDBTableService ldbService,
DatasetFramework dsFramework,
CConfiguration conf) |
| Modifier and Type | Method and Description |
|---|---|
static void |
UsageRegistry.setupDatasets(DatasetFramework datasetFramework)
Adds datasets and types to the given
DatasetFramework used by usage registry. |
| 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) |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.