Uses of Interface
io.druid.server.coordination.DataSegmentAnnouncer

Packages that use DataSegmentAnnouncer

Package	Description
io.druid.indexing.common
io.druid.segment.realtime.plumber
io.druid.server.coordination

Uses of DataSegmentAnnouncer in io.druid.indexing.common

Methods in io.druid.indexing.common that return DataSegmentAnnouncer

Modifier and Type	Method and Description
DataSegmentAnnouncer	TaskToolbox.getSegmentAnnouncer()

Constructors in io.druid.indexing.common with parameters of type DataSegmentAnnouncer

Constructor and Description
TaskToolbox(TaskConfig config, Task task, TaskActionClientFactory taskActionClientFactory, com.metamx.emitter.service.ServiceEmitter emitter, io.druid.segment.loading.DataSegmentPusher segmentPusher, io.druid.segment.loading.DataSegmentKiller dataSegmentKiller, io.druid.segment.loading.DataSegmentMover dataSegmentMover, io.druid.segment.loading.DataSegmentArchiver dataSegmentArchiver, DataSegmentAnnouncer segmentAnnouncer, FilteredServerView newSegmentServerView, QueryRunnerFactoryConglomerate queryRunnerFactoryConglomerate, ExecutorService queryExecutorService, com.metamx.metrics.MonitorScheduler monitorScheduler, SegmentLoader segmentLoader, com.fasterxml.jackson.databind.ObjectMapper objectMapper, File taskWorkDir)
TaskToolboxFactory(TaskConfig config, TaskActionClientFactory taskActionClientFactory, com.metamx.emitter.service.ServiceEmitter emitter, io.druid.segment.loading.DataSegmentPusher segmentPusher, io.druid.segment.loading.DataSegmentKiller dataSegmentKiller, io.druid.segment.loading.DataSegmentMover dataSegmentMover, io.druid.segment.loading.DataSegmentArchiver dataSegmentArchiver, DataSegmentAnnouncer segmentAnnouncer, FilteredServerView newSegmentServerView, QueryRunnerFactoryConglomerate queryRunnerFactoryConglomerate, ExecutorService queryExecutorService, com.metamx.metrics.MonitorScheduler monitorScheduler, SegmentLoaderFactory segmentLoaderFactory, com.fasterxml.jackson.databind.ObjectMapper objectMapper)

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

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

Constructor and Description
FlushingPlumber(org.joda.time.Duration flushDuration, DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics, com.metamx.emitter.service.ServiceEmitter emitter, QueryRunnerFactoryConglomerate conglomerate, DataSegmentAnnouncer segmentAnnouncer, ExecutorService queryExecutorService)
FlushingPlumberSchool(org.joda.time.Duration flushDuration, com.metamx.emitter.service.ServiceEmitter emitter, QueryRunnerFactoryConglomerate conglomerate, DataSegmentAnnouncer segmentAnnouncer, ExecutorService queryExecutorService, org.joda.time.Period windowPeriod, File basePersistDirectory, com.metamx.common.Granularity segmentGranularity, VersioningPolicy versioningPolicy, RejectionPolicyFactory rejectionPolicy, RejectionPolicyFactory rejectionPolicyFactory, int maxPendingPersists)
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)

Uses of DataSegmentAnnouncer in io.druid.server.coordination

Classes in io.druid.server.coordination that implement DataSegmentAnnouncer

Modifier and Type	Class and Description
class	AbstractDataSegmentAnnouncer
class	BatchDataSegmentAnnouncer
class	MultipleDataSegmentAnnouncerDataSegmentAnnouncer This class has the greatest name ever
class	SingleDataSegmentAnnouncer

Methods in io.druid.server.coordination that return DataSegmentAnnouncer

Modifier and Type	Method and Description
DataSegmentAnnouncer	LegacyDataSegmentAnnouncerProvider.get()
DataSegmentAnnouncer	BatchDataSegmentAnnouncerProvider.get()

Constructors in io.druid.server.coordination with parameters of type DataSegmentAnnouncer

Constructor and Description
ZkCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, SegmentLoaderConfig config, ZkPathsConfig zkPaths, DruidServerMetadata me, DataSegmentAnnouncer announcer, org.apache.curator.framework.CuratorFramework curator, ServerManager serverManager, com.metamx.common.concurrent.ScheduledExecutorFactory factory)

Constructor parameters in io.druid.server.coordination with type arguments of type DataSegmentAnnouncer

Constructor and Description
MultipleDataSegmentAnnouncerDataSegmentAnnouncer(Iterable<DataSegmentAnnouncer> dataSegmentAnnouncers)