io.druid.indexing.common.task

Class MergeTask

java.lang.Object

io.druid.indexing.common.task.AbstractTask

io.druid.indexing.common.task.AbstractFixedIntervalTask

io.druid.indexing.common.task.MergeTaskBase

io.druid.indexing.common.task.MergeTask

All Implemented Interfaces:

Task

Direct Known Subclasses:

SameIntervalMergeTask.SubTask

public class MergeTask
extends MergeTaskBase

Constructor Summary

Constructors

Constructor and Description
MergeTask(String id, String dataSource, List<DataSegment> segments, List<AggregatorFactory> aggregators, Boolean rollup, IndexSpec indexSpec, Boolean buildV9Directly, SegmentWriteOutMediumFactory segmentWriteOutMediumFactory, Map<String,Object> context)

Method Summary

Modifier and Type	Method and Description
List<AggregatorFactory>	getAggregators()
IndexSpec	getIndexSpec()
Boolean	getRollup()
String	getType() Returns a descriptive label for this task type.
File	merge(TaskToolbox toolbox, Map<DataSegment,File> segments, File outDir)

Methods inherited from class io.druid.indexing.common.task.MergeTaskBase

getPriority, getSegments, getSegmentWriteOutMediumFactory, isReady, run, toString, verifyInputSegments

Methods inherited from class io.druid.indexing.common.task.AbstractFixedIntervalTask

getInterval

Methods inherited from class io.druid.indexing.common.task.AbstractTask

canRestore, equals, getClasspathPrefix, getContext, getDataSource, getGroupId, getId, getNodeType, getQueryRunner, getTaskResource, hashCode, stopGracefully, success

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface io.druid.indexing.common.task.Task

getContextValue, getContextValue

Constructor Detail

MergeTask

public MergeTask(String id,
                 String dataSource,
                 List<DataSegment> segments,
                 List<AggregatorFactory> aggregators,
                 Boolean rollup,
                 IndexSpec indexSpec,
                 Boolean buildV9Directly,
                 @Nullable
                 SegmentWriteOutMediumFactory segmentWriteOutMediumFactory,
                 Map<String,Object> context)

Method Detail

merge

public File merge(TaskToolbox toolbox,
                  Map<DataSegment,File> segments,
                  File outDir)
           throws Exception

Specified by:

merge in class MergeTaskBase

Throws:

Exception

getType

public String getType()

Description copied from interface: Task

Returns a descriptive label for this task type. Used for metrics emission and logging.

Returns:

task type label

getRollup

public Boolean getRollup()

getIndexSpec

public IndexSpec getIndexSpec()

getAggregators

public List<AggregatorFactory> getAggregators()