io.druid.segment.realtime.appenderator

Class Appenderators

java.lang.Object

io.druid.segment.realtime.appenderator.Appenderators

public class Appenderators
extends Object

Constructor Summary

Constructors

Constructor and Description
Appenderators()

Method Summary

Modifier and Type	Method and Description
static Appenderator	createOffline(DataSchema schema, AppenderatorConfig config, FireDepartmentMetrics metrics, DataSegmentPusher dataSegmentPusher, com.fasterxml.jackson.databind.ObjectMapper objectMapper, IndexIO indexIO, IndexMerger indexMerger)
static Appenderator	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)

Methods inherited from class java.lang.Object

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

Constructor Detail

Appenderators

public Appenderators()

Method Detail

createRealtime

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

createOffline

public static Appenderator createOffline(DataSchema schema,
                                         AppenderatorConfig config,
                                         FireDepartmentMetrics metrics,
                                         DataSegmentPusher dataSegmentPusher,
                                         com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                         IndexIO indexIO,
                                         IndexMerger indexMerger)