| co.cask.cdap.data |
This package contains implementations of the data fabric.
|
| co.cask.cdap.data.dataset |
This package contains implementations of the data set framework and built-in data sets.
|
| co.cask.cdap.data.file |
This package contains classes for interacting with data files.
|
| co.cask.cdap.data.file.filter |
|
| co.cask.cdap.data.runtime |
This package contains implementations and guice-bindings needed for data-fabric runtime.
|
| co.cask.cdap.data.security |
|
| co.cask.cdap.data.stream |
This package contains classes for management and manipulation of stream files.
|
| co.cask.cdap.data.stream.decoder |
|
| 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.stream.service.heartbeat |
|
| co.cask.cdap.data.stream.service.upload |
|
| co.cask.cdap.data.view |
|
| co.cask.cdap.data2 |
This package contains implementations of the data fabric v2.
|
| co.cask.cdap.data2.datafabric |
|
| co.cask.cdap.data2.datafabric.dataset |
|
| co.cask.cdap.data2.datafabric.dataset.instance |
|
| co.cask.cdap.data2.datafabric.dataset.service |
|
| co.cask.cdap.data2.datafabric.dataset.service.executor |
|
| co.cask.cdap.data2.datafabric.dataset.service.mds |
|
| co.cask.cdap.data2.datafabric.dataset.type |
|
| co.cask.cdap.data2.dataset2 |
This package contains implementations of the dataset system v2.
|
| co.cask.cdap.data2.dataset2.lib.cube |
This package contains Cube implementation that stores
CubeFacts and allows querying its data.
|
| co.cask.cdap.data2.dataset2.lib.file |
|
| co.cask.cdap.data2.dataset2.lib.hbase |
This package contains HBase implementations of the dataset system v2.
|
| co.cask.cdap.data2.dataset2.lib.kv |
|
| co.cask.cdap.data2.dataset2.lib.partitioned |
|
| co.cask.cdap.data2.dataset2.lib.table |
|
| co.cask.cdap.data2.dataset2.lib.table.hbase |
This package contains HBase implementations of the table dataset.
|
| co.cask.cdap.data2.dataset2.lib.table.inmemory |
This package contains in-memory implementations of the table dataset.
|
| co.cask.cdap.data2.dataset2.lib.table.leveldb |
This package contains LevelDB implementations of the table dataset.
|
| co.cask.cdap.data2.dataset2.lib.timeseries |
This package contains FactTable that handle storing time series Facts.
|
| co.cask.cdap.data2.dataset2.module.lib |
|
| co.cask.cdap.data2.dataset2.module.lib.hbase |
|
| co.cask.cdap.data2.dataset2.module.lib.inmemory |
|
| co.cask.cdap.data2.dataset2.module.lib.leveldb |
|
| co.cask.cdap.data2.dataset2.tx |
|
| co.cask.cdap.data2.increment.hbase |
|
| co.cask.cdap.data2.metadata.dataset |
|
| co.cask.cdap.data2.metadata.indexer |
|
| co.cask.cdap.data2.metadata.lineage |
|
| co.cask.cdap.data2.metadata.publisher |
|
| co.cask.cdap.data2.metadata.store |
|
| co.cask.cdap.data2.metadata.system |
|
| co.cask.cdap.data2.metadata.writer |
|
| co.cask.cdap.data2.metrics |
|
| co.cask.cdap.data2.queue |
API definition for queue for the txds2 system.
|
| co.cask.cdap.data2.registry |
|
| co.cask.cdap.data2.registry.internal.keymaker |
|
| co.cask.cdap.data2.registry.internal.pair |
|
| co.cask.cdap.data2.transaction |
|
| co.cask.cdap.data2.transaction.coprocessor |
|
| co.cask.cdap.data2.transaction.metrics |
|
| co.cask.cdap.data2.transaction.queue |
Transaction aware queue implementation.
|
| co.cask.cdap.data2.transaction.queue.hbase |
This package contains an HBase implementation of queues.
|
| co.cask.cdap.data2.transaction.queue.hbase.coprocessor |
|
| co.cask.cdap.data2.transaction.queue.inmemory |
This package contains in memory implementation of queues.
|
| co.cask.cdap.data2.transaction.queue.leveldb |
This package contains levelDB implementation of queues.
|
| co.cask.cdap.data2.transaction.snapshot |
|
| co.cask.cdap.data2.transaction.stream |
This package contains transaction stream consumer classes for maintaining stateful consumption of stream entries.
|
| 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.transaction.stream.inmemory |
|
| co.cask.cdap.data2.transaction.stream.leveldb |
This package contains class for stream consumer implementation that uses LevelDB as state store.
|
| co.cask.cdap.data2.util |
|
| co.cask.cdap.data2.util.hbase |
|
| co.cask.cdap.hbase.wd |
Classes in this package implement row salting approach to distribute writes with monotonically increasing keys to
multiple regions.
|
| co.cask.cdap.store |
|
| co.cask.cdap.store.guice |
|