co.cask.cdap.data.stream.service

Interface StreamMetaStore

All Known Implementing Classes:

InMemoryStreamMetaStore, MDSStreamMetaStore

public interface StreamMetaStore

A temporary place for hosting MDS access logic for streams.

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.

Method Detail

addStream

void addStream(Id.Stream streamId)
               throws Exception

Adds a stream to the meta store.

Throws:

Exception

removeStream

void removeStream(Id.Stream streamId)
                  throws Exception

Removes a stream from the meta store.

Throws:

Exception

streamExists

boolean streamExists(Id.Stream streamId)
                     throws Exception

Checks if a stream exists in the meta store.

Throws:

Exception

listStreams

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

List all stream specifications stored for the namespaceId.

Throws:

Exception

listStreams

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

List all stream specifications with their associated Id.Namespace.

Throws:

Exception