Uses of Interface
co.cask.cdap.data.stream.service.StreamMetaStore

Packages that use StreamMetaStore

Package	Description
co.cask.cdap.data.stream.service	This package contains class for running stream http service as well as twill runnable for running the service in YARN.
co.cask.cdap.data2.transaction.queue.inmemory	This package contains in memory implementation of queues.
co.cask.cdap.data2.transaction.stream	This package contains transaction stream consumer classes for maintaining stateful consumption of stream entries.

Uses of StreamMetaStore in co.cask.cdap.data.stream.service

Classes in co.cask.cdap.data.stream.service that implement StreamMetaStore

Modifier and Type	Class and Description
class	InMemoryStreamMetaStore In-memory implementation of the StreamMetaStore.
class	MDSStreamMetaStore Implementation of StreamMetaStore that access MDS directly.

Constructors in co.cask.cdap.data.stream.service with parameters of type StreamMetaStore

Constructor and Description
DistributedStreamService(CConfiguration cConf, StreamAdmin streamAdmin, StreamCoordinatorClient streamCoordinatorClient, StreamFileJanitorService janitorService, ZKClient zkClient, DiscoveryServiceClient discoveryServiceClient, StreamMetaStore streamMetaStore, com.google.common.base.Supplier<Discoverable> discoverableSupplier, StreamWriterSizeCollector streamWriterSizeCollector, HeartbeatPublisher heartbeatPublisher, NotificationFeedManager feedManager, NotificationService notificationService, MetricStore metricStore)
LocalStreamService(StreamCoordinatorClient streamCoordinatorClient, StreamFileJanitorService janitorService, StreamMetaStore streamMetaStore, StreamAdmin streamAdmin, StreamWriterSizeCollector streamWriterSizeCollector, NotificationService notificationService, MetricStore metricStore)
StreamFetchHandler(CConfiguration cConf, StreamAdmin streamAdmin, StreamMetaStore streamMetaStore)

Uses of StreamMetaStore in co.cask.cdap.data2.transaction.queue.inmemory

Constructors in co.cask.cdap.data2.transaction.queue.inmemory with parameters of type StreamMetaStore

Constructor and Description
InMemoryStreamAdmin(InMemoryQueueService queueService, UsageRegistry usageRegistry, LineageWriter lineageWriter, StreamMetaStore streamMetaStore, MetadataStore metadataStore, ViewAdmin viewAdmin)

Uses of StreamMetaStore in co.cask.cdap.data2.transaction.stream

Constructors in co.cask.cdap.data2.transaction.stream with parameters of type StreamMetaStore

Constructor and Description

FileStreamAdmin(NamespacedLocationFactory namespacedLocationFactory, CConfiguration cConf, StreamCoordinatorClient streamCoordinatorClient, StreamConsumerStateStoreFactory stateStoreFactory, NotificationFeedManager notificationFeedManager, UsageRegistry usageRegistry, LineageWriter lineageWriter, StreamMetaStore streamMetaStore, ExploreTableNaming tableNaming, MetadataStore metadataStore, ViewAdmin viewAdmin)