| Package | Description | 
|---|---|
| io.druid.segment.realtime.appenderator | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AppenderatorImpl  | 
| Modifier and Type | Field and Description | 
|---|---|
protected Appenderator | 
BaseAppenderatorDriver.appenderator  | 
| 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)  | 
| Constructor and Description | 
|---|
AppenderatorPlumber(DataSchema schema,
                   RealtimeTuningConfig config,
                   FireDepartmentMetrics metrics,
                   DataSegmentAnnouncer segmentAnnouncer,
                   SegmentPublisher segmentPublisher,
                   SegmentHandoffNotifier handoffNotifier,
                   Appenderator appenderator)  | 
BatchAppenderatorDriver(Appenderator appenderator,
                       SegmentAllocator segmentAllocator,
                       UsedSegmentChecker usedSegmentChecker)
Create a driver. 
 | 
StreamAppenderatorDriver(Appenderator appenderator,
                        SegmentAllocator segmentAllocator,
                        SegmentHandoffNotifierFactory handoffNotifierFactory,
                        UsedSegmentChecker usedSegmentChecker,
                        com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                        FireDepartmentMetrics metrics)
Create a driver. 
 | 
Copyright © 2011–2018. All rights reserved.