Uses of Class
io.druid.segment.realtime.FireDepartmentMetrics

Packages that use FireDepartmentMetrics

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

Uses of FireDepartmentMetrics in io.druid.indexing.common.index

Methods in io.druid.indexing.common.index with parameters of type FireDepartmentMetrics

Modifier and Type	Method and Description
Plumber	YeOldePlumberSchool.findPlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics)

Uses of FireDepartmentMetrics in io.druid.indexing.common.task

Methods in io.druid.indexing.common.task that return FireDepartmentMetrics

Modifier and Type	Method and Description
FireDepartmentMetrics	RealtimeIndexTask.getMetrics() Public for tests.

Uses of FireDepartmentMetrics in io.druid.segment.realtime

Methods in io.druid.segment.realtime that return FireDepartmentMetrics

Modifier and Type	Method and Description
FireDepartmentMetrics	FireDepartment.getMetrics()
FireDepartmentMetrics	RealtimeManager.getMetrics(String datasource)
FireDepartmentMetrics	FireDepartmentMetrics.merge(FireDepartmentMetrics other) merge other FireDepartmentMetrics, will modify this object's data
FireDepartmentMetrics	FireDepartmentMetrics.snapshot()

Methods in io.druid.segment.realtime with parameters of type FireDepartmentMetrics

Modifier and Type	Method and Description
FireDepartmentMetrics	FireDepartmentMetrics.merge(FireDepartmentMetrics other) merge other FireDepartmentMetrics, will modify this object's data

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

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

Modifier and Type	Method and Description
Appenderator	DefaultRealtimeAppenderatorFactory.build(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics)
Appenderator	DefaultOfflineAppenderatorFactory.build(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics)
Appenderator	AppenderatorFactory.build(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics)
static Appenderator	Appenderators.createOffline(DataSchema schema, AppenderatorConfig config, FireDepartmentMetrics metrics, DataSegmentPusher dataSegmentPusher, com.fasterxml.jackson.databind.ObjectMapper objectMapper, IndexIO indexIO, IndexMerger indexMerger)
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, ServiceEmitter emitter, ExecutorService queryExecutorService, Cache cache, CacheConfig cacheConfig)
Plumber	AppenderatorPlumberSchool.findPlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics)

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

Constructor and Description
AppenderatorImpl(DataSchema schema, AppenderatorConfig tuningConfig, FireDepartmentMetrics metrics, DataSegmentPusher dataSegmentPusher, com.fasterxml.jackson.databind.ObjectMapper objectMapper, QueryRunnerFactoryConglomerate conglomerate, DataSegmentAnnouncer segmentAnnouncer, 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)
StreamAppenderatorDriver(Appenderator appenderator, SegmentAllocator segmentAllocator, SegmentHandoffNotifierFactory handoffNotifierFactory, UsedSegmentChecker usedSegmentChecker, com.fasterxml.jackson.databind.ObjectMapper objectMapper, FireDepartmentMetrics metrics) Create a driver.

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

Methods in io.druid.segment.realtime.plumber with parameters of type FireDepartmentMetrics

Modifier and Type	Method and Description
static void	Plumbers.addNextRow(com.google.common.base.Supplier<Committer> committerSupplier, Firehose firehose, Plumber plumber, boolean reportParseExceptions, FireDepartmentMetrics metrics)
Plumber	RealtimePlumberSchool.findPlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics)
Plumber	PlumberSchool.findPlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics) Creates a Plumber
Plumber	FlushingPlumberSchool.findPlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics)

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

Constructor and Description
FlushingPlumber(org.joda.time.Duration flushDuration, DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics, ServiceEmitter emitter, QueryRunnerFactoryConglomerate conglomerate, DataSegmentAnnouncer segmentAnnouncer, ExecutorService queryExecutorService, IndexMerger indexMerger, IndexIO indexIO, Cache cache, CacheConfig cacheConfig, com.fasterxml.jackson.databind.ObjectMapper objectMapper)
RealtimePlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics, 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)