Uses of Interface
io.druid.segment.realtime.plumber.SegmentHandoffNotifierFactory

Packages that use SegmentHandoffNotifierFactory

Package	Description
io.druid.indexing.common
io.druid.segment.realtime.appenderator
io.druid.segment.realtime.plumber

Uses of SegmentHandoffNotifierFactory in io.druid.indexing.common

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

Modifier and Type	Method and Description
SegmentHandoffNotifierFactory	TaskToolbox.getSegmentHandoffNotifierFactory()

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

Constructor and Description
TaskToolbox(TaskConfig config, TaskActionClient taskActionClient, ServiceEmitter emitter, DataSegmentPusher segmentPusher, DataSegmentKiller dataSegmentKiller, DataSegmentMover dataSegmentMover, DataSegmentArchiver dataSegmentArchiver, DataSegmentAnnouncer segmentAnnouncer, DataSegmentServerAnnouncer serverAnnouncer, SegmentHandoffNotifierFactory handoffNotifierFactory, com.google.inject.Provider<QueryRunnerFactoryConglomerate> queryRunnerFactoryConglomerateProvider, ExecutorService queryExecutorService, MonitorScheduler monitorScheduler, SegmentLoader segmentLoader, com.fasterxml.jackson.databind.ObjectMapper objectMapper, File taskWorkDir, IndexIO indexIO, Cache cache, CacheConfig cacheConfig, IndexMergerV9 indexMergerV9, DruidNodeAnnouncer druidNodeAnnouncer, DruidNode druidNode, LookupNodeService lookupNodeService, DataNodeService dataNodeService)
TaskToolboxFactory(TaskConfig config, TaskActionClientFactory taskActionClientFactory, ServiceEmitter emitter, DataSegmentPusher segmentPusher, DataSegmentKiller dataSegmentKiller, DataSegmentMover dataSegmentMover, DataSegmentArchiver dataSegmentArchiver, DataSegmentAnnouncer segmentAnnouncer, DataSegmentServerAnnouncer serverAnnouncer, SegmentHandoffNotifierFactory handoffNotifierFactory, com.google.inject.Provider<QueryRunnerFactoryConglomerate> queryRunnerFactoryConglomerateProvider, ExecutorService queryExecutorService, MonitorScheduler monitorScheduler, SegmentLoaderFactory segmentLoaderFactory, com.fasterxml.jackson.databind.ObjectMapper objectMapper, IndexIO indexIO, Cache cache, CacheConfig cacheConfig, IndexMergerV9 indexMergerV9, DruidNodeAnnouncer druidNodeAnnouncer, DruidNode druidNode, LookupNodeService lookupNodeService, DataNodeService dataNodeService)

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

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

Constructor and Description
AppenderatorPlumberSchool(AppenderatorFactory appenderatorFactory, DataSegmentAnnouncer segmentAnnouncer, SegmentHandoffNotifierFactory handoffNotifierFactory, SegmentPublisher segmentPublisher)
StreamAppenderatorDriver(Appenderator appenderator, SegmentAllocator segmentAllocator, SegmentHandoffNotifierFactory handoffNotifierFactory, UsedSegmentChecker usedSegmentChecker, com.fasterxml.jackson.databind.ObjectMapper objectMapper, FireDepartmentMetrics metrics) Create a driver.

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

Classes in io.druid.segment.realtime.plumber that implement SegmentHandoffNotifierFactory

Modifier and Type	Class and Description
class	CoordinatorBasedSegmentHandoffNotifierFactory
class	NoopSegmentHandoffNotifierFactory

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

Constructor and Description

RealtimePlumberSchool(ServiceEmitter emitter, QueryRunnerFactoryConglomerate conglomerate, DataSegmentPusher dataSegmentPusher, DataSegmentAnnouncer segmentAnnouncer, SegmentPublisher segmentPublisher, SegmentHandoffNotifierFactory handoffNotifierFactory, ExecutorService executorService, IndexMergerV9 indexMergerV9, IndexIO indexIO, Cache cache, CacheConfig cacheConfig, com.fasterxml.jackson.databind.ObjectMapper objectMapper)