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, TaskActionClient taskActionClient, 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, SegmentHandoffNotifierFactory handoffNotifierFactory, QueryRunnerFactoryConglomerate queryRunnerFactoryConglomerate, ExecutorService queryExecutorService, com.metamx.metrics.MonitorScheduler monitorScheduler, SegmentLoader segmentLoader, com.fasterxml.jackson.databind.ObjectMapper objectMapper, File taskWorkDir, Cache cache, CacheConfig cacheConfig)
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, SegmentHandoffNotifierFactory handoffNotifierFactory, QueryRunnerFactoryConglomerate queryRunnerFactoryConglomerate, ExecutorService queryExecutorService, com.metamx.metrics.MonitorScheduler monitorScheduler, SegmentLoaderFactory segmentLoaderFactory, com.fasterxml.jackson.databind.ObjectMapper objectMapper, Cache cache, CacheConfig cacheConfig)

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, Cache cache, CacheConfig cacheConfig, com.fasterxml.jackson.databind.ObjectMapper objectMapper)
FlushingPlumberSchool(org.joda.time.Duration flushDuration, com.metamx.emitter.service.ServiceEmitter emitter, QueryRunnerFactoryConglomerate conglomerate, DataSegmentAnnouncer segmentAnnouncer, ExecutorService queryExecutorService, Cache cache, CacheConfig cacheConfig, com.fasterxml.jackson.databind.ObjectMapper objectMapper)
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, SegmentHandoffNotifier handoffNotifier, Cache cache, CacheConfig cacheConfig, com.fasterxml.jackson.databind.ObjectMapper objectMapper)
RealtimePlumberSchool(com.metamx.emitter.service.ServiceEmitter emitter, QueryRunnerFactoryConglomerate conglomerate, io.druid.segment.loading.DataSegmentPusher dataSegmentPusher, DataSegmentAnnouncer segmentAnnouncer, SegmentPublisher segmentPublisher, SegmentHandoffNotifierFactory handoffNotifierFactory, ExecutorService executorService, Cache cache, CacheConfig cacheConfig, com.fasterxml.jackson.databind.ObjectMapper objectMapper)

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)