co.cask.cdap.data.stream.service

Class MDSStreamMetaStore

java.lang.Object

co.cask.cdap.data.stream.service.MDSStreamMetaStore

All Implemented Interfaces:

StreamMetaStore

public final class MDSStreamMetaStore
extends Object
implements StreamMetaStore

Implementation of StreamMetaStore that access MDS directly.

Constructor Summary

Constructors

Constructor and Description
MDSStreamMetaStore(co.cask.tephra.TransactionExecutorFactory txExecutorFactory, DatasetFramework dsFramework)

Method Summary

Methods

Modifier and Type	Method and Description
void	addStream(Id.Stream streamId) Adds a stream to the meta store.
com.google.common.collect.Multimap<Id.Namespace,co.cask.cdap.api.data.stream.StreamSpecification>	listStreams() List all stream specifications with their associated Id.Namespace.
List<co.cask.cdap.api.data.stream.StreamSpecification>	listStreams(Id.Namespace namespaceId) List all stream specifications stored for the namespaceId.
void	removeStream(Id.Stream streamId) Removes a stream from the meta store.
boolean	streamExists(Id.Stream streamId) Checks if a stream exists in the meta store.

Methods inherited from class java.lang.Object

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

Constructor Detail

MDSStreamMetaStore

@Inject
public MDSStreamMetaStore(co.cask.tephra.TransactionExecutorFactory txExecutorFactory,
                         DatasetFramework dsFramework)

Method Detail

addStream

public void addStream(Id.Stream streamId)
               throws Exception

Description copied from interface: StreamMetaStore

Adds a stream to the meta store.

Specified by:

addStream in interface StreamMetaStore

Throws:

Exception

removeStream

public void removeStream(Id.Stream streamId)
                  throws Exception

Description copied from interface: StreamMetaStore

Removes a stream from the meta store.

Specified by:

removeStream in interface StreamMetaStore

Throws:

Exception

streamExists

public boolean streamExists(Id.Stream streamId)
                     throws Exception

Description copied from interface: StreamMetaStore

Checks if a stream exists in the meta store.

Specified by:

streamExists in interface StreamMetaStore

Throws:

Exception

listStreams

public List<co.cask.cdap.api.data.stream.StreamSpecification> listStreams(Id.Namespace namespaceId)
                                                                   throws Exception

Description copied from interface: StreamMetaStore

List all stream specifications stored for the namespaceId.

Specified by:

listStreams in interface StreamMetaStore

Throws:

Exception

listStreams

public com.google.common.collect.Multimap<Id.Namespace,co.cask.cdap.api.data.stream.StreamSpecification> listStreams()
                                                                                                              throws Exception

Description copied from interface: StreamMetaStore

List all stream specifications with their associated Id.Namespace.

Specified by:

listStreams in interface StreamMetaStore

Throws:

Exception