| Package | Description | 
|---|---|
| io.druid.indexing.common.task | |
| io.druid.indexing.kafka | |
| io.druid.indexing.kafka.supervisor | |
| io.druid.segment.indexing | |
| io.druid.segment.realtime.appenderator | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
IndexTask.IndexTuningConfig  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
KafkaTuningConfig  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
KafkaSupervisorTuningConfig  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
RealtimeTuningConfig  | 
| Modifier and Type | Method and Description | 
|---|---|
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 | 
|---|
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)  | 
Copyright © 2011–2018. All rights reserved.