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, 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)

Method Summary

Methods

Modifier and Type	Method and Description
Map<io.druid.timeline.DataSegment,File>	fetchSegments(List<io.druid.timeline.DataSegment> segments)
TaskConfig	getConfig()
io.druid.segment.loading.DataSegmentArchiver	getDataSegmentArchiver()
io.druid.segment.loading.DataSegmentKiller	getDataSegmentKiller()
io.druid.segment.loading.DataSegmentMover	getDataSegmentMover()
com.metamx.emitter.service.ServiceEmitter	getEmitter()
com.metamx.metrics.MonitorScheduler	getMonitorScheduler()
FilteredServerView	getNewSegmentServerView()
com.fasterxml.jackson.databind.ObjectMapper	getObjectMapper()
ExecutorService	getQueryExecutorService()
QueryRunnerFactoryConglomerate	getQueryRunnerFactoryConglomerate()
DataSegmentAnnouncer	getSegmentAnnouncer()
io.druid.segment.loading.DataSegmentPusher	getSegmentPusher()
TaskActionClient	getTaskActionClient()
File	getTaskWorkDir()
void	pushSegments(Iterable<io.druid.timeline.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,
           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)

Method Detail

getConfig

public TaskConfig getConfig()

getTaskActionClient

public TaskActionClient getTaskActionClient()

getEmitter

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

getSegmentPusher

public io.druid.segment.loading.DataSegmentPusher getSegmentPusher()

getDataSegmentKiller

public io.druid.segment.loading.DataSegmentKiller getDataSegmentKiller()

getDataSegmentMover

public io.druid.segment.loading.DataSegmentMover getDataSegmentMover()

getDataSegmentArchiver

public io.druid.segment.loading.DataSegmentArchiver getDataSegmentArchiver()

getSegmentAnnouncer

public DataSegmentAnnouncer getSegmentAnnouncer()

getNewSegmentServerView

public FilteredServerView getNewSegmentServerView()

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<io.druid.timeline.DataSegment,File> fetchSegments(List<io.druid.timeline.DataSegment> segments)
                                                      throws io.druid.segment.loading.SegmentLoadingException

Throws:

io.druid.segment.loading.SegmentLoadingException

pushSegments

public void pushSegments(Iterable<io.druid.timeline.DataSegment> segments)
                  throws IOException

Throws:

IOException

getTaskWorkDir

public File getTaskWorkDir()