co.cask.cdap.data.view

Class MDSViewStore

java.lang.Object

co.cask.cdap.data.view.MDSViewStore

All Implemented Interfaces:

ViewStore

public final class MDSViewStore
extends Object
implements ViewStore

Default implementation of ViewStore.

Constructor Summary

Constructors

Constructor and Description
MDSViewStore(DatasetFramework datasetFramework, co.cask.tephra.TransactionExecutorFactory executorFactory)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	createOrUpdate(Id.Stream.View viewId, ViewSpecification spec) Creates a view.
void	delete(Id.Stream.View viewId) Deletes a view.
boolean	exists(Id.Stream.View viewId)
ViewDetail	get(Id.Stream.View viewId)
List<Id.Stream.View>	list(Id.Stream streamId)

Methods inherited from class java.lang.Object

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

Constructor Detail

MDSViewStore

@Inject
public MDSViewStore(DatasetFramework datasetFramework,
                   co.cask.tephra.TransactionExecutorFactory executorFactory)

Method Detail

createOrUpdate

public boolean createOrUpdate(Id.Stream.View viewId,
                     ViewSpecification spec)

Description copied from interface: ViewStore

Creates a view. Updates the view if it already exists.

Specified by:

createOrUpdate in interface ViewStore

Parameters:

viewId - the view

spec - the view config

Returns:

true if a new view was created

exists

public boolean exists(Id.Stream.View viewId)

Specified by:

exists in interface ViewStore

Parameters:

viewId - the view

Returns:

true if the view exists

delete

public void delete(Id.Stream.View viewId)
            throws NotFoundException

Description copied from interface: ViewStore

Deletes a view.

Specified by:

delete in interface ViewStore

Parameters:

viewId - the view

Throws:

NotFoundException

list

public List<Id.Stream.View> list(Id.Stream streamId)

Specified by:

list in interface ViewStore

Parameters:

streamId - the stream

Returns:

list of view IDs for a stream

get

public ViewDetail get(Id.Stream.View viewId)
               throws NotFoundException

Specified by:

get in interface ViewStore

Parameters:

viewId - the view

Returns:

the details of a view

Throws:

NotFoundException