public class MergeTask extends MergeTaskBase
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) |
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) |
getPriority, getSegments, getSegmentWriteOutMediumFactory, isReady, run, toString, verifyInputSegments
getInterval
canRestore, equals, getClasspathPrefix, getContext, getDataSource, getGroupId, getId, getNodeType, getQueryRunner, getTaskResource, hashCode, stopGracefully, success
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
getContextValue, getContextValue
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)
public File merge(TaskToolbox toolbox, Map<DataSegment,File> segments, File outDir) throws Exception
merge
in class MergeTaskBase
Exception
public String getType()
Task
public Boolean getRollup()
public IndexSpec getIndexSpec()
public List<AggregatorFactory> getAggregators()
Copyright © 2011–2018. All rights reserved.