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

Packages that use DataSegmentAnnouncer

Package	Description
io.druid.indexing.common
io.druid.segment.realtime.appenderator
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, DataSegmentPusher segmentPusher, DataSegmentKiller dataSegmentKiller, DataSegmentMover dataSegmentMover, 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, IndexMerger indexMerger, IndexIO indexIO, Cache cache, CacheConfig cacheConfig, IndexMergerV9 indexMergerV9)
TaskToolboxFactory(TaskConfig config, TaskActionClientFactory taskActionClientFactory, com.metamx.emitter.service.ServiceEmitter emitter, DataSegmentPusher segmentPusher, DataSegmentKiller dataSegmentKiller, DataSegmentMover dataSegmentMover, DataSegmentArchiver dataSegmentArchiver, DataSegmentAnnouncer segmentAnnouncer, SegmentHandoffNotifierFactory handoffNotifierFactory, QueryRunnerFactoryConglomerate queryRunnerFactoryConglomerate, ExecutorService queryExecutorService, com.metamx.metrics.MonitorScheduler monitorScheduler, SegmentLoaderFactory segmentLoaderFactory, com.fasterxml.jackson.databind.ObjectMapper objectMapper, IndexMerger indexMerger, IndexIO indexIO, Cache cache, CacheConfig cacheConfig, IndexMergerV9 indexMergerV9)

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

Methods in io.druid.segment.realtime.appenderator with parameters of type DataSegmentAnnouncer

Modifier and Type

Method and Description

static Appenderator

Appenderators.createRealtime(DataSchema schema, AppenderatorConfig config, FireDepartmentMetrics metrics, DataSegmentPusher dataSegmentPusher, com.fasterxml.jackson.databind.ObjectMapper objectMapper, IndexIO indexIO, IndexMerger indexMerger, QueryRunnerFactoryConglomerate conglomerate, DataSegmentAnnouncer segmentAnnouncer, com.metamx.emitter.service.ServiceEmitter emitter, ExecutorService queryExecutorService, Cache cache, CacheConfig cacheConfig)

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

Constructor and Description
AppenderatorImpl(DataSchema schema, AppenderatorConfig tuningConfig, FireDepartmentMetrics metrics, DataSegmentPusher dataSegmentPusher, com.fasterxml.jackson.databind.ObjectMapper objectMapper, QueryRunnerFactoryConglomerate conglomerate, DataSegmentAnnouncer segmentAnnouncer, com.metamx.emitter.service.ServiceEmitter emitter, ExecutorService queryExecutorService, IndexIO indexIO, IndexMerger indexMerger, Cache cache, CacheConfig cacheConfig)
AppenderatorPlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics, DataSegmentAnnouncer segmentAnnouncer, SegmentPublisher segmentPublisher, SegmentHandoffNotifier handoffNotifier, Appenderator appenderator)
AppenderatorPlumberSchool(AppenderatorFactory appenderatorFactory, DataSegmentAnnouncer segmentAnnouncer, SegmentHandoffNotifierFactory handoffNotifierFactory, SegmentPublisher segmentPublisher)
DefaultRealtimeAppenderatorFactory(com.metamx.emitter.service.ServiceEmitter emitter, QueryRunnerFactoryConglomerate conglomerate, DataSegmentAnnouncer segmentAnnouncer, ExecutorService queryExecutorService, DataSegmentPusher dataSegmentPusher, com.fasterxml.jackson.databind.ObjectMapper objectMapper, IndexIO indexIO, IndexMerger indexMerger, 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, IndexMerger indexMerger, IndexIO indexIO, 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, IndexMerger indexMerger, IndexMergerV9 indexMergerV9, IndexIO indexIO, 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, DataSegmentPusher dataSegmentPusher, SegmentPublisher segmentPublisher, SegmentHandoffNotifier handoffNotifier, IndexMerger indexMerger, IndexIO indexIO, Cache cache, CacheConfig cacheConfig, com.fasterxml.jackson.databind.ObjectMapper objectMapper)
RealtimePlumberSchool(com.metamx.emitter.service.ServiceEmitter emitter, QueryRunnerFactoryConglomerate conglomerate, DataSegmentPusher dataSegmentPusher, DataSegmentAnnouncer segmentAnnouncer, SegmentPublisher segmentPublisher, SegmentHandoffNotifierFactory handoffNotifierFactory, ExecutorService executorService, IndexMerger indexMerger, IndexMergerV9 indexMergerV9, IndexIO indexIO, 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

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

Modifier and Type	Method and Description
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, ScheduledExecutorFactory factory)