co.cask.cdap.data2.registry

Class UsageRegistry

java.lang.Object

co.cask.cdap.data2.registry.UsageRegistry

public class UsageRegistry
extends Object

Store program/adapter -> dataset/stream usage information. TODO: Reduce duplication between this and UsageDataset.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	UsageRegistry.UsageDatasetIterable For passing UsageDataset to Transactional.of(co.cask.tephra.TransactionExecutorFactory, com.google.common.base.Supplier<T>).

Constructor Summary

Constructors

Constructor and Description
UsageRegistry(co.cask.tephra.TransactionExecutorFactory txExecutorFactory, DatasetProvider provider)

Method Summary

Methods

Modifier and Type	Method and Description
Set<Id.DatasetInstance>	getDatasets(Id.Application id)
Set<Id.DatasetInstance>	getDatasets(Id.Program id)
Set<Id.Program>	getPrograms(Id.DatasetInstance id)
Set<Id.Program>	getPrograms(Id.Stream id)
Set<Id.Stream>	getStreams(Id.Application id)
Set<Id.Stream>	getStreams(Id.Program id)
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	register(Id user, Id.DatasetInstance datasetId) Registers usage of a dataset by multiple ids.
void	register(Id user, Id.Stream streamId) Register usage of a stream by an id.
void	registerAll(Iterable<? extends Id> users, Id.DatasetInstance datasetId) Registers usage of a dataset by multiple ids.
void	registerAll(Iterable<? extends Id> users, Id.Stream streamId) Registers usage of a stream by multiple ids.
static void	setupDatasets(DatasetFramework datasetFramework) Adds datasets and types to the given DatasetFramework used by usage registry.
void	unregister(Id.Application applicationId) Unregisters all usage information of an application.

Methods inherited from class java.lang.Object

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

Constructor Detail

UsageRegistry

@Inject
public UsageRegistry(co.cask.tephra.TransactionExecutorFactory txExecutorFactory,
                    DatasetProvider provider)

Method Detail

registerAll

public void registerAll(Iterable<? extends Id> users,
               Id.Stream streamId)

Registers usage of a stream by multiple ids.

Parameters:

users - the users of the stream

streamId - the stream

register

public void register(Id user,
            Id.Stream streamId)

Register usage of a stream by an id.

Parameters:

user - the user of the stream

streamId - the stream

registerAll

public void registerAll(Iterable<? extends Id> users,
               Id.DatasetInstance datasetId)

Registers usage of a dataset by multiple ids.

Parameters:

users - the users of the dataset

datasetId - the dataset

register

public void register(Id user,
            Id.DatasetInstance datasetId)

Registers usage of a dataset by multiple ids.

Parameters:

user - the user of the dataset

datasetId - the dataset

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.Application id)

getStreams

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

getDatasets

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

getStreams

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

getPrograms

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

getPrograms

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

setupDatasets

public static void setupDatasets(DatasetFramework datasetFramework)
                          throws IOException,
                                 DatasetManagementException

Adds datasets and types to the given DatasetFramework used by usage registry.

Parameters:

datasetFramework - framework to add types and datasets to

Throws:

IOException

DatasetManagementException