public class AppendTask extends MergeTaskBase
Constructor and Description |
---|
AppendTask(String id,
String dataSource,
List<DataSegment> segments,
List<AggregatorFactory> aggregators,
IndexSpec indexSpec,
Boolean buildV9Directly,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory,
Map<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
List<AggregatorFactory> |
getAggregators() |
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 AppendTask(String id, String dataSource, List<DataSegment> segments, List<AggregatorFactory> aggregators, 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 List<AggregatorFactory> getAggregators()
Copyright © 2011–2018. All rights reserved.