Uses of Interface
io.druid.segment.realtime.SegmentPublisher

Packages that use SegmentPublisher

Package	Description
io.druid.guice
io.druid.indexing.common.task
io.druid.segment.realtime
io.druid.segment.realtime.plumber

Uses of SegmentPublisher in io.druid.guice

Methods in io.druid.guice that return SegmentPublisher

Modifier and Type	Method and Description
SegmentPublisher	NoopSegmentPublisherProvider.get()
SegmentPublisher	DbSegmentPublisherProvider.get()

Uses of SegmentPublisher in io.druid.indexing.common.task

Classes in io.druid.indexing.common.task that implement SegmentPublisher

Modifier and Type	Class and Description
static class	RealtimeIndexTask.TaskActionSegmentPublisher

Uses of SegmentPublisher in io.druid.segment.realtime

Classes in io.druid.segment.realtime that implement SegmentPublisher

Modifier and Type	Class and Description
class	DbSegmentPublisher
class	NoopSegmentPublisher

Uses of SegmentPublisher in io.druid.segment.realtime.plumber

Constructors in io.druid.segment.realtime.plumber with parameters of type SegmentPublisher

Constructor and Description
RealtimePlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics, com.metamx.emitter.service.ServiceEmitter emitter, QueryRunnerFactoryConglomerate conglomerate, DataSegmentAnnouncer segmentAnnouncer, ExecutorService queryExecutorService, io.druid.segment.loading.DataSegmentPusher dataSegmentPusher, SegmentPublisher segmentPublisher, FilteredServerView serverView)
RealtimePlumberSchool(com.metamx.emitter.service.ServiceEmitter emitter, QueryRunnerFactoryConglomerate conglomerate, io.druid.segment.loading.DataSegmentPusher dataSegmentPusher, DataSegmentAnnouncer segmentAnnouncer, SegmentPublisher segmentPublisher, FilteredServerView serverView, ExecutorService executorService, org.joda.time.Period windowPeriod, File basePersistDirectory, com.metamx.common.Granularity segmentGranularity, VersioningPolicy versioningPolicy, RejectionPolicyFactory rejectionPolicy, RejectionPolicyFactory rejectionPolicyFactory, int maxPendingPersists)