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, 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 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)
FiniteAppenderatorDriver(Appenderator appenderator, SegmentAllocator segmentAllocator, SegmentHandoffNotifierFactory handoffNotifierFactory, UsedSegmentChecker usedSegmentChecker, com.fasterxml.jackson.databind.ObjectMapper objectMapper, int maxRowsPerSegment, long handoffConditionTimeout, 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(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)