Package | Description |
---|---|
io.druid.indexing.common | |
io.druid.query | |
io.druid.segment.realtime | |
io.druid.segment.realtime.plumber | |
io.druid.server.coordination |
Modifier and Type | Method and Description |
---|---|
QueryRunnerFactoryConglomerate |
TaskToolbox.getQueryRunnerFactoryConglomerate() |
Constructor and Description |
---|
TaskToolbox(TaskConfig config,
Task task,
TaskActionClientFactory taskActionClientFactory,
com.metamx.emitter.service.ServiceEmitter emitter,
io.druid.segment.loading.DataSegmentPusher segmentPusher,
io.druid.segment.loading.DataSegmentKiller dataSegmentKiller,
io.druid.segment.loading.DataSegmentMover dataSegmentMover,
io.druid.segment.loading.DataSegmentArchiver dataSegmentArchiver,
DataSegmentAnnouncer segmentAnnouncer,
FilteredServerView newSegmentServerView,
QueryRunnerFactoryConglomerate queryRunnerFactoryConglomerate,
ExecutorService queryExecutorService,
com.metamx.metrics.MonitorScheduler monitorScheduler,
SegmentLoader segmentLoader,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
File taskWorkDir) |
TaskToolboxFactory(TaskConfig config,
TaskActionClientFactory taskActionClientFactory,
com.metamx.emitter.service.ServiceEmitter emitter,
io.druid.segment.loading.DataSegmentPusher segmentPusher,
io.druid.segment.loading.DataSegmentKiller dataSegmentKiller,
io.druid.segment.loading.DataSegmentMover dataSegmentMover,
io.druid.segment.loading.DataSegmentArchiver dataSegmentArchiver,
DataSegmentAnnouncer segmentAnnouncer,
FilteredServerView newSegmentServerView,
QueryRunnerFactoryConglomerate queryRunnerFactoryConglomerate,
ExecutorService queryExecutorService,
com.metamx.metrics.MonitorScheduler monitorScheduler,
SegmentLoaderFactory segmentLoaderFactory,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultQueryRunnerFactoryConglomerate |
Constructor and Description |
---|
RealtimeManager(List<FireDepartment> fireDepartments,
QueryRunnerFactoryConglomerate conglomerate) |
Constructor and Description |
---|
FlushingPlumber(org.joda.time.Duration flushDuration,
DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics,
com.metamx.emitter.service.ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService) |
FlushingPlumberSchool(org.joda.time.Duration flushDuration,
com.metamx.emitter.service.ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService,
org.joda.time.Period windowPeriod,
File basePersistDirectory,
com.metamx.common.Granularity segmentGranularity,
VersioningPolicy versioningPolicy,
RejectionPolicyFactory rejectionPolicy,
RejectionPolicyFactory rejectionPolicyFactory,
int maxPendingPersists) |
RealtimePlumber(DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics,
com.metamx.emitter.service.ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService,
io.druid.segment.loading.DataSegmentPusher dataSegmentPusher,
SegmentPublisher segmentPublisher,
FilteredServerView serverView) |
RealtimePlumberSchool(com.metamx.emitter.service.ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
io.druid.segment.loading.DataSegmentPusher dataSegmentPusher,
DataSegmentAnnouncer segmentAnnouncer,
SegmentPublisher segmentPublisher,
FilteredServerView serverView,
ExecutorService executorService,
org.joda.time.Period windowPeriod,
File basePersistDirectory,
com.metamx.common.Granularity segmentGranularity,
VersioningPolicy versioningPolicy,
RejectionPolicyFactory rejectionPolicy,
RejectionPolicyFactory rejectionPolicyFactory,
int maxPendingPersists) |
Constructor and Description |
---|
ServerManager(SegmentLoader segmentLoader,
QueryRunnerFactoryConglomerate conglomerate,
com.metamx.emitter.service.ServiceEmitter emitter,
ExecutorService exec,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
Cache cache,
CacheConfig cacheConfig) |
Copyright © 2015. All rights reserved.