Uses of Interface
co.cask.cdap.data2.transaction.stream.StreamAdmin

Packages that use StreamAdmin

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.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 StreamAdmin in co.cask.cdap.data.stream

Methods in co.cask.cdap.data.stream with parameters of type StreamAdmin

Modifier and Type	Method and Description
static StreamConfig	StreamUtils.ensureExists(StreamAdmin admin, Id.Stream streamId)

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

Constructor and Description
StreamFileJanitor(CConfiguration cConf, StreamAdmin streamAdmin, NamespacedLocationFactory namespacedLocationFactory, NamespaceStore namespaceStore)
StreamInputFormatProvider(Id.Namespace namespaceId, co.cask.cdap.api.data.stream.StreamBatchReadable streamBatchReadable, StreamAdmin streamAdmin)
StreamViewHttpHandler(StreamAdmin admin)

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

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

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)
StreamHandler(CConfiguration cConf, StreamCoordinatorClient streamCoordinatorClient, StreamAdmin streamAdmin, StreamFileWriterFactory writerFactory, MetricsCollectionService metricsCollectionService, StreamWriterSizeCollector sizeCollector, AbstractNamespaceClient namespaceClient)

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

Classes in co.cask.cdap.data2.transaction.queue.inmemory that implement StreamAdmin

Modifier and Type	Class and Description
class	InMemoryStreamAdmin admin for queues in memory.

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

Classes in co.cask.cdap.data2.transaction.stream that implement StreamAdmin

Modifier and Type	Class and Description
class	FileStreamAdmin An abstract base StreamAdmin for File based stream.

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

Constructor and Description
AbstractStreamFileConsumerFactory(CConfiguration cConf, StreamAdmin streamAdmin, StreamConsumerStateStoreFactory stateStoreFactory)