Uses of Interface
co.cask.cdap.data.stream.StreamCoordinatorClient

Packages that use StreamCoordinatorClient

Package	Description
co.cask.cdap.data.stream	This package contains classes for management and manipulation of stream files.
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.stream	This package contains transaction stream consumer classes for maintaining stateful consumption of stream entries.

Uses of StreamCoordinatorClient in co.cask.cdap.data.stream

Classes in co.cask.cdap.data.stream that implement StreamCoordinatorClient

Modifier and Type	Class and Description
class	AbstractStreamCoordinatorClient Base implementation for StreamCoordinatorClient.
class	DistributedStreamCoordinatorClient A StreamCoordinatorClient uses ZooKeeper to implementation coordination needed for stream.
class	InMemoryStreamCoordinatorClient In memory implementation for StreamCoordinatorClient.

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

Methods in co.cask.cdap.data.stream.service that return StreamCoordinatorClient

Modifier and Type	Method and Description
protected StreamCoordinatorClient	AbstractStreamService.getStreamCoordinatorClient()

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

Constructor and Description
AbstractStreamService(StreamCoordinatorClient streamCoordinatorClient, StreamFileJanitorService janitorService, StreamWriterSizeCollector sizeCollector, MetricStore metricStore)
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)
StreamHandler(CConfiguration cConf, StreamCoordinatorClient streamCoordinatorClient, StreamAdmin streamAdmin, StreamFileWriterFactory writerFactory, MetricsCollectionService metricsCollectionService, StreamWriterSizeCollector sizeCollector, AbstractNamespaceClient namespaceClient)

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

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

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)