public class TaskToolbox extends Object
Constructor and Description |
---|
TaskToolbox(TaskConfig config,
Task task,
TaskActionClient taskActionClient,
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,
SegmentHandoffNotifierFactory handoffNotifierFactory,
QueryRunnerFactoryConglomerate queryRunnerFactoryConglomerate,
ExecutorService queryExecutorService,
com.metamx.metrics.MonitorScheduler monitorScheduler,
SegmentLoader segmentLoader,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
File taskWorkDir,
IndexMerger indexMerger,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
IndexMergerV9 indexMergerV9) |
public TaskToolbox(TaskConfig config, Task task, TaskActionClient taskActionClient, 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, SegmentHandoffNotifierFactory handoffNotifierFactory, QueryRunnerFactoryConglomerate queryRunnerFactoryConglomerate, ExecutorService queryExecutorService, com.metamx.metrics.MonitorScheduler monitorScheduler, SegmentLoader segmentLoader, com.fasterxml.jackson.databind.ObjectMapper objectMapper, File taskWorkDir, IndexMerger indexMerger, IndexIO indexIO, Cache cache, CacheConfig cacheConfig, IndexMergerV9 indexMergerV9)
public TaskConfig getConfig()
public TaskActionClient getTaskActionClient()
public com.metamx.emitter.service.ServiceEmitter getEmitter()
public io.druid.segment.loading.DataSegmentPusher getSegmentPusher()
public io.druid.segment.loading.DataSegmentKiller getDataSegmentKiller()
public io.druid.segment.loading.DataSegmentMover getDataSegmentMover()
public io.druid.segment.loading.DataSegmentArchiver getDataSegmentArchiver()
public DataSegmentAnnouncer getSegmentAnnouncer()
public SegmentHandoffNotifierFactory getSegmentHandoffNotifierFactory()
public QueryRunnerFactoryConglomerate getQueryRunnerFactoryConglomerate()
public ExecutorService getQueryExecutorService()
public com.metamx.metrics.MonitorScheduler getMonitorScheduler()
public com.fasterxml.jackson.databind.ObjectMapper getObjectMapper()
public Map<io.druid.timeline.DataSegment,File> fetchSegments(List<io.druid.timeline.DataSegment> segments) throws io.druid.segment.loading.SegmentLoadingException
io.druid.segment.loading.SegmentLoadingException
public void pushSegments(Iterable<io.druid.timeline.DataSegment> segments) throws IOException
IOException
public File getTaskWorkDir()
public IndexIO getIndexIO()
public IndexMerger getIndexMerger()
public Cache getCache()
public CacheConfig getCacheConfig()
public IndexMergerV9 getIndexMergerV9()
Copyright © 2011–2016. All rights reserved.