co.cask.cdap.data2.registry

Class UsageDataset

java.lang.Object

co.cask.cdap.api.dataset.lib.AbstractDataset

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

co.cask.cdap.data2.registry.UsageDataset

All Implemented Interfaces:

co.cask.cdap.api.dataset.Dataset, co.cask.cdap.api.dataset.metrics.MeteredDataset, co.cask.tephra.TransactionAware, Closeable, AutoCloseable

public class UsageDataset
extends MetadataStoreDataset

Store program/adapter -> dataset/stream usage information.

Nested Class Summary

Nested classes/interfaces inherited from class co.cask.cdap.data2.dataset2.lib.table.MetadataStoreDataset

MetadataStoreDataset.KeyValue<T>

Constructor Summary

Constructors

Constructor and Description
UsageDataset(co.cask.cdap.api.dataset.table.Table table)

Method Summary

Methods

Modifier and Type	Method and Description
Set<Id.DatasetInstance>	getDatasets(Id.Application applicationId) Returns datasets used by an application.
Set<Id.DatasetInstance>	getDatasets(Id.Program programId) Returns datasets used by a program.
Set<Id.Program>	getPrograms(Id.DatasetInstance datasetInstanceId) Returns programs using dataset.
Set<Id.Program>	getPrograms(Id.Stream streamId) Returns programs using stream.
Set<Id.Stream>	getStreams(Id.Application applicationId) Returns streams used by an application.
Set<Id.Stream>	getStreams(Id.Program programId) Returns streams used by a program.
void	register(Id.Program programId, Id.DatasetInstance datasetInstanceId) Registers usage of a dataset by a program.
void	register(Id.Program programId, Id.Stream streamId) Registers usage of a stream by a program.
void	unregister(Id.Application applicationId) Unregisters all usage information of an application.

Methods inherited from class co.cask.cdap.data2.dataset2.lib.table.MetadataStoreDataset

deleteAll, deserialize, exists, get, getFirst, list, list, list, listKV, listKV, listKV, scan, serialize, write

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

close, commitTx, getName, getTransactionAwareName, getTxChanges, postTxCommit, rollbackTx, setMetricsCollector, startTx, toString, updateTx

Methods inherited from class java.lang.Object

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

Constructor Detail

UsageDataset

public UsageDataset(co.cask.cdap.api.dataset.table.Table table)

Method Detail

register

public void register(Id.Program programId,
            Id.DatasetInstance datasetInstanceId)

Registers usage of a dataset by a program.

Parameters:

programId - program

datasetInstanceId - dataset

register

public void register(Id.Program programId,
            Id.Stream streamId)

Registers usage of a stream by a program.

Parameters:

programId - program

streamId - stream

unregister

public void unregister(Id.Application applicationId)

Unregisters all usage information of an application.

Parameters:

applicationId - application

getDatasets

public Set<Id.DatasetInstance> getDatasets(Id.Program programId)

Returns datasets used by a program.

Parameters:

programId - program

Returns:

datasets used by programId

getDatasets

public Set<Id.DatasetInstance> getDatasets(Id.Application applicationId)

Returns datasets used by an application.

Parameters:

applicationId - application

Returns:

datasets used by applicaionId

getStreams

public Set<Id.Stream> getStreams(Id.Program programId)

Returns streams used by a program.

Parameters:

programId - program

Returns:

streams used by programId

getStreams

public Set<Id.Stream> getStreams(Id.Application applicationId)

Returns streams used by an application.

Parameters:

applicationId - application

Returns:

streams used by applicaionId

getPrograms

public Set<Id.Program> getPrograms(Id.DatasetInstance datasetInstanceId)

Returns programs using dataset.

Parameters:

datasetInstanceId - dataset

Returns:

programs using datasetInstanceId

getPrograms

public Set<Id.Program> getPrograms(Id.Stream streamId)

Returns programs using stream.

Parameters:

streamId - stream

Returns:

programs using streamId