io.druid.indexing.common

Class TaskToolbox

java.lang.Object

io.druid.indexing.common.TaskToolbox

public class TaskToolbox
extends Object

Stuff that may be needed by a Task in order to conduct its business.

Constructor Summary

Constructors

Constructor and Description

TaskToolbox(TaskConfig config, Task task, TaskActionClient taskActionClient, com.metamx.emitter.service.ServiceEmitter emitter, DataSegmentPusher segmentPusher, DataSegmentKiller dataSegmentKiller, DataSegmentMover dataSegmentMover, 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)

Method Summary

Modifier and Type	Method and Description
Map<DataSegment,File>	fetchSegments(List<DataSegment> segments)
Cache	getCache()
CacheConfig	getCacheConfig()
TaskConfig	getConfig()
DataSegmentArchiver	getDataSegmentArchiver()
DataSegmentKiller	getDataSegmentKiller()
DataSegmentMover	getDataSegmentMover()
com.metamx.emitter.service.ServiceEmitter	getEmitter()
IndexIO	getIndexIO()
IndexMerger	getIndexMerger()
IndexMergerV9	getIndexMergerV9()
com.metamx.metrics.MonitorScheduler	getMonitorScheduler()
com.fasterxml.jackson.databind.ObjectMapper	getObjectMapper()
ExecutorService	getQueryExecutorService()
QueryRunnerFactoryConglomerate	getQueryRunnerFactoryConglomerate()
DataSegmentAnnouncer	getSegmentAnnouncer()
SegmentHandoffNotifierFactory	getSegmentHandoffNotifierFactory()
DataSegmentPusher	getSegmentPusher()
TaskActionClient	getTaskActionClient()
File	getTaskWorkDir()
void	publishSegments(Iterable<DataSegment> segments)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskToolbox

public TaskToolbox(TaskConfig config,
                   Task task,
                   TaskActionClient taskActionClient,
                   com.metamx.emitter.service.ServiceEmitter emitter,
                   DataSegmentPusher segmentPusher,
                   DataSegmentKiller dataSegmentKiller,
                   DataSegmentMover dataSegmentMover,
                   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)

Method Detail

getConfig

public TaskConfig getConfig()

getTaskActionClient

public TaskActionClient getTaskActionClient()

getEmitter

public com.metamx.emitter.service.ServiceEmitter getEmitter()

getSegmentPusher

public DataSegmentPusher getSegmentPusher()

getDataSegmentKiller

public DataSegmentKiller getDataSegmentKiller()

getDataSegmentMover

public DataSegmentMover getDataSegmentMover()

getDataSegmentArchiver

public DataSegmentArchiver getDataSegmentArchiver()

getSegmentAnnouncer

public DataSegmentAnnouncer getSegmentAnnouncer()

getSegmentHandoffNotifierFactory

public SegmentHandoffNotifierFactory getSegmentHandoffNotifierFactory()

getQueryRunnerFactoryConglomerate

public QueryRunnerFactoryConglomerate getQueryRunnerFactoryConglomerate()

getQueryExecutorService

public ExecutorService getQueryExecutorService()

getMonitorScheduler

public com.metamx.metrics.MonitorScheduler getMonitorScheduler()

getObjectMapper

public com.fasterxml.jackson.databind.ObjectMapper getObjectMapper()

fetchSegments

public Map<DataSegment,File> fetchSegments(List<DataSegment> segments)
                                    throws SegmentLoadingException

Throws:

SegmentLoadingException

publishSegments

public void publishSegments(Iterable<DataSegment> segments)
                     throws IOException

Throws:

IOException

getTaskWorkDir

public File getTaskWorkDir()

getIndexIO

public IndexIO getIndexIO()

getIndexMerger

public IndexMerger getIndexMerger()

getCache

public Cache getCache()

getCacheConfig

public CacheConfig getCacheConfig()

getIndexMergerV9

public IndexMergerV9 getIndexMergerV9()