io.druid.segment.realtime.appenderator

Class DefaultRealtimeAppenderatorFactory

java.lang.Object

io.druid.segment.realtime.appenderator.DefaultRealtimeAppenderatorFactory

All Implemented Interfaces:

AppenderatorFactory

public class DefaultRealtimeAppenderatorFactory
extends Object
implements AppenderatorFactory

Constructor Summary

Constructors

Constructor and Description
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)

Method Summary

Modifier and Type	Method and Description
Appenderator	build(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultRealtimeAppenderatorFactory

public 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)

Method Detail

build

public Appenderator build(DataSchema schema,
                          RealtimeTuningConfig config,
                          FireDepartmentMetrics metrics)

Specified by:

build in interface AppenderatorFactory