public class TaskToolbox extends Object
Constructor and Description |
---|
TaskToolbox(TaskConfig config,
TaskActionClient taskActionClient,
ServiceEmitter emitter,
DataSegmentPusher segmentPusher,
DataSegmentKiller dataSegmentKiller,
DataSegmentMover dataSegmentMover,
DataSegmentArchiver dataSegmentArchiver,
DataSegmentAnnouncer segmentAnnouncer,
DataSegmentServerAnnouncer serverAnnouncer,
SegmentHandoffNotifierFactory handoffNotifierFactory,
com.google.inject.Provider<QueryRunnerFactoryConglomerate> queryRunnerFactoryConglomerateProvider,
ExecutorService queryExecutorService,
MonitorScheduler monitorScheduler,
SegmentLoader segmentLoader,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
File taskWorkDir,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
IndexMergerV9 indexMergerV9,
DruidNodeAnnouncer druidNodeAnnouncer,
DruidNode druidNode,
LookupNodeService lookupNodeService,
DataNodeService dataNodeService) |
public TaskToolbox(TaskConfig config, TaskActionClient taskActionClient, ServiceEmitter emitter, DataSegmentPusher segmentPusher, DataSegmentKiller dataSegmentKiller, DataSegmentMover dataSegmentMover, DataSegmentArchiver dataSegmentArchiver, DataSegmentAnnouncer segmentAnnouncer, DataSegmentServerAnnouncer serverAnnouncer, SegmentHandoffNotifierFactory handoffNotifierFactory, com.google.inject.Provider<QueryRunnerFactoryConglomerate> queryRunnerFactoryConglomerateProvider, ExecutorService queryExecutorService, MonitorScheduler monitorScheduler, SegmentLoader segmentLoader, com.fasterxml.jackson.databind.ObjectMapper objectMapper, File taskWorkDir, IndexIO indexIO, Cache cache, CacheConfig cacheConfig, IndexMergerV9 indexMergerV9, DruidNodeAnnouncer druidNodeAnnouncer, DruidNode druidNode, LookupNodeService lookupNodeService, DataNodeService dataNodeService)
public TaskConfig getConfig()
public TaskActionClient getTaskActionClient()
public ServiceEmitter getEmitter()
public DataSegmentPusher getSegmentPusher()
public DataSegmentKiller getDataSegmentKiller()
public DataSegmentMover getDataSegmentMover()
public DataSegmentArchiver getDataSegmentArchiver()
public DataSegmentAnnouncer getSegmentAnnouncer()
public DataSegmentServerAnnouncer getDataSegmentServerAnnouncer()
public SegmentHandoffNotifierFactory getSegmentHandoffNotifierFactory()
public QueryRunnerFactoryConglomerate getQueryRunnerFactoryConglomerate()
public ExecutorService getQueryExecutorService()
public MonitorScheduler getMonitorScheduler()
public com.fasterxml.jackson.databind.ObjectMapper getObjectMapper()
public Map<DataSegment,File> fetchSegments(List<DataSegment> segments) throws SegmentLoadingException
SegmentLoadingException
public void publishSegments(Iterable<DataSegment> segments) throws IOException
IOException
public IndexIO getIndexIO()
public Cache getCache()
public CacheConfig getCacheConfig()
public IndexMergerV9 getIndexMergerV9()
public File getFirehoseTemporaryDir()
public File getMergeDir()
public File getPersistDir()
public DruidNodeAnnouncer getDruidNodeAnnouncer()
public LookupNodeService getLookupNodeService()
public DataNodeService getDataNodeService()
public DruidNode getDruidNode()
Copyright © 2011–2018. All rights reserved.